fix(stream): set tbname for parition

a0291949 · Liu Jicong · 3b840538 · a0291949
隐藏空白更改
内联并排

Showing with 3 addition and 0 deletion

source/libs/executor/src/groupoperator.c source/libs/executor/src/groupoperator.c +3 -0

未找到文件。
--- a/source/libs/executor/src/groupoperator.c
+++ b/source/libs/executor/src/groupoperator.c
@@ -906,6 +906,9 @@ static SSDataBlock* buildStreamPartitionResult(SOperatorInfo* pOperator) {
      } else {
        pDest->info.parTbName[0] = 0;
      }
+      if (pParInfo->groupId && pDest->info.parTbName[0]) {
+        streamStatePutParName(pOperator->pTaskInfo->streamInfo.pState, pParInfo->groupId, pDest->info.parTbName);
+      }
      /*printf("\n\n set name %s\n\n", pDest->info.parTbName);*/
      blockDataDestroy(pTmpBlock);
      blockDataDestroy(pResBlock);