diff --git a/job/server/src/main/java/alluxio/master/job/tracker/DistLoadCliRunner.java b/job/server/src/main/java/alluxio/master/job/tracker/DistLoadCliRunner.java
index 40f3574d72cd..6d21cc5387fb 100644
--- a/job/server/src/main/java/alluxio/master/job/tracker/DistLoadCliRunner.java
+++ b/job/server/src/main/java/alluxio/master/job/tracker/DistLoadCliRunner.java
@@ -156,7 +156,7 @@ private void submitDistLoad(List<URIStatus> pool, int replication,
                               Set<String> workerSet, Set<String> excludedWorkerSet,
                               Set<String> localityIds, Set<String> excludedLocalityIds,
                               boolean directCache, CmdInfo cmdInfo) {
-    if (mSubmitted.size() >= DEFAULT_ACTIVE_JOBS) {
+    if (mSubmitted.size() >= mActiveJobs) {
       waitForCmdJob();
     }
 
diff --git a/job/server/src/main/java/alluxio/master/job/tracker/MigrateCliRunner.java b/job/server/src/main/java/alluxio/master/job/tracker/MigrateCliRunner.java
index c72d4040ecec..c244409a9492 100644
--- a/job/server/src/main/java/alluxio/master/job/tracker/MigrateCliRunner.java
+++ b/job/server/src/main/java/alluxio/master/job/tracker/MigrateCliRunner.java
@@ -124,7 +124,7 @@ private void copy(AlluxioURI srcPath, AlluxioURI dstPath, boolean overwrite, int
   // Submit a child job within a distributed command job.
   private void submitDistCp(List<Pair<String, String>> pool, boolean overwrite,
          WriteType writeType, CmdInfo cmdInfo) {
-    if (mSubmitted.size() >= DEFAULT_ACTIVE_JOBS) {
+    if (mSubmitted.size() >= mActiveJobs) {
       waitForCmdJob();
     }