File tree Expand file tree Collapse file tree 1 file changed +0
-6
lines changed
it/kafka/src/test/java/org/apache/beam/it/kafka Expand file tree Collapse file tree 1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change @@ -299,9 +299,6 @@ private PipelineLauncher.LaunchInfo generateDataAndWrite() throws IOException {
299299 .addParameter ("maxNumWorkers" , String .valueOf (configuration .maxNumWorkers ))
300300 .addParameter ("experiments" , configuration .useDataflowRunnerV2 ? "use_runner_v2" : "" )
301301 .addParameter ("enableStreamingEngine" , "true" ) // Enable streaming engine
302- .addParameter ("usePublicIps" , "false" ) // Use private IPs for better performance
303- .addParameter (
304- "subnetwork" , "regions/us-central1/subnetworks/default" ) // Use default subnet
305302 .build ();
306303
307304 return pipelineLauncher .launch (project , region , options );
@@ -334,9 +331,6 @@ private PipelineLauncher.LaunchInfo readData() throws IOException {
334331 .addParameter ("runner" , configuration .runner )
335332 .addParameter ("experiments" , configuration .useDataflowRunnerV2 ? "use_runner_v2" : "" )
336333 .addParameter ("enableStreamingEngine" , "true" ) // Enable streaming engine
337- .addParameter ("usePublicIps" , "false" ) // Use private IPs for better performance
338- .addParameter (
339- "subnetwork" , "regions/us-central1/subnetworks/default" ) // Use default subnet
340334 .build ();
341335
342336 return pipelineLauncher .launch (project , region , options );
You can’t perform that action at this time.
0 commit comments