From 28c43f015119145d16cb3d850f587f6dfcc2f16b Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 11 May 2023 11:36:27 +0800 Subject: [PATCH] fix(stream): add null check. --- source/libs/executor/src/executor.c | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/source/libs/executor/src/executor.c b/source/libs/executor/src/executor.c index 434f2924d1..cafed977b7 100644 --- a/source/libs/executor/src/executor.c +++ b/source/libs/executor/src/executor.c @@ -160,9 +160,11 @@ void doSetTaskId(SOperatorInfo* pOperator) { SExecTaskInfo* pTaskInfo = pOperator->pTaskInfo; if (pOperator->operatorType == QUERY_NODE_PHYSICAL_PLAN_STREAM_SCAN) { SStreamScanInfo* pStreamScanInfo = pOperator->info; - STableScanInfo* pScanInfo = pStreamScanInfo->pTableScanOp->info; - if (pScanInfo->base.dataReader != NULL) { - tsdbReaderSetId(pScanInfo->base.dataReader, pTaskInfo->id.str); + if (pStreamScanInfo->pTableScanOp != NULL) { + STableScanInfo* pScanInfo = pStreamScanInfo->pTableScanOp->info; + if (pScanInfo->base.dataReader != NULL) { + tsdbReaderSetId(pScanInfo->base.dataReader, pTaskInfo->id.str); + } } } else { doSetTaskId(pOperator->pDownstream[0]);