Thank you Aljoscha.
With above steps working wordcount beam using quick start program.
When running on actual beam source tree getting following error.
root1@master:~/Projects/*beam*/examples/java$ *git branch *
master
* release-2.0.0 * ==> beam source code*
Hi All,
build jar file from the beam quickstart. while run the jar on Flinkcluster
got below error.?
anybody got this error?
Could you please help how to resolve this?
root1@master:~/NAI/Tools/flink-1.3.0$ *bin/flink run -c
org.apache.beam.examples.WordCount
