We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4c21b59 commit 983d13aCopy full SHA for 983d13a
1 file changed
doris/benchmark.sh
@@ -96,8 +96,13 @@ mv *.parquet "$BE_DATA_DIR/user_files_secure"
96
97
BE_ID=$(mysql -h127.0.0.1 -P9030 -uroot -N -e 'show backends' | awk '{print $1}' | head -1)
98
99
-PARALLEL_NUM=$(($(nproc) / 4))
100
-echo "Setting parallel_pipeline_task_num to $PARALLEL_NUM (cpu cores: $(nproc) / 4)"
+CORES=$(nproc)
+PARALLEL_NUM=$((CORES / 4))
101
+if [ "$PARALLEL_NUM" -lt 1 ]; then
102
+ echo "Computed parallel_pipeline_task_num ($PARALLEL_NUM) is less than 1 based on $CORES cores; clamping to 1."
103
+ PARALLEL_NUM=1
104
+fi
105
+echo "Setting parallel_pipeline_task_num to $PARALLEL_NUM (cpu cores: $CORES, computed as CORES/4 with min 1)"
106
107
echo "start loading hits.parquet using TVF, estimated to take about 3 minutes ..."
108
START=$(date +%s)
0 commit comments