add dstVgId

451a65f5 · Cary Xu · f266d593 · 451a65f5
隐藏空白更改
内联并排

Showing with 1 addition and 2 deletion

source/dnode/mnode/impl/src/mndSma.c source/dnode/mnode/impl/src/mndSma.c +1 -2

未找到文件。
--- a/source/dnode/mnode/impl/src/mndSma.c
+++ b/source/dnode/mnode/impl/src/mndSma.c
@@ -416,8 +416,7 @@ static int32_t mndCreateSma(SMnode *pMnode, SNodeMsg *pReq, SMCreateSmaReq *pCre
  streamObj.version = 1;
  streamObj.sql = pCreate->sql;
  streamObj.createdBy = STREAM_CREATED_BY__SMA;
-  // TODO
-  streamObj.fixedSinkVgId = 0;
+  streamObj.fixedSinkVgId = smaObj.dstVgId;
  streamObj.smaId = smaObj.uid;
  /*streamObj.physicalPlan = "";*/
  streamObj.logicalPlan = "not implemented";