Re: PyFlink: called already closed and NullPointerException

2021-04-15 Thread Yik San Chan
; > Regards, > Dian > > 2021年4月16日 上午11:37,Yik San Chan 写道: > > The question is cross-posted on Stack Overflow > https://stackoverflow.com/questions/67118743/pyflink-called-already-closed-and-nullpointerexception > . > > Hi community, > > I run into an issue w

Re: PyFlink: called already closed and NullPointerException

2021-04-15 Thread Dian Fu
es.apache.org/jira/browse/FLINK-22297>. Regards, Dian > 2021年4月16日 上午11:37,Yik San Chan 写道: > > The question is cross-posted on Stack Overflow > https://stackoverflow.com/questions/67118743/pyflink-called-already-closed-and-nullpointerexception > > <https://stackover

PyFlink: called already closed and NullPointerException

2021-04-15 Thread Yik San Chan
The question is cross-posted on Stack Overflow https://stackoverflow.com/questions/67118743/pyflink-called-already-closed-and-nullpointerexception . Hi community, I run into an issue where a PyFlink job may end up with 3 very different outcomes, given very slight difference in input, and luck