search

abajwa-hw / ambari-flink-service

Ambari service for Apache Flink
125 stars 111 forks source link

How would you submit job to Flink Application running on Yarn (flinkapp-from-ambari) #10

Open teamsoo opened 7 years ago

teamsoo commented 7 years ago

Executing your test command

./bin/flink run --jobmanager yarn-cluster -yn 1 -ytm 768 -yjm 768 ./examples/batch/WordCount.jar

will create new application called "Flink Application: org.apache.flink.examples.java.wordcount.WordCount" (according to Yarn ResourceManager UI) instead of submitting job to the "flinkapp-from-ambari" application.

So, how would you submit a job to "flinkapp-from-ambari" that's started by Ambari Service?