Thank you Timo.
root1@root1-HP-EliteBook-840-G2:~/NAI/Tools/BEAM/Flink_Cluster/rama/flink$ *./bin/flink run ./examples/streaming/WordCount.jar --input file:///home/root1/hamlet.txt --output file:///home/root1/wordcount_out* Execution of worcountjar gives error... 08/07/2017 18:03:16 Source: Custom File Source(1/1) switched to FAILED java.io.FileNotFoundException: The provided file path file:/home/root1/hamlet.txt does not exist. at org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction.run(ContinuousFileMonitoringFunction.java:192) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:87) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:55) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:95) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:263) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702) at java.lang.Thread.run(Thread.java:748) On Mon, Aug 7, 2017 at 5:56 PM, Timo Walther <twal...@apache.org> wrote: > 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. >> >> >
