You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2018/05/08 13:54:31 UTC
flink git commit: [FLINK-8286] Fix Kerberos integration for FLIP-6
YarnTaskExecutorRunner
Repository: flink
Updated Branches:
refs/heads/master 5249981dc -> ba3e2711a
[FLINK-8286] Fix Kerberos integration for FLIP-6 YarnTaskExecutorRunner
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba3e2711
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ba3e2711
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ba3e2711
Branch: refs/heads/master
Commit: ba3e2711a2091b7c0907a5caf3ea527f837a442f
Parents: 5249981
Author: Shuyi Chen <sh...@uber.com>
Authored: Wed May 2 12:02:50 2018 -0700
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Tue May 8 13:39:47 2018 +0200
----------------------------------------------------------------------
.../main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ba3e2711/flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java
index 0c676e7..94cd5a9 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java
@@ -125,13 +125,13 @@ public class YarnTaskExecutorRunner {
LOG.info("YARN daemon is running as: {} Yarn client user obtainer: {}",
currentUser.getShortUserName(), yarnClientUsername);
- SecurityConfiguration sc = new SecurityConfiguration(configuration);
-
if (keytabPath != null && remoteKeytabPrincipal != null) {
configuration.setString(SecurityOptions.KERBEROS_LOGIN_KEYTAB, keytabPath);
configuration.setString(SecurityOptions.KERBEROS_LOGIN_PRINCIPAL, remoteKeytabPrincipal);
}
+ SecurityConfiguration sc = new SecurityConfiguration(configuration);
+
final String containerId = ENV.get(YarnFlinkResourceManager.ENV_FLINK_CONTAINER_ID);
Preconditions.checkArgument(containerId != null,
"ContainerId variable %s not set", YarnFlinkResourceManager.ENV_FLINK_CONTAINER_ID);