[
https://issues.apache.org/jira/browse/FLINK-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vijayakumar Palaniappan updated FLINK-6297:
---
Issue is still reproducible
Changes i did are
- iterator as the source without closing the stream
- env.getConfig().setAutoWatermarkInterval(5000);
Iterator src:
class Ite implements Iterator, Serializable {
int i = 0;
public boolean hasNext() {
if (i == inputElements.size()) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return i < inputElements.size();
}
public MyEvent next() {
return inputElements.get(i++);
}
}
DataStream input = env.fromCollection(new Ite(), MyEvent.class);
Event Input:
final List inputElements = new ArrayList<>();
inputElements.add(new MyEvent(1, 'a', 1, 1));
inputElements.add(new MyEvent(1, 'b', 1, 2));
inputElements.add(new MyEvent(1, 'a', 2, 3));
inputElements.add(new MyEvent(1, 'a', 3, 6));
Event Constructor:
public MyEvent(int v, char payload,int key, int timestamp)
event key 2 never times out.
On Fri, May 19, 2017 at 10:45 AM, Kostas Kloudas (JIRA)
--
Thanks,
-Vijay
> CEP timeout does not trigger under certain conditions
> -
>
> Key: FLINK-6297
> URL: https://issues.apache.org/jira/browse/FLINK-6297
> Project: Flink
> Issue Type: Bug
> Components: CEP
>Affects Versions: 1.2.0
>Reporter: Vijayakumar Palaniappan
>
> -TimeoutPattern does not trigger under certain conditions. Following are the
> preconditions:
> -Assume a pattern of Event A followed by Event B within 2 Seconds
> -PeriodicWaterMarks every 1 second
> -Assume following events have arrived.
> -Event A-1[time: 1 sec]
> -Event B-1[time: 2 sec]
> -Event A-2[time: 2 sec]
> -Event A-3[time: 5 sec]
> -WaterMark[time: 5 sec]
> I would assume that after watermark arrival, Event A-1,B-1 detected. A-2
> timed out. But A-2 timeout does not happen.
> if i use a punctuated watermark and generate watermark for every event, it
> seems to work as expected.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
