Thanks for the replay.
Yes, it only happen if I config the idle state retention times. The error occurs the first time before the first recovery. I haven't run with proctime but rowtime in flink 1.4.x. I am not sure if it will cause problems with proctime in 1.4.x.
I am adding some trace log for ProcTimeBoundedRangeOver. I will update with my test result and fire a JIRA after that.
From: Fabian Hueske <fhueske@xxxxxxxxx>
Sent: Wednesday, May 30, 2018 1:43:01 AM
To: Dawid Wysakowicz
Subject: Re: NPE in flink sql over-window
Hi,Dawid's analysis is certainly correct, but looking at the code this should not happen.
I have a few questions:
- You said this only happens if you configure idle state retention times, right?
- Does the error occur the first time without a previous recovery?- Did you run the same query on Flink 1.4.x without any problems?
2018-05-30 9:25 GMT+02:00 Dawid Wysakowicz <dwysakowicz@xxxxxxxxxx>: