diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterJobStatusStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterJobStatusStmt.java index 09f135d2fb..16077cc260 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterJobStatusStmt.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterJobStatusStmt.java @@ -58,6 +58,8 @@ public class AlterJobStatusStmt extends DdlStmt { throw new AnalysisException("Value can't is null"); } this.jobName = inputValue; - + if (CreateJobStmt.isInnerJob(jobName)) { + throw new AnalysisException("Can't alter inner job status"); + } } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateJobStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateJobStmt.java index ef76aedba2..17e2185bf5 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateJobStmt.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateJobStmt.java @@ -85,7 +85,7 @@ public class CreateJobStmt extends DdlStmt { private JobExecuteType executeType; // exclude job name prefix, which is used by inner job - private final String excludeJobNamePrefix = "inner_"; + private static final String excludeJobNamePrefix = "inner_"; private static final ImmutableSet> supportStmtSuperClass = new ImmutableSet.Builder>().add(InsertStmt.class) @@ -208,4 +208,8 @@ public class CreateJobStmt extends DdlStmt { } return executeSql; } + + protected static boolean isInnerJob(String jobName) { + return jobName.startsWith(excludeJobNamePrefix); + } }