flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Farouk <farouk.za...@gmail.com>
Subject Re: NPE in Flink 1.8.0
Date Wed, 15 May 2019 16:15:16 GMT
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 <akshay.shinde@oracle.com> 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
>

Mime
View raw message