Flink queue mapping modified

Queue will be added only when "flink run" has been called PNDA-4796
pndaproject · Aug 2, 2018 · f687486 · f687486
1 parent 92c89e2
commit f687486
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/salt/resource-manager/templates/yarn-common-wrapper.sh b/salt/resource-manager/templates/yarn-common-wrapper.sh
@@ -6,7 +6,7 @@ CLI=`basename "$0"`
 if [ $CLI == "hive" ] || [ $CLI == "beeline" ]; then
 #--hiveconf tez.queue.name=dev
   PROP=('--hiveconf' 'tez.queue.name')
-elif [ $CLI == "flink" ] || [ $CLI == "pyflink.sh" ]; then 
+elif [ $CLI == "flink" ] && [ "$1" == "run" ] || [ $CLI == "pyflink.sh" ]; then
   PROP=('-yqu' '')
 else
   PROP=('--queue' '')