flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: How to run wordcount program on Multi-node Cluster.
Date Mon, 07 Aug 2017 12:26:34 GMT
Hi Ramanji,

you can find the source code of the examples here:

A general introduction how the cluster execution works can be found here:

It might also be helpful to have a look at the web interface which can 
show you a nice graph of the job.

I hope this helps. Feel free to ask further questions.


Am 07.08.17 um 14:00 schrieb P. Ramanjaneya Reddy:
> Hello Everyone,
> I have followed the steps specified below link to Install & Run Apache
> Flink on Multi-node Cluster.
> http://data-flair.training/blogs/install-run-deploy-flink-multi-node-cluster/
>   used flink-1.3.2-bin-hadoop27-scala_2.10.tgz for install
> using the command
>   " bin/flink run
> /home/root1/NAI/Tools/BEAM/Flink_Cluster/rama/flink/examples/streaming/WordCount.jar"
> able to run wordcount, but where can i see which input consider and output
> generated?
> and how can i specify the input and output paths?
> I'm trying to understand how the wordcount will work using Multi-node
> Cluster.?
> any suggestions will help me further understanding?
> Thanks & Regards,
> Ramanji.

View raw message