fix test

apache · Oct 6, 2024 · 1742b2f · 1742b2f
1 parent 65b794a
commit 1742b2f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertJob.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertJob.java
@@ -299,7 +299,9 @@ public void cancelTaskById(long taskId) throws JobException {
  @Override
  public void cancelAllTasks() throws JobException {
  try {
- checkAuth("CANCEL LOAD");
+ if (getJobConfig().getExecuteType().equals(JobExecuteType.INSTANT)) {
+ checkAuth("CANCEL LOAD");
+ }
  super.cancelAllTasks();
  this.failMsg = new FailMsg(FailMsg.CancelType.USER_CANCEL, "user cancel");
  } catch (DdlException e) {

diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/task/AbstractTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/task/AbstractTask.java
@@ -141,7 +141,6 @@ public void cancel() throws JobException {
  executeCancelLogic();
  } catch (Exception e) {
  log.warn("cancel task failed, job id is {}, task id is {}", jobId, taskId, e);
- throw new JobException(e);
  } finally {
  closeOrReleaseResources();
  }