ambari-flink-service
ambari-flink-service copied to clipboard
Ambari Flink Service HDP3
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}")