From aed85746d636f6eec6347fd5ddcfa68267a9d666 Mon Sep 17 00:00:00 2001 From: Israel Herraiz Date: Mon, 27 May 2024 17:46:41 +0200 Subject: [PATCH] Remove pipeline options override from inside connector --- .../java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java index 5b676561bf8c..900be9ccb616 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java @@ -1725,11 +1725,6 @@ && getInclusiveStartAt().toSqlTimestamp().after(getInclusiveEndAt().toSqlTimesta new PostProcessingMetricsDoFn(metrics); LOG.info("Partition metadata table that will be used is " + partitionMetadataTableName); - input - .getPipeline() - .getOptions() - .as(SpannerChangeStreamOptions.class) - .setMetadataTable(partitionMetadataTableName); final PCollection impulseOut = input.apply(Impulse.create()); final PCollection partitionsOut =