Skip to content

spark_dataproc: resolve each jar URL in get_openlineage_jar.sh independently - #343

Merged
tnazarew merged 1 commit into
mainfrom
spark/jar-url-defaults
Oct 21, 2026
Merged

tnazarew merged 1 commit into
mainfrom
spark/jar-url-defaults

Conversation

@tnazarew

Copy link
Copy Markdown
Collaborator

get_openlineage_jar.sh (the Dataproc init action that installs the jars) read the BigQuery connector, Spanner and Bigtable URLs from cluster metadata only when OPENLINEAGE_SPARK_URL was set. Otherwise all four fell back to hardcoded defaults. This means:

  • a cluster created with only OPENLINEAGE_SPARK_URL got empty connector URLs and gsutil cp "" failed;
  • a custom connector URL was ignored whenever the OpenLineage URL was not passed.

Change

Each URL is now read from its own metadata attribute and falls back to its own default (metadata_or_default). The default values are unchanged.

Impact

  • CI (producer_spark_dataproc.yml) passes all four URLs, so the installed jars do not change.
  • Note that CI uploads this script to the shared gs://open-lineage-e2e/scripts/ on every run, so other runs pick it up once this is merged.
  • Local runs that set only some URLs now work. This prepares for the local runner changes, which will come in a separate PR.

Testing

bash -n, plus a run with stubbed get_metadata_value and gsutil:

Metadata set Jars copied
all four all four given URLs
only OPENLINEAGE_SPARK_URL given OpenLineage jar + default BigQuery, Spanner, Bigtable
none all four defaults

Not yet run on a real Dataproc cluster beyond this PR's CI.

🤖 Generated with Claude Code

@tnazarew
tnazarew force-pushed the spark/jar-url-defaults branch from 83876fa to 7bc6223 Compare October 21, 2026 17:08
@tnazarew
tnazarew marked this pull request as ready for review October 21, 2026 17:29
…ndently

Previously the BigQuery connector, Spanner and Bigtable URLs from the
cluster metadata were used only when OPENLINEAGE_SPARK_URL was set;
otherwise all four fell back to the defaults. Now each URL is taken from
its own metadata attribute and falls back to its own default, so e.g.
a cluster created with only OPENLINEAGE_SPARK_URL still gets the
default connectors and a custom connector URL is not ignored.

CI passes all four URLs, so its jars are unchanged.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Signed-off-by: tnazarew <tomasz.nazarewicz@getindata.com>
@tnazarew
tnazarew force-pushed the spark/jar-url-defaults branch from 7bc6223 to f60af65 Compare October 21, 2026 17:29
@tnazarew
tnazarew merged commit 83a9700 into main Oct 21, 2026
2 checks passed
@tnazarew
tnazarew deleted the spark/jar-url-defaults branch October 21, 2026 17:29
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant