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.