Merge pull request #16803 from taosdata/feature/stream

fix(sma): split stream task for specified vgroup

Merge pull request #16803 from taosdata/feature/stream
fix(sma): split stream task for specified vgroup
8b707226 · Liu Jicong · GitHub · abdd28f3 · 30627ce1 · 8b707226
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/dnode/mnode/impl/src/mndScheduler.c source/dnode/mnode/impl/src/mndScheduler.c +1 -1

未找到文件。
--- a/source/dnode/mnode/impl/src/mndScheduler.c
+++ b/source/dnode/mnode/impl/src/mndScheduler.c
@@ -319,7 +319,7 @@ int32_t mndScheduleStream(SMnode* pMnode, SStreamObj* pStream) {

  bool multiTarget = pDbObj->cfg.numOfVgroups > 1;

-  if (planTotLevel == 2 || externalTargetDB || multiTarget) {
+  if (planTotLevel == 2 || externalTargetDB || multiTarget || pStream->fixedSinkVgId) {
    /*if (true) {*/
    SArray* taskOneLevel = taosArrayInit(0, sizeof(void*));
    taosArrayPush(pStream->tasks, &taskOneLevel);