You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by sc...@apache.org on 2026/02/23 14:01:51 UTC
(beam) branch master updated: [Dataflow Streaming] Remove dead code around redundant experiments (#37684)
This is an automated email from the ASF dual-hosted git repository.
scwhittle pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new cb7caaad2ca [Dataflow Streaming] Remove dead code around redundant experiments (#37684)
cb7caaad2ca is described below
commit cb7caaad2ca7c21cbed024ade2684dcb5911891a
Author: Arun Pandian <pa...@google.com>
AuthorDate: Mon Feb 23 06:01:43 2026 -0800
[Dataflow Streaming] Remove dead code around redundant experiments (#37684)
The experiments are not needed, they are also not set on the outgoing
requests.
---
.../java/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 f34b7486657..d826c3b2a38 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 class DataflowRunner extends PipelineRunner<DataflowPipelineJob> {
if (useUnifiedWorker(options)) {
options.setEnableStreamingEngine(true);
- List<String> 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");
- }
}
}