Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6376#discussion_r203978136
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeAllWindowCheckpointingITCase.java
---
@@ -133,9 +122,12 @@ public void apply(
out.collect(new
Tuple4<>(key, window.getStart(), window.getEnd(), new IntType(sum)));
}
})
- .addSink(new ValidatingSink(numKeys,
numElementsPerKey / windowSize)).setParallelism(1);
+ .addSink(new ValidatingSink<>(
+ new
EventTimeWindowCheckpointingITCase.SinkValidatorUpdateFun(numElementsPerKey),
+ new
EventTimeWindowCheckpointingITCase.SinkValidatorCheckFun(numKeys,
numElementsPerKey, windowSize)))
+ .setParallelism(1);
- tryExecute(env, "Tumbling Window Test");
+ env.execute("Tumbling Window Test");
--- End diff --
Same as above.
---
