Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6351#discussion_r203380952
--- Diff:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/DataStreamAllroundTestJobFactory.java
---
@@ -184,12 +189,16 @@
private static final ConfigOption<Long>
SEQUENCE_GENERATOR_SRC_EVENT_TIME_MAX_OUT_OF_ORDERNESS = ConfigOptions
.key("sequence_generator_source.event_time.max_out_of_order")
- .defaultValue(500L);
+ .defaultValue(0L);
private static final ConfigOption<Long>
SEQUENCE_GENERATOR_SRC_EVENT_TIME_CLOCK_PROGRESS = ConfigOptions
.key("sequence_generator_source.event_time.clock_progress")
.defaultValue(100L);
+ private static final ConfigOption<Long>
TUMBLING_WINDOW_OPERATOR_NUM_EVENTS = ConfigOptions
+ .key("sliding_window_operator.num_events")
--- End diff --
`tumbling` instead of `sliding`?
---
