NPE in Flink 1.8.0

[Akshay Shinde]

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

[Farouk]

Hi

We had the same issue.

Make sure everything is using Flink 1.8 and not half on 1.7.2 and the other half on 1.8.

Make sure to prune docker images and so on, even maven repo.

Farouk

Le mer. 15 mai 2019 à 18:08, Akshay Shinde <[hidden email]> a écrit :

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