When the following job has started then the job fails because in submit time we don't know on which node
the job will run and the security.kerberos.spnego.principal=HTTP/[email protected]
is host specific.
flink run \
-yD security.kerberos.login.keytab=/cdep/keytabs/systest.keytab \
-yD [email protected] \
-yD security.spnego.auth.enabled=true \
-yt /var/run/cloudera-scm-agent/process/1546340184-flink-FLINK_HISTORY_SERVER/flink.keytab \
-yD security.kerberos.spnego.keytab=flink.keytab \
-yD security.kerberos.spnego.principal=HTTP/[email protected] \
$HOME/job.jar