From 6677dfba943e176ddde55ca373fb6dfe26541fef Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Tue, 11 Jan 2022 18:57:19 +0800 Subject: [PATCH] feature/qnode --- source/libs/qworker/src/qworker.c | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/source/libs/qworker/src/qworker.c b/source/libs/qworker/src/qworker.c index ad3e8073ee..2a395fcfe1 100644 --- a/source/libs/qworker/src/qworker.c +++ b/source/libs/qworker/src/qworker.c @@ -964,6 +964,13 @@ int32_t qwHandleFetch(SQWorkerMgmt *mgmt, uint64_t sId, uint64_t queryId, uint64 qError("dsGetDataBlock failed, code:%x", code); QW_ERR_JRET(code); } + + rsp->useconds = htobe64(output.useconds); + rsp->completed = 0; + rsp->precision = output.precision; + rsp->compressed = output.compressed; + rsp->compLen = htonl(dataLength); + rsp->numOfRows = htonl(output.numOfRows); if (DS_BUF_EMPTY == output.bufStatus && output.queryEnd) { rsp->completed = 1;