[hotfix] Add an option to allow operator chaining
This closes #19
diff --git a/docker/ops-playground-image/java/flink-playground-clickcountjob/src/main/java/org/apache/flink/playgrounds/ops/clickcount/ClickEventCount.java b/docker/ops-playground-image/java/flink-playground-clickcountjob/src/main/java/org/apache/flink/playgrounds/ops/clickcount/ClickEventCount.java
index f3d628c..534ef9f 100644
--- a/docker/ops-playground-image/java/flink-playground-clickcountjob/src/main/java/org/apache/flink/playgrounds/ops/clickcount/ClickEventCount.java
+++ b/docker/ops-playground-image/java/flink-playground-clickcountjob/src/main/java/org/apache/flink/playgrounds/ops/clickcount/ClickEventCount.java
@@ -60,6 +60,7 @@
public static final String CHECKPOINTING_OPTION = "checkpointing";
public static final String EVENT_TIME_OPTION = "event-time";
public static final String BACKPRESSURE_OPTION = "backpressure";
+ public static final String OPERATOR_CHAINING_OPTION = "chaining";
public static final Time WINDOW_SIZE = Time.of(15, TimeUnit.SECONDS);
@@ -121,6 +122,7 @@
boolean checkpointingEnabled = params.has(CHECKPOINTING_OPTION);
boolean eventTimeSemantics = params.has(EVENT_TIME_OPTION);
+ boolean enableChaining = params.has(OPERATOR_CHAINING_OPTION);
if (checkpointingEnabled) {
env.enableCheckpointing(1000);
@@ -130,7 +132,9 @@
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
}
- //disabling Operator chaining to make it easier to follow the Job in the WebUI
- env.disableOperatorChaining();
+ if(!enableChaining){
+ //disabling Operator chaining to make it easier to follow the Job in the WebUI
+ env.disableOperatorChaining();
+ }
}
}
