[
https://issues.apache.org/jira/browse/FLINK-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16547853#comment-16547853
]
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_r203382388
--- Diff:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/SemanticsCheckMapper.java
---
@@ -56,6 +56,7 @@ public void flatMap(Event event, Collector<String> out)
throws Exception {
if (validator.check(currentValue, nextValue)) {
sequenceValue.update(nextValue);
} else {
+ sequenceValue.update(nextValue);
--- End diff --
```
sequenceValue.update(nextValue);
if (!validator.check(currentValue, nextValue)) {
out.collect("Alert: " + currentValue + " -> " +
nextValue + " (" + event.getKey() + ")");
}
```
> 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)
