flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yuvraj singh <19yuvrajsing...@gmail.com>
Subject error with session window
Date Mon, 24 Sep 2018 11:26:16 GMT
Hi all ,


I  am stuck with this error


please help me .


I am using sessionwindow


2018-09-23 07:15:08,097 INFO  org.apache.flink.runtime.taskmanager.Task
                - city-geohashes-processor (24/48)
(26aed9a769743191c7cb0257087e490a) switched from RUNNING to FAILED.

java.lang.UnsupportedOperationException: The end timestamp of a
processing-time window cannot become earlier than the current processing
time by merging. Current processing time: 1537667108063 window:
TimeWindow{start=1537667100054, end=1537667107237}

        at
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator$2.merge(WindowOperator.java:325)

        at
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator$2.merge(WindowOperator.java:311)

        at
org.apache.flink.streaming.runtime.operators.windowing.MergingWindowSet.addWindow(MergingWindowSet.java:212)

        at
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.processElement(WindowOperator.java:311)

        at
org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:202)




Thanks

Yuvraj Singh

Mime
View raw message