Hi,I am testing the streaming wiki example - https://ci.apache.org/projects/flink/flink-docs-master/quickstart/run_example_quickstart.html
It works fine from local mode (mvn exec:java -Dexec.mainClass=wikiedits.WikipediaAnalysis). But when I run the jar on Yarn cluster mode, nothing happened. Any ideas? I tested the word count example from hdfs file on Yarn cluster and it worked fine.
Best, Patcharee
