fix:set task code success after kill
This commit is contained in:
parent
7b735c67d0
commit
591b51f624
|
@ -575,7 +575,7 @@ int32_t tqProcessSubscribeReq(STQ* pTq, int64_t sversion, char* msg, int32_t msg
|
||||||
if(tqIsHandleExec(pHandle)) {
|
if(tqIsHandleExec(pHandle)) {
|
||||||
qTaskInfo_t pTaskInfo = pHandle->execHandle.task;
|
qTaskInfo_t pTaskInfo = pHandle->execHandle.task;
|
||||||
if (pTaskInfo != NULL) {
|
if (pTaskInfo != NULL) {
|
||||||
qKillTask(pTaskInfo, TSDB_CODE_TSC_QUERY_KILLED);
|
qKillTask(pTaskInfo, TSDB_CODE_SUCCESS);
|
||||||
}
|
}
|
||||||
|
|
||||||
// if (pHandle->execHandle.subType == TOPIC_SUB_TYPE__COLUMN) {
|
// if (pHandle->execHandle.subType == TOPIC_SUB_TYPE__COLUMN) {
|
||||||
|
|
Loading…
Reference in New Issue