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 , 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.(StreamTask.java:212)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.(StreamTask.java:190)
> at
> org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask.(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
