Skip to content

Commit

Permalink
[regression test](routine test) add case for desired_concurrent_number (
Browse files Browse the repository at this point in the history
  • Loading branch information
liugddx authored and 胥剑旭 committed Dec 14, 2023
1 parent 26b959b commit 75cfaa7
Show file tree
Hide file tree
Showing 3 changed files with 321 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -462,7 +462,7 @@ private void checkJobProperties() throws UserException {
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,
Expand Down
Loading

0 comments on commit 75cfaa7

Please sign in to comment.