NullPointerException on StreamTask

[bastien dine]

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)

[Congxian Qiu]

Hi

From the code[1] said, seems `chainedConfigs.get(edge.getSourceId())` is null(chainedConfigs will never be null and edge would not be null), but I can’t tell why this can happen, maybe some one else can help here.

[1] https://github.com/apache/flink/blob/d044789f202d2ec260056c1dc94cd1dd08ed0b77/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L1175

Best Congxian

On May 27, 2019, 22:17 +0800, bastien dine <[hidden email]>, wrote:

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)