Explorar o código

YARN-7806. Distributed Shell should use timeline async api's. Contributed by Rohith Sharma K S

(cherry picked from commit 97607617ce01ee21af4fb9eb8df26fc6986a38a2)
Sunil G %!s(int64=7) %!d(string=hai) anos
pai
achega
ecfdd01be7

+ 2 - 2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java

@@ -1485,7 +1485,7 @@ public class ApplicationMaster {
       appSubmitterUgi.doAs(new PrivilegedExceptionAction<Object>() {
         @Override
         public TimelinePutResponse run() throws Exception {
-          timelineV2Client.putEntities(entity);
+          timelineV2Client.putEntitiesAsync(entity);
           return null;
         }
       });
@@ -1519,7 +1519,7 @@ public class ApplicationMaster {
       appSubmitterUgi.doAs(new PrivilegedExceptionAction<Object>() {
         @Override
         public TimelinePutResponse run() throws Exception {
-          timelineV2Client.putEntities(entity);
+          timelineV2Client.putEntitiesAsync(entity);
           return null;
         }
       });