diff --git a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultFetcherRunner.java b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultFetcherRunner.java
index 21cd8e9..12eab33 100644
--- a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultFetcherRunner.java
+++ b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultFetcherRunner.java
@@ -48,7 +48,7 @@ public class DefaultFetcherRunner extends FetcherRunner {
             }
 
             int nRunning = 0, nReady = 0, nStopped = 0, nOthers = 0, nError = 0, nDiscarded = 0, nSUCCEED = 0;
-            for (final String id : getExecutableManger().getAllJobIdsInCache()) {
+            for (final String id : getExecutableManager().getAllJobIdsInCache()) {
                 if (isJobPoolFull()) {
                     return;
                 }
@@ -58,7 +58,7 @@ public class DefaultFetcherRunner extends FetcherRunner {
                     continue;
                 }
 
-                final Output outputDigest = getExecutableManger().getOutputDigest(id);
+                final Output outputDigest = getExecutableManager().getOutputDigest(id);
                 if ((outputDigest.getState() != ExecutableState.READY)) {
                     // logger.debug("Job id:" + id + " not runnable");
                     if (outputDigest.getState() == ExecutableState.SUCCEED) {
@@ -71,7 +71,7 @@ public class DefaultFetcherRunner extends FetcherRunner {
                         nStopped++;
                     } else {
                         if (fetchFailed) {
-                            getExecutableManger().forceKillJob(id);
+                            getExecutableManager().forceKillJob(id);
                             nError++;
                         } else {
                             nOthers++;
@@ -80,7 +80,7 @@ public class DefaultFetcherRunner extends FetcherRunner {
                     continue;
                 }
 
-                final AbstractExecutable executable = getExecutableManger().getJob(id);
+                final AbstractExecutable executable = getExecutableManager().getJob(id);
                 if (!executable.isReady()) {
                     nOthers++;
                     continue;
diff --git a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java
index 9d8f20e..454ce56 100644
--- a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java
+++ b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/FetcherRunner.java
@@ -72,7 +72,7 @@ public abstract class FetcherRunner implements Runnable {
         this.fetchFailed = fetchFailed;
     }
 
-    ExecutableManager getExecutableManger() {
+    ExecutableManager getExecutableManager() {
         return ExecutableManager.getInstance(jobEngineConfig.getConfig());
     }
 }
diff --git a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/PriorityFetcherRunner.java b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/PriorityFetcherRunner.java
index 0792ed0..099eaf3 100644
--- a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/PriorityFetcherRunner.java
+++ b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/PriorityFetcherRunner.java
@@ -84,14 +84,14 @@ public class PriorityFetcherRunner extends FetcherRunner {
             }
 
             int nRunning = 0, nReady = 0, nStopped = 0, nOthers = 0, nError = 0, nDiscarded = 0, nSUCCEED = 0;
-            for (final String id : getExecutableManger().getAllJobIdsInCache()) {
+            for (final String id : getExecutableManager().getAllJobIdsInCache()) {
                 if (runningJobs.containsKey(id)) {
                     // logger.debug("Job id:" + id + " is already running");
                     nRunning++;
                     continue;
                 }
 
-                final Output outputDigest = getExecutableManger().getOutputDigest(id);
+                final Output outputDigest = getExecutableManager().getOutputDigest(id);
                 if ((outputDigest.getState() != ExecutableState.READY)) {
                     // logger.debug("Job id:" + id + " not runnable");
                     if (outputDigest.getState() == ExecutableState.SUCCEED) {
@@ -104,7 +104,7 @@ public class PriorityFetcherRunner extends FetcherRunner {
                         nStopped++;
                     } else {
                         if (fetchFailed) {
-                            getExecutableManger().forceKillJob(id);
+                            getExecutableManager().forceKillJob(id);
                             nError++;
                         } else {
                             nOthers++;
@@ -113,7 +113,7 @@ public class PriorityFetcherRunner extends FetcherRunner {
                     continue;
                 }
 
-                AbstractExecutable executable = getExecutableManger().getJob(id);
+                AbstractExecutable executable = getExecutableManager().getJob(id);
                 if (!executable.isReady()) {
                     nOthers++;
                     continue;