Re: NPE in flink sql over-window

2018-06-05 Thread Fabian Hueske
-- > *From:* Yan Zhou [FDS Science] > *Sent:* Monday, June 4, 2018 4:05 PM > *To:* Fabian Hueske > > *Cc:* Dawid Wysakowicz; user > *Subject:* Re: NPE in flink sql over-window > > > Hi Fabian, > > > Yes, the NPE cause the

Re: NPE in flink sql over-window

2018-06-04 Thread Yan Zhou [FDS Science]
, 2018 4:05 PM To: Fabian Hueske Cc: Dawid Wysakowicz; user Subject: Re: NPE in flink sql over-window Hi Fabian, Yes, the NPE cause the job failure and recovery( instead of being the result of a recovery). And yet, during the recovery, the same exceptions are thrown from same line. Best Yan

Re: NPE in flink sql over-window

2018-06-04 Thread Yan Zhou [FDS Science]
: Yan Zhou [FDS Science] Cc: Dawid Wysakowicz; user Subject: Re: NPE in flink sql over-window Hi Yan, Thanks for the details and for digging into the issue. If I got it right, the NPE caused the job failure and recovery (instead of being the result of a recovery), correct? Best, Fabian 2018-05-31

Re: NPE in flink sql over-window

2018-05-31 Thread Fabian Hueske
or ProcTimeBoundedRangeOver. I will update > with my test result and fire a JIRA after that. > > > Best > > Yan > -- > *From:* Fabian Hueske > *Sent:* Wednesday, May 30, 2018 1:43:01 AM > *To:* Dawid Wysakowicz > *Cc:* user > *Sub

Re: NPE in flink sql over-window

2018-05-30 Thread Yan Zhou [FDS Science]
trace log for ProcTimeBoundedRangeOver. I will update with my test result and fire a JIRA after that. Best Yan From: Fabian Hueske Sent: Wednesday, May 30, 2018 1:43:01 AM To: Dawid Wysakowicz Cc: user Subject: Re: NPE in flink sql over-window Hi, Dawid's a

Re: NPE in flink sql over-window

2018-05-30 Thread Fabian Hueske
tiguous free space left)* > > > > -- > *From:* Yan Zhou [FDS Science] > *Sent:* Tuesday, May 29, 2018 10:52:18 PM > *To:* user@flink.apache.org > *Subject:* NPE in flink sql over-window > > > Hi, > > I am using flink sql 1.5.0. My appl

Re: NPE in flink sql over-window

2018-05-30 Thread Dawid Wysakowicz
Sent:* Tuesday, May 29, 2018 10:52:18 PM > *To:* user@flink.apache.org > *Subject:* NPE in flink sql over-window >   > > Hi, > > I am using flink sql 1.5.0. My application throws NPE. And after it > recover from checkpoint automatically, it throws NPE immediately from > sa

Re: NPE in flink sql over-window

2018-05-29 Thread Yan Zhou [FDS Science]
0007fa50c00] total_blobs=54308 nmethods=53551 adapters=617 compilation: disabled (not enough contiguous free space left) From: Yan Zhou [FDS Science] Sent: Tuesday, May 29, 2018 10:52:18 PM To: user@flink.apache.org Subject: NPE in flink sql over-window Hi, I am

NPE in flink sql over-window

2018-05-29 Thread Yan Zhou [FDS Science]
Hi, I am using flink sql 1.5.0. My application throws NPE. And after it recover from checkpoint automatically, it throws NPE immediately from same line of code. My application read message from kafka, convert the datastream into a table, issue an Over-window aggregation and write the result in