[ 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)