[FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston · zuston · commit 5df56aad5eba · 2021-03-12T19:45:20.000+08:00
Change-Id: Ia4c246f80771ebd7474753a271fb3c1a56cc184d
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java b/flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java
@@ -564,8 +564,8 @@ static ContainerLaunchContext createTaskExecutorContext(
                 Collection<Token<? extends TokenIdentifier>> userTokens = cred.getAllTokens();
                 for (Token<? extends TokenIdentifier> token : userTokens) {
                     if (!token.getKind().equals(AMRMTokenIdentifier.KIND_NAME)) {
-                        final Text id = new Text(token.getIdentifier());
-                        taskManagerCred.addToken(id, token);
+                        final Text alias = new Text(token.getService());
+                        taskManagerCred.addToken(alias, token);
                     }
                 }
 

Original file line number	Diff line number	Diff line change
`@@ -564,8 +564,8 @@ static ContainerLaunchContext createTaskExecutorContext(`
`564`	`564`	`Collection<Token<? extends TokenIdentifier>> userTokens = cred.getAllTokens();`
`565`	`565`	`for (Token<? extends TokenIdentifier> token : userTokens) {`
`566`	`566`	`if (!token.getKind().equals(AMRMTokenIdentifier.KIND_NAME)) {`
`567`		`- final Text id = new Text(token.getIdentifier());`
`568`		`- taskManagerCred.addToken(id, token);`
	`567`	`+ final Text alias = new Text(token.getService());`
	`568`	`+ taskManagerCred.addToken(alias, token);`
`569`	`569`	`}`
`570`	`570`	`}`
`571`	`571`