Skip to content

Commit 1de783a

Browse files
committed
Adding a StreamingWorkerHarnessFactoryOutput class to hold harness and its dependencies
1 parent f430b7a commit 1de783a

4 files changed

Lines changed: 242 additions & 182 deletions

File tree

runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -310,7 +310,7 @@ public Integer create(PipelineOptions options) {
310310
class EnableWindmillServiceDirectPathFactory implements DefaultValueFactory<Boolean> {
311311
@Override
312312
public Boolean create(PipelineOptions options) {
313-
if (ExperimentalOptions.hasExperiment(options, "enable_windmill_service_direct_path=false")) {
313+
if (ExperimentalOptions.hasExperiment(options, "disable_windmill_service_direct_path")) {
314314
return false;
315315
}
316316
return ExperimentalOptions.hasExperiment(options, "enable_windmill_service_direct_path");

0 commit comments

Comments
 (0)