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

[regression test](routine test) add case for send_batch_parallelism (#27333)

Browse Source
This commit is contained in:
Guangdong Liu
2023-11-21 20:43:20 +08:00
committed by GitHub
parent a0fab03289
commit c1435c0589
3 changed files with 328 additions and 15 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

@ -492,7 +492,7 @@ public class CreateRoutineLoadStmt extends DdlStmt {
sendBatchParallelism = ((Long) Util.getLongPropertyOrDefault(jobProperties.get(SEND_BATCH_PARALLELISM),
ConnectContext.get().getSessionVariable().getSendBatchParallelism(), SEND_BATCH_PARALLELISM_PRED,
SEND_BATCH_PARALLELISM + " should > 0")).intValue();
SEND_BATCH_PARALLELISM + " must be greater than 0")).intValue();
loadToSingleTablet = Util.getBooleanPropertyOrDefault(jobProperties.get(LoadStmt.LOAD_TO_SINGLE_TABLET),
RoutineLoadJob.DEFAULT_LOAD_TO_SINGLE_TABLET,
LoadStmt.LOAD_TO_SINGLE_TABLET + " should be a boolean");