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();
+		}
 	}
 }
diff --git a/operations-playground/docker-compose.yaml b/operations-playground/docker-compose.yaml
index 6ebf338..0d795e7 100644
--- a/operations-playground/docker-compose.yaml
+++ b/operations-playground/docker-compose.yaml
@@ -21,7 +21,7 @@
   client:
     build: ../docker/ops-playground-image
     image: apache/flink-ops-playground:1-FLINK-1.11-scala_2.11
-    command: "flink run -d -p 2 /opt/ClickCountJob.jar --bootstrap.servers kafka:9092 --checkpointing --event-time"
+    command: "flink run -d /opt/ClickCountJob.jar --bootstrap.servers kafka:9092 --checkpointing --event-time"
     depends_on:
       - jobmanager
       - kafka