beam word count example is failing on the flink runner deployed at dedicated flink cluster using beam java SDK
I have used the below official documentation to run the beam word count example :
https://beam.apache.org/get-started/quickstart-java/
I have used the below official documentation to run the beam word count example :
https://beam.apache.org/get-started/quickstart-java/