Hello eveyrone,
I am experiencing random NullPointerException since I upgrade 1.8
Cannot find anything related on the JIRA, have someone an explanation ? or
maybe can point me in the right direction to check some stuff ?
My source is a KafkaProducer
Stacktrace :
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)
------------------
Bastien DINE
Data Architect / Software Engineer / Sysadmin
bastiendine.io
