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 <bastien.d...@gmail.com>, 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) > > ------------------ > > Bastien DINE > Data Architect / Software Engineer / Sysadmin > bastiendine.io
