[
https://issues.apache.org/jira/browse/FLINK-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16547848#comment-16547848
]
ASF GitHub Bot commented on FLINK-9862:
---------------------------------------
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`?
> Update end-to-end test to use RocksDB backed timers
> ---------------------------------------------------
>
> Key: FLINK-9862
> URL: https://issues.apache.org/jira/browse/FLINK-9862
> Project: Flink
> Issue Type: Sub-task
> Components: State Backends, Checkpointing, Streaming
> Affects Versions: 1.6.0
> Reporter: Till Rohrmann
> Assignee: Tzu-Li (Gordon) Tai
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.6.0
>
>
> We should add or modify an end-to-end test to use RocksDB backed timers.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
