From 5531da99ff394099db8c83032129d218c9d79058 Mon Sep 17 00:00:00 2001 From: Alex Duan <417921451@qq.com> Date: Fri, 28 Jun 2024 15:35:12 +0800 Subject: [PATCH] fix: if multi-stable set stmt singleSingleStb false --- src/benchInsert.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/benchInsert.c b/src/benchInsert.c index 009cf7d3..2797fcfb 100644 --- a/src/benchInsert.c +++ b/src/benchInsert.c @@ -2495,7 +2495,7 @@ void *syncWriteProgressive(void *sarg) { int64_t delay3 = 0; if (stmt) { taos_stmt_close(pThreadInfo->conn->stmt); - if(stbInfo->autoTblCreating) { + if(stbInfo->autoTblCreating || database->superTbls->size > 1) { pThreadInfo->conn->stmt = taos_stmt_init(pThreadInfo->conn->taos); } else { TAOS_STMT_OPTIONS op; @@ -3431,7 +3431,7 @@ int32_t initInsertThread(SDataBase* database, SSuperTable* stbInfo, int32_t nthr goto END; } taos_stmt_close(pThreadInfo->conn->stmt); - if(stbInfo->autoTblCreating) { + if (stbInfo->autoTblCreating || database->superTbls->size > 1) { pThreadInfo->conn->stmt = taos_stmt_init(pThreadInfo->conn->taos); } else { TAOS_STMT_OPTIONS op;