From 47717df036342a1bfe172271c0e32de747d8045a Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Fri, 2 Sep 2022 18:25:28 +0800 Subject: [PATCH] enh: remove hb and response query immediately --- source/libs/qworker/src/qworker.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/source/libs/qworker/src/qworker.c b/source/libs/qworker/src/qworker.c index d57b8e2e33..4f45eda7ce 100644 --- a/source/libs/qworker/src/qworker.c +++ b/source/libs/qworker/src/qworker.c @@ -206,6 +206,10 @@ int32_t qwGetQueryResFromSink(QW_FPARAMS_DEF, SQWTaskCtx *ctx, int32_t *dataLen, int32_t code = 0; SOutputData output = {0}; + if (NULL == ctx->sinkHandle) { + return TSDB_CODE_SUCCESS; + } + *dataLen = 0; while (true) { -- GitLab