ambari-flink-service
ambari-flink-service copied to clipboard
abajwa-hw
Ambari service for Apache Flink
I forked your service and brought it into HDP3 via a Management Pack: [dfhz_hdp_mpack](https://github.com/steven-dfheinz/dfhz_hdp_mpack). I was successful with just a few adjustments to the start function. For some reason the...
Small typo; you wrote `hhttp` instead of `http` https://github.com/abajwa-hw/ambari-flink-service/blob/master/configuration/flink-ambari-config.xml#L72
The "install service" can fail due at [flink.py Line 45](https://github.com/abajwa-hw/ambari-flink-service/blob/master/package/scripts/flink.py#L45) due to the proxy variables not being set This is despite adding proxy variables to both AMBARI_JVM_ARGS and http_proxy in...
Not sure if this is my own problem with my Ambari server settings etc, but when I was starting the Flink service, it failed to start because it couldn't find...
When flink is started as ambari service (yarn session), the command will be launched without the -s parameter which was established in the log as taskmanager.numberOfTaskSlots: `Execute['export HADOOP_CONF_DIR=/etc/hadoop/conf; /opt/flink/bin/yarn-session.sh -n...
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...
