Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5172#discussion_r162239390 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java --- @@ -126,12 +124,6 @@ public static void runYarnTaskManager(String[] args, final Class<? extends YarnT hadoopConfiguration.set(CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHENTICATION, "kerberos"); --- End diff -- @EronWright , I've created a PR for [FLINK-8390|https://issues.apache.org/jira/browse/FLINK-8390] to address the integration test code issue. Could you please take a look at that as well?
---