fix: compatibility after update stream

99657ccf · Shengliang Guan · b8cc1742 · 99657ccf
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

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

未找到文件。
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -153,7 +153,7 @@ SSdbRow *mndStreamActionDecode(SSdbRaw *pRaw) {
  SDecoder decoder;
  tDecoderInit(&decoder, buf, tlen + 1);
-  if (tDecodeSStreamObj(&decoder, pStream, 2) < 0) {
+  if (tDecodeSStreamObj(&decoder, pStream, sver) < 0) {
    tDecoderClear(&decoder);
    goto STREAM_DECODE_OVER;
  }