Hi,
I am using flink single-job mode on YARN to read data from a kafka
cluster installation configured for Kerberos. When i upgrade flink to
1.4.0 , the yarn application can not run normally and logs th error
like this:
Exception in thread "main" java.lang.RuntimeException:
org.apache.flink.confi
Hey 杨光,
thanks for looking into this in such a detail. Unfortunately, I'm not
sure what the expected behaviour is (whether the change in behaviour
was accidental or on purpose).
Let me pull in Gordon who has worked quite a bit on the Kerberos
related components in Flink.
@Gordon:
1) Do you know
Hi 杨光,
Thanks a lot for reporting and looking into this with such detail!
Your observations are correct: the changes from 1.3.2 to 1.4.0 in the
YarnTaskManagerRunner caused the local Keytab path in TMs to not be correctly
set.
Unfortunately, AFAIK I don’t think there is a possible workaround to
