diff --git a/src/common/inc/tglobal.h b/src/common/inc/tglobal.h index e53c8987183ef4f036f06246cf13338173210806..26f9faecca3790ad816aee1f9df1dcb16ff8c9c0 100644 --- a/src/common/inc/tglobal.h +++ b/src/common/inc/tglobal.h @@ -222,7 +222,7 @@ extern uint32_t curRange; extern char Compressor[]; #endif // long query -extern int8_t tsDeathLockKillQuery; +extern int8_t tsDeadLockKillQuery; typedef struct { char dir[TSDB_FILENAME_LEN]; diff --git a/src/common/src/tglobal.c b/src/common/src/tglobal.c index c7725dde08ab8f1025444f173a37ec07ce2fcce7..1677c6b52a801f6bacf030d017e7d73da5495657 100644 --- a/src/common/src/tglobal.c +++ b/src/common/src/tglobal.c @@ -277,7 +277,7 @@ char Compressor[32] = "ZSTD_COMPRESSOR"; // ZSTD_COMPRESSOR or GZIP_COMPRESS #endif // long query death-lock -int8_t tsDeathLockKillQuery = 0; +int8_t tsDeadLockKillQuery = 0; int32_t (*monStartSystemFp)() = NULL; void (*monStopSystemFp)() = NULL; @@ -1651,8 +1651,8 @@ static void doInitGlobalConfig(void) { #endif // enable kill long query - cfg.option = "deathLockKillQuery"; - cfg.ptr = &tsDeathLockKillQuery; + cfg.option = "deadLockKillQuery"; + cfg.ptr = &tsDeadLockKillQuery; cfg.valType = TAOS_CFG_VTYPE_INT8; cfg.cfgType = TSDB_CFG_CTYPE_B_CONFIG | TSDB_CFG_CTYPE_B_SHOW; cfg.minValue = 0; diff --git a/src/query/src/queryMain.c b/src/query/src/queryMain.c index b92a4625f633cae2486a82bfb3cc7c3d6bf721ec..77fcdb0825a9ec3015b013fcf2e63629394506db 100644 --- a/src/query/src/queryMain.c +++ b/src/query/src/queryMain.c @@ -239,8 +239,8 @@ int waitMoment(SQInfo* pQInfo){ ms *= 1000; } } - - printf("wait sleep %dms. sql=%s\n", ms, pQInfo->sql); + if(ms == 0) return 0; + qWarn("wait sleep %dms. sql=%s", ms, pQInfo->sql); if(ms < 1000) { taosMsleep(ms); @@ -250,7 +250,7 @@ int waitMoment(SQInfo* pQInfo){ taosMsleep(1000); used_ms += 1000; if(isQueryKilled(pQInfo)){ - printf(" check query is canceled, sleep break... %s\n", pQInfo->sql); + qWarn("check query is canceled, sleep break... %s", pQInfo->sql); break; } } diff --git a/src/tsdb/src/tsdbBuffer.c b/src/tsdb/src/tsdbBuffer.c index be64f9ee1bdeffaaa4229c5e8c99d5ad5ebf847f..3dae2c6f4a087868897e71aeea34094a26732f1b 100644 --- a/src/tsdb/src/tsdbBuffer.c +++ b/src/tsdb/src/tsdbBuffer.c @@ -118,7 +118,7 @@ SListNode *tsdbAllocBufBlockFromPool(STsdbRepo *pRepo) { STsdbBufPool *pBufPool = pRepo->pPool; while (POOL_IS_EMPTY(pBufPool)) { - if(tsDeathLockKillQuery) { + if(tsDeadLockKillQuery) { // supply new Block if(tsdbInsertNewBlock(pRepo) > 0) { tsdbWarn("vgId:%d add new elastic block . elasticBlocks=%d totalBlocks=%d", REPO_ID(pRepo), pBufPool->nElasticBlocks, pBufPool->nBufBlocks);