Hi, What version of Flink are you using? Also, how are you building your job? Is it a fat-jar, maybe based in the Flink Quickstart project?
Best, Aljoscha > On 9. Jun 2017, at 11:49, Biplob Biswas <revolutioni...@gmail.com> wrote: > > One more thing i noticed is that the streaming wordcount from the flink > package works when i run it but when i used the same github code, packaged > it and uploaded the fat jar with the word count example to the cluster, i > get the same error. > > I am wondering, How can making my uber jar produce such erroneous result > when i am basically not changing anything else. > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Error-running-Flink-job-in-Yarn-cluster-mode-tp13593p13607.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
