fix(sma): split stream task for specified vgroup

30627ce1 · Liu Jicong · b8a7c8b2 · 30627ce1
隐藏空白更改
内联并排

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);