Hi Ramanji,
you can find the source code of the examples here:
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCount.java
A general introduction how the cluster execution works can be found here:
https://ci.apache.org/projects/flink/flink-docs-release-1.4/concepts/programming-model.html#programs-and-dataflows
https://ci.apache.org/projects/flink/flink-docs-release-1.4/concepts/runtime.html
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.
Regards,
Timo
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.
