Hi Sathish,
Do you see the tasks submitted on the history server ?
Regards
JB
On 08/01/2017 11:51 AM, Sathish Jayaraman wrote:
Hi,
I am trying to execute Beam example in local spark setup. When I try to submit
the sample WordCount jar via spark-submit, the job just hangs at 'INFO
SparkRunner$Evaluator: Evaluating ParMultiDo(ExtractWords)’. But it runs fine
when executed directly. Below is the command I used to submit the job in spark
local,
$ ~/spark/bin/spark-submit --class "org.apache.beam.examples.WordCount"
--master local[4] target/word-count-beam-0.1.jar —inputFile=./pom.xml
--output=csvout --runner=SparkRunner
Have attached log file for reference. Can anyone please help me find out whats
going on?
Regards,
Sathish. J
--
Jean-Baptiste Onofré
[email protected]
http://blog.nanthrax.net
Talend - http://www.talend.com
