Re: Exception occurred while processing valve output watermark & NullPointerException

2018-11-21 Thread Dawid Wysakowicz
Hi, I think vino is right. It seems that the NullPointerException comes from your condition. Please add handling of the situation when the string that you are comparing is null. Best, Dawid On 21/11/2018 04:32, vino yang wrote: > Hi Steve, > > It seems the NPE caused by the property of the IoT

Re: Exception occurred while processing valve output watermark & NullPointerException

2018-11-20 Thread vino yang
Hi Steve, It seems the NPE caused by the property of the IoTEvent's instance. Can you make sure the property is not null? Thanks, vino. Steve Bistline 于2018年11月21日周三 上午2:09写道: > Any guidance would be most appreciated. > > Thx > > Steve > === > > java.lan

Exception occurred while processing valve output watermark & NullPointerException

2018-11-20 Thread Steve Bistline
Any guidance would be most appreciated. Thx Steve === java.lang.RuntimeException: Exception occurred while processing valve output watermark: at org.apache.flink.streaming.runtime.io.StreamInputProcessor$ForwardingValveOutputHandler.handleWatermar