Hi again,
Actually it works well! I just realized from looking at Yarn application
log that the Flink streaming result is printed in taskmanager.out. When
I sent a question to the mailing list I looked at the screen where I
issued the command, and there was no streaming result there.
Where is the taskmanager.out and how can I change it?
Best,
Patcharee
On 28. april 2016 13:18, Maximilian Michels wrote:
Hi Patcharee,
What do you mean by "nothing happened"? There is no output? Did you
check the logs?
Cheers,
Max
On Thu, Apr 28, 2016 at 12:10 PM, patcharee wrote:
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
