Hi Folks,
trying to run a flink cluster in multi node environment with 1 master and 1 worker node and trying to run a job on master but getting error
running below command for executing job
./bin/flink run ./examples/streaming/WordCount.jar --input /home/test_wc/test_wo_c.txt --output /home/test_wc/output1.txt OR
./bin/flink run ./examples/streaming/WordCount.jar
Getting below error :
Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph
Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:32087