diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java
index a15c78e4267e4..557e80279aed3 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/ApplicationMaster.java
@@ -323,7 +323,7 @@ public enum DSEntity {
       ContainerRetryPolicy.NEVER_RETRY;
   private Set<Integer> containerRetryErrorCodes = null;
   private int containerMaxRetries = 0;
-  private int containrRetryInterval = 0;
+  private int containerRetryInterval = 0;
   private long containerFailuresValidityInterval = -1;
 
   private List<String> localizableFiles = new ArrayList<>();
@@ -722,7 +722,7 @@ public boolean init(String[] args) throws ParseException, IOException {
     }
     containerMaxRetries = Integer.parseInt(
         cliParser.getOptionValue("container_max_retries", "0"));
-    containrRetryInterval = Integer.parseInt(cliParser.getOptionValue(
+    containerRetryInterval = Integer.parseInt(cliParser.getOptionValue(
         "container_retry_interval", "0"));
     containerFailuresValidityInterval = Long.parseLong(
         cliParser.getOptionValue("container_failures_validity_interval", "-1"));
@@ -1555,7 +1555,7 @@ public void run() {
       ContainerRetryContext containerRetryContext =
           ContainerRetryContext.newInstance(
               containerRetryPolicy, containerRetryErrorCodes,
-              containerMaxRetries, containrRetryInterval,
+              containerMaxRetries, containerRetryInterval,
               containerFailuresValidityInterval);
       ContainerLaunchContext ctx = ContainerLaunchContext.newInstance(
         localResources, myShellEnv, commands, null, allTokens.duplicate(),