database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Bug] Return error if user failed to pause/resume a certain routine load. (#6426)

Browse Source 
When operating a single job, maintain the same behavior as before
This problem is introduced by #6394.
This commit is contained in:
Mingyu Chen
2021-08-12 11:50:57 +08:00
committed by GitHub
parent a7d620c359
commit 671d8f6af8
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java
View File

@ -41,14 +41,14 @@ import org.apache.doris.persist.AlterRoutineLoadJobOperationLog;
import org.apache.doris.persist.RoutineLoadOperation;
import org.apache.doris.qe.ConnectContext;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.google.common.base.Preconditions;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
@ -286,6 +286,11 @@ public class RoutineLoadManager implements Writable {
"routine load job has been paused by user").build());
} catch (UserException e) {
LOG.warn("failed to pause routine load job {}", routineLoadJob.getName(), e);
// if user want to pause a certain job and failed, return error.
// if user want to pause all possible jobs, skip error jobs.
if (!pauseRoutineLoadStmt.isAll()) {
throw e;
}
continue;
}
}
@ -316,6 +321,11 @@ public class RoutineLoadManager implements Writable {
.build());
} catch (UserException e) {
LOG.warn("failed to resume routine load job {}", routineLoadJob.getName(), e);
// if user want to resume a certain job and failed, return error.
// if user want to resume all possible jobs, skip error jobs.
if (!resumeRoutineLoadStmt.isAll()) {
throw e;
}
continue;
}
}