From 71fabef903bdfb7c34357b34620dc9036b3991ff Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Mon, 28 Mar 2022 17:30:32 +0800
Subject: [PATCH] stream add shuffle dispatcher

---
 source/libs/stream/src/tstream.c | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/libs/stream/src/tstream.c b/source/libs/stream/src/tstream.c
index eb4cd2f97d..220f83bb3e 100644
--- a/source/libs/stream/src/tstream.c
+++ b/source/libs/stream/src/tstream.c
@@ -37,7 +37,8 @@ static int32_t streamBuildDispatchMsg(SStreamTask* pTask, SArray* data, SRpcMsg*
     req.taskId = pTask->fixedEpDispatcher.taskId;
   } else if (pTask->dispatchType == TASK_DISPATCH__SHUFFLE) {
     int32_t nodeId = 0;
-    char    ctbName[TSDB_TABLE_FNAME_LEN];
+    // TODO fix tbname issue
+    char ctbName[TSDB_TABLE_FNAME_LEN + 22];
     // all groupId must be the same in an array
     SSDataBlock* pBlock = taosArrayGet(data, 0);
     sprintf(ctbName, "%s:%ld", pTask->shuffleDispatcher.stbFullName, pBlock->info.groupId);