[hotfix] Update datetime formatter to actually produce and store per-hour data
This closes #17
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
