Hi Till Thanks. I'll check it out.
Farouk <http://www.avg.com/email-signature?utm_medium=email&utm_source=link&utm_campaign=sig-email&utm_content=webmail> Garanti sans virus. www.avg.com <http://www.avg.com/email-signature?utm_medium=email&utm_source=link&utm_campaign=sig-email&utm_content=webmail> <#DAB4FAD8-2DD7-40BB-A1B8-4E2AA1F9FDF2> Le mer. 8 mai 2019 à 16:59, Till Rohrmann <trohrm...@apache.org> a écrit : > 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 >> >