From 0d933e07ce693bea00b6edeabf6df6e5c1dbc2ac Mon Sep 17 00:00:00 2001 From: Arun Pandian Date: Mon, 23 Feb 2026 13:28:30 +0000 Subject: [PATCH] [Dataflow Streaming] Remove dead code around redundant experiments The experiments are not needed, they are also not set on the outgoing requests. --- .../org/apache/beam/runners/dataflow/DataflowRunner.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java index f34b74866575..d826c3b2a38c 100644 --- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java +++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java @@ -1301,14 +1301,6 @@ public DataflowPipelineJob run(Pipeline pipeline) { if (useUnifiedWorker(options)) { options.setEnableStreamingEngine(true); - List experiments = - new ArrayList<>(options.getExperiments()); // non-null if useUnifiedWorker is true - if (!experiments.contains("enable_streaming_engine")) { - experiments.add("enable_streaming_engine"); - } - if (!experiments.contains("enable_windmill_service")) { - experiments.add("enable_windmill_service"); - } } }