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

[regression test](routine test) add case for desired_concurrent_number (#27372)

Browse Source
This commit is contained in:
Guangdong Liu
2023-11-23 15:11:01 +08:00
committed by GitHub
parent afe5af433a
commit c884e46e6c
3 changed files with 321 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java
View File

@ -462,7 +462,7 @@ public class CreateRoutineLoadStmt extends DdlStmt {
desiredConcurrentNum = ((Long) Util.getLongPropertyOrDefault(
jobProperties.get(DESIRED_CONCURRENT_NUMBER_PROPERTY),
Config.max_routine_load_task_concurrent_num, DESIRED_CONCURRENT_NUMBER_PRED,
DESIRED_CONCURRENT_NUMBER_PROPERTY + " should > 0")).intValue();
DESIRED_CONCURRENT_NUMBER_PROPERTY + " must be greater than 0")).intValue();
maxErrorNum = Util.getLongPropertyOrDefault(jobProperties.get(MAX_ERROR_NUMBER_PROPERTY),
RoutineLoadJob.DEFAULT_MAX_ERROR_NUM, MAX_ERROR_NUMBER_PRED,