fix(stream): update the version when open stream tasks.

a3b02a80 · Haojun Liao · 3aa68977 · a3b02a80
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

source/libs/stream/src/streamMeta.c source/libs/stream/src/streamMeta.c +2 -1

未找到文件。
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -296,7 +296,8 @@ int32_t streamLoadTasks(SStreamMeta* pMeta, int64_t ver) {
    tDecodeStreamTask(&decoder, pTask);
    tDecoderClear(&decoder);

-    if (pMeta->expandFunc(pMeta->ahandle, pTask, -1) < 0) {
+    // todo set correct initial version.
+    if (pMeta->expandFunc(pMeta->ahandle, pTask, 0) < 0) {
      tdbFree(pKey);
      tdbFree(pVal);
      tdbTbcClose(pCur);