Hi Farouk, from the stack trace alone I cannot say much. Would it be possible to share a minimal example which reproduces the problem?
My suspicion is that OperatorChain.java:294 produces a null value. Differently, said that somehow there is no StreamConfig registered for the given outputId. What you could check is whether you have compiled the Flink job with Flink 1.8.0 and not 1.7.2? Maybe something changed wrt the output enumeration. Cheers, Till On Tue, May 7, 2019 at 5:34 PM Farouk <farouk.za...@gmail.com> wrote: > Hi > > We are migrating our app to Flink 1.8.0. > > We built a docker image like this as Hadoop is not anymore bundled : > > FROM myrepo:50000/flink:1.8.0-scala_2.11-alpine > > ADD --chown=flink:flink > https://my-artifactory-repo/artifactory/my-repo/org/apache/flink/flink-shaded-hadoop2-uber/2.8.3-1.8.0/flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar > /opt/flink/lib > > When running Flink, we are facing the stack trace below : > > java.lang.NullPointerException > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:284) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:360) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:296) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:133) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:267) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) > at java.lang.Thread.run(Thread.java:748) > > Any idea on what's happening ? > > I think it's a problem with classloading. > > With Flink 1.7.2, every thing works fine > > Thanks > Farouk >
