Hi, Thanks for trying it out.
I was running the job in local single node setup. I also spawn a HDInsights cluster in Azure platform just to test the WordCount program. Its the same result there too, stuck at the Evaluating ParMultiDo step. It runs fine in mvn compile exec, but when bundled into jar & submitted via spark-submit there is no result. If there is no support from Beam to run on top of Spark then I have to write Spark native code which is what I am doing currently. Regards, Sathish. J On 03-Aug-2017, at 2:34 PM, Jean-Baptiste Onofré <[email protected]<mailto:[email protected]>> wrote: nanthrax.net<mailto:[email protected]>
