From cff70750d922b3e382d1725530ae51b8486be78f Mon Sep 17 00:00:00 2001 From: Sandeep Mishra Date: Fri, 10 Apr 2026 05:41:31 +0000 Subject: [PATCH 1/2] initial commit --- .../main/java/org/apache/beam/it/gcp/TemplateTestBase.java | 5 +++++ .../cloud/teleport/v2/templates/DataStreamToBigQueryIT.java | 2 +- .../cloud/teleport/v2/templates/DataStreamToSpannerIT.java | 2 +- ...aStreamToSpannerWideRowForMax16KeyTablePerDatabaseIT.java | 2 +- ...taStreamToSpannerWideRowForMax9MibTablePerDatabaseIT.java | 2 +- .../DataStreamToSpannerWideRowForMaxColumnsPerTablesIT.java | 2 +- .../DataStreamToSpannerWideRowForMaxTableNameIT.java | 2 +- ...amToSpannerWideRowForMaxTableNameWithMaxColumnNameIT.java | 2 +- .../DatastreamToSpannerReservedKeywordsMySqlIT.java | 2 +- .../DatastreamToSpannerReservedKeywordsPostgresIT.java | 2 +- ...SQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java | 2 +- .../MySQLDatastreamToSpannerDataTypesAndExpressionIT.java | 2 +- .../MySQLDatastreamToSpannerTableAndIndexLimitsIT.java | 2 +- ...SQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java | 2 +- .../templates/PostgreSQLDatastreamToSpannerDataTypesIT.java | 2 +- .../PostgreSQLDatastreamToSpannerTableAndIndexLimitsIT.java | 2 +- .../v2/templates/endtoend/EndToEndTestingITBase.java | 2 +- .../failureinjectiontesting/DataStreamToSpannerFTBase.java | 2 +- .../DataStreamToSpannerMySQLSrcPubsubFT.java | 2 +- .../cloud/teleport/v2/templates/DataStreamToPostgresIT.java | 2 +- .../cloud/teleport/v2/templates/DataStreamToSQLIT.java | 2 +- 21 files changed, 25 insertions(+), 20 deletions(-) diff --git a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java index 78ca1299b4..098ec6b180 100644 --- a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java +++ b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java @@ -841,4 +841,9 @@ private static void cleanUpTemplates(String metafileName) { LOG.warn("Error during clean up staged template.", e); } } + + protected String getPrivateConnectivity() { + return System.getProperty("privateConnectivity", "datastream-connect-2"); + } } + diff --git a/v2/datastream-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQueryIT.java b/v2/datastream-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQueryIT.java index ddade4fd43..fa41b615b4 100644 --- a/v2/datastream-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQueryIT.java +++ b/v2/datastream-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQueryIT.java @@ -108,7 +108,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); bigQueryResourceManager = diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerIT.java index 290470c0cd..0e8275a0b8 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerIT.java @@ -109,7 +109,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); gcsResourceManager = setUpSpannerITGcsResourceManager(); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax16KeyTablePerDatabaseIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax16KeyTablePerDatabaseIT.java index c308f99585..aaa458459c 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax16KeyTablePerDatabaseIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax16KeyTablePerDatabaseIT.java @@ -94,7 +94,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); spannerResourceManager = setUpSpannerResourceManager(); pubsubResourceManager = setUpPubSubResourceManager(); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax9MibTablePerDatabaseIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax9MibTablePerDatabaseIT.java index 5191e29860..a20a576849 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax9MibTablePerDatabaseIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax9MibTablePerDatabaseIT.java @@ -103,7 +103,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); spannerResourceManager = setUpSpannerResourceManager(); pubsubResourceManager = setUpPubSubResourceManager(); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxColumnsPerTablesIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxColumnsPerTablesIT.java index f3f38a4614..51c4627327 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxColumnsPerTablesIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxColumnsPerTablesIT.java @@ -95,7 +95,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); spannerResourceManager = setUpSpannerResourceManager(); pubsubResourceManager = setUpPubSubResourceManager(); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameIT.java index 707f880e4d..336a77b924 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameIT.java @@ -95,7 +95,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); spannerResourceManager = setUpSpannerResourceManager(); pubsubResourceManager = setUpPubSubResourceManager(); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameWithMaxColumnNameIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameWithMaxColumnNameIT.java index 0808e81979..9d7aac4892 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameWithMaxColumnNameIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameWithMaxColumnNameIT.java @@ -97,7 +97,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); spannerResourceManager = setUpSpannerResourceManager(); pubsubResourceManager = setUpPubSubResourceManager(); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerReservedKeywordsMySqlIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerReservedKeywordsMySqlIT.java index c5479e2778..33b90e364c 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerReservedKeywordsMySqlIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerReservedKeywordsMySqlIT.java @@ -89,7 +89,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); LOG.info("Datastream resource manager created"); } diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerReservedKeywordsPostgresIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerReservedKeywordsPostgresIT.java index c4c1426a35..d3e54f1424 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerReservedKeywordsPostgresIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerReservedKeywordsPostgresIT.java @@ -98,7 +98,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); LOG.info("Datastream resource manager created"); } diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java index a27caf6706..048cee34a4 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java @@ -105,7 +105,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); LOG.info("Datastream resource manager created"); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerDataTypesAndExpressionIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerDataTypesAndExpressionIT.java index b7954e9d8e..2450a411c4 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerDataTypesAndExpressionIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerDataTypesAndExpressionIT.java @@ -122,7 +122,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); LOG.info("Datastream resource manager created"); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerTableAndIndexLimitsIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerTableAndIndexLimitsIT.java index 08f3b0035c..6d2b0ef305 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerTableAndIndexLimitsIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDatastreamToSpannerTableAndIndexLimitsIT.java @@ -104,7 +104,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); LOG.info("Datastream resource manager created"); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java index 7b34a4b0c3..ae17ada963 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToPGDialectSpannerTableAndIndexLimitsIT.java @@ -119,7 +119,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); LOG.info("Datastream resource manager created"); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerDataTypesIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerDataTypesIT.java index 549c6e7b60..3f99a790a8 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerDataTypesIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerDataTypesIT.java @@ -165,7 +165,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); LOG.info("Datastream resource manager created"); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerTableAndIndexLimitsIT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerTableAndIndexLimitsIT.java index 1600e4a877..4ab80b56e5 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerTableAndIndexLimitsIT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDatastreamToSpannerTableAndIndexLimitsIT.java @@ -118,7 +118,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); LOG.info("Datastream resource manager created"); diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/endtoend/EndToEndTestingITBase.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/endtoend/EndToEndTestingITBase.java index af7bc8aeaa..bfbaa39afd 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/endtoend/EndToEndTestingITBase.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/endtoend/EndToEndTestingITBase.java @@ -443,7 +443,7 @@ public PipelineLauncher.LaunchInfo launchFwdDataflowJob( datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); Stream stream = createDataStreamResources( diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/failureinjectiontesting/DataStreamToSpannerFTBase.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/failureinjectiontesting/DataStreamToSpannerFTBase.java index 8d1b28d7de..064d64b19c 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/failureinjectiontesting/DataStreamToSpannerFTBase.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/failureinjectiontesting/DataStreamToSpannerFTBase.java @@ -179,7 +179,7 @@ public PipelineLauncher.LaunchInfo launchFwdDataflowJob( datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); Stream stream = createDataStreamResources( diff --git a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/failureinjectiontesting/DataStreamToSpannerMySQLSrcPubsubFT.java b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/failureinjectiontesting/DataStreamToSpannerMySQLSrcPubsubFT.java index 30f5e2353a..3c8c474c67 100644 --- a/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/failureinjectiontesting/DataStreamToSpannerMySQLSrcPubsubFT.java +++ b/v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/failureinjectiontesting/DataStreamToSpannerMySQLSrcPubsubFT.java @@ -197,7 +197,7 @@ public void pubsubDuplicateMessageDeliveryFITest() throws IOException, Interrupt datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); Stream stream = createDataStreamResources( diff --git a/v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgresIT.java b/v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgresIT.java index 328aeea81b..9934272634 100644 --- a/v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgresIT.java +++ b/v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgresIT.java @@ -89,7 +89,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") // Use the parameter + .setPrivateConnectivity(getPrivateConnectivity()) .build(); cloudSqlSourceResourceManager = diff --git a/v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSQLIT.java b/v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSQLIT.java index 67dd1645f1..b3518cfdc9 100644 --- a/v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSQLIT.java +++ b/v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSQLIT.java @@ -102,7 +102,7 @@ public void setUp() throws IOException { datastreamResourceManager = DatastreamResourceManager.builder(testName, PROJECT, REGION) .setCredentialsProvider(credentialsProvider) - .setPrivateConnectivity("datastream-connect-2") + .setPrivateConnectivity(getPrivateConnectivity()) .build(); String password = System.getProperty("cloudOracleSysPassword"); From a31deb626b78cc54534937b8f2045d9c542d16d8 Mon Sep 17 00:00:00 2001 From: Sandeep Mishra Date: Fri, 10 Apr 2026 08:51:21 +0000 Subject: [PATCH 2/2] updated --- .../src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java | 1 - 1 file changed, 1 deletion(-) diff --git a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java index 098ec6b180..f43afac2ea 100644 --- a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java +++ b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java @@ -846,4 +846,3 @@ protected String getPrivateConnectivity() { return System.getProperty("privateConnectivity", "datastream-connect-2"); } } -