Resolve the issue that app cannot be submitted due to timeline server abnormalities

zhongweiwang86 · zhongweiwang86 · commit 6031b335474b · 2024-11-13T17:06:57.000+08:00
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/YarnClientImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/YarnClientImpl.java
@@ -451,9 +451,12 @@ private void addTimelineDelegationToken(
       }
     }
     org.apache.hadoop.security.token.Token<TimelineDelegationTokenIdentifier>
-        timelineDelegationToken = getTimelineDelegationToken();
-    if (timelineDelegationToken == null) {
-      return;
+            timelineDelegationToken = null;
+    try{
+      timelineDelegationToken = getTimelineDelegationToken();
+    }catch (Exception e){
+      LOG.error("Failed to get delegation token: {}", e.getMessage());
+      return ;
     }
     credentials.addToken(timelineService, timelineDelegationToken);
     LOG.debug("Add timeline delegation token into credentials: {}",

Original file line number	Diff line number	Diff line change
`@@ -451,9 +451,12 @@ private void addTimelineDelegationToken(`
`451`	`451`	`}`
`452`	`452`	`}`
`453`	`453`	`org.apache.hadoop.security.token.Token<TimelineDelegationTokenIdentifier>`
`454`		`- timelineDelegationToken = getTimelineDelegationToken();`
`455`		`- if (timelineDelegationToken == null) {`
`456`		`- return;`
	`454`	`+ timelineDelegationToken = null;`
	`455`	`+ try{`
	`456`	`+ timelineDelegationToken = getTimelineDelegationToken();`
	`457`	`+ }catch (Exception e){`
	`458`	`+ LOG.error("Failed to get delegation token: {}", e.getMessage());`
	`459`	`+ return ;`
`457`	`460`	`}`
`458`	`461`	`credentials.addToken(timelineService, timelineDelegationToken);`
`459`	`462`	`LOG.debug("Add timeline delegation token into credentials: {}",`