abajwa-hw / ambari-flink-service

Ambari service for Apache Flink
125 stars 111 forks source link

Ambari Flink Service HDP3 #19

Open steven-matison opened 4 years ago

steven-matison commented 4 years ago

I forked your service and brought it into HDP3 via a Management Pack: dfhz_hdp_mpack. I was successful with just a few adjustments to the start function. For some reason the -d (detached) and -nm (app name) at the back of the cmd were not being honored. My solution was to move to the front.

cmd = format("export HADOOP_CONF_DIR={hadoop_conf_dir}; export HADOOP_CLASSPATH={hadoop_classpath}; {bin_dir}/yarn-session.sh -d -nm {flink_appname} -n {flink_numcontainers} -s {flink_numberoftaskslots} -jm {flink_jobmanager_memory} -tm {flink_container_memory} -qu {flink_queue}")