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"); - } } }