fix: thread concurrency <= count of a subtable

This commit is contained in:
Yaming Pei 2025-03-03 15:35:45 +08:00
parent 8ba478cad0
commit 2815227d25
1 changed files with 2 additions and 2 deletions

View File

@ -483,12 +483,12 @@ static int csvInitWriteMeta(SDataBase* db, SSuperTable* stb, CsvWriteMeta* write
break;
}
case CSV_NAMING_B_THREAD: {
write_meta->total_threads = g_arguments->nthreads;
write_meta->total_threads = MIN(g_arguments->nthreads, stb->childTblCount);
csvGenThreadFormatter(write_meta);
break;
}
case CSV_NAMING_B_THREAD_TIME_SLICE: {
write_meta->total_threads = g_arguments->nthreads;
write_meta->total_threads = MIN(g_arguments->nthreads, stb->childTblCount);
csvGenThreadFormatter(write_meta);
csvCalcTimestampStep(write_meta);
break;