xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: void return code

This commit is contained in:
dapan1121 2024-12-16 19:20:16 +08:00
parent 7be31eea30
commit 2464f1ba68
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/qworker/src/qworker.c
View File

@ -819,10 +819,10 @@ int32_t qwProcessQuery(QW_FPARAMS_DEF, SQWMsg *qwMsg, char *sql) {
QW_ERR_JRET(TSDB_CODE_APP_ERROR); QW_ERR_JRET(TSDB_CODE_APP_ERROR);
} }
atomic_add_fetch_64(&gQueryMgmt.stat.taskRunNum, 1); (void)atomic_add_fetch_64(&gQueryMgmt.stat.taskRunNum, 1);
uint64_t flags = 0; uint64_t flags = 0;
dsGetSinkFlags(sinkHandle, &flags); (void)dsGetSinkFlags(sinkHandle, &flags);
ctx->level = plan->level; ctx->level = plan->level;
ctx->dynamicTask = qIsDynamicExecTask(pTaskInfo); ctx->dynamicTask = qIsDynamicExecTask(pTaskInfo);
@ -1353,7 +1353,7 @@ int32_t qwProcessDelete(QW_FPARAMS_DEF, SQWMsg *qwMsg, SDeleteRes *pRes) {
ctx.sinkHandle = sinkHandle; ctx.sinkHandle = sinkHandle;
uint64_t flags = 0; uint64_t flags = 0;
dsGetSinkFlags(sinkHandle, &flags); (void)dsGetSinkFlags(sinkHandle, &flags);
ctx.sinkWithMemPool = flags & DS_FLAG_USE_MEMPOOL; ctx.sinkWithMemPool = flags & DS_FLAG_USE_MEMPOOL;