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.
