From ce9dae676855d12294c89514cc3eb80ecca69816 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 23 Oct 2020 14:37:00 +0800 Subject: [PATCH] [td-1373] --- src/query/src/qExecutor.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c index 331c8faa53..7df85369ec 100644 --- a/src/query/src/qExecutor.c +++ b/src/query/src/qExecutor.c @@ -4769,9 +4769,9 @@ static bool multiTableMultioutputHelper(SQInfo *pQInfo, int32_t index) { if (pRuntimeEnv->pTSBuf != NULL) { if (pRuntimeEnv->cur.vgroupIndex == -1) { - STSElem elem = tsBufGetElemStartPos(pRuntimeEnv->pTSBuf, 0, &pRuntimeEnv->pCtx[0].tag); + STSElem elem = tsBufGetElemStartPos(pRuntimeEnv->pTSBuf, pQInfo->vgId, &pRuntimeEnv->pCtx[0].tag); - // failed to find data with the specified tag value + // failed to find data with the specified tag value and vnodeId if (elem.vnode < 0) { return false; }