Hi
We would highly appreciate any information on following stacktrace. Our flink
job is simply writing data to Cassandra using cassandra sink and we are getting
following exception -
Caused by: 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.SourceStreamTask.<init>(SourceStreamTask.java:51)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:422)
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:745)
My jobs were working fine with version 1.7.2, now we upgraded our version to
1.8.0 then we are facing this problem.
Waiting for your response.
--
Regards,
Akshay Shinde
SMTS, Oracle
