Re: Failed to stream on Yarn cluster

2016-04-28 Thread patcharee

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 <patcharee.thong...@uni.no> 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






Failed to stream on Yarn cluster

2016-04-28 Thread patcharee

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