Skip to content

Commit

Permalink
fix: if multi-stable set stmt singleSingleStb false
Browse files Browse the repository at this point in the history
  • Loading branch information
DuanKuanJun committed Jun 28, 2024
1 parent 79327c8 commit 5531da9
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/benchInsert.c
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down

0 comments on commit 5531da9

Please sign in to comment.