Hi Lior,
Try adding this to your flink-conf.yaml:
env.ssh.opts: FLINK_CONF_DIR=/tmp/parallelmachine/lior/flink/conf
I think this is expected and not a bug (setting FLINK_CONF_DIR from the
environment is supported for YARN). Please do file a JIRA for this feature
as I think it would be a nice im
Hi,
I am new here.
My name is Lior and I am working at Parallel Machines.
Was assigned recently to work on Flink run/use/improve :-)
I am using the FLINK_CONF_DIR environment variable to pass the config
location
to the start-cluster.sh (e.g. env
FLINK_CONF_DIR=/tmp/parallelmachine/lior/flink/conf