error with session window

Posted by yuvraj singh on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/error-with-session-window-tp23325.html

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