|
|
Hi,
In my Flink cluster , i have continuously an NPE:
java.lang.NullPointerException
at
org.apache.flink.streaming.runtime.tasks.StreamTask.createRecordWriters(StreamTask.java:1175)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:212)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:190)
at
org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask.<init>(TwoInputStreamTask.java:55)
at sun.reflect.GeneratedConstructorAccessor29.newInstance(Unknown Source)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at
org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:1405)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:689)
at java.lang.Thread.run(Thread.java:748)
And same times i have just : java.lang.NullPointerException sans aucune
stacktrace.
While processing a DataStream some time i have a null object in the stream!
logically we shouldn't.
For example we have this code
exemple :
aDataStream.map(new MyPOJOFilter())...; this code generate an NPE
and when i add a filter for the null elements :
aDataStream.filter(data-> null != data).map(new MyPOJOFilter())...; it
works !
Can some one help;
Regards.
--
Cordialement,Regards.
|
Locked
