diff --git a/include/libs/stream/tstream.h b/include/libs/stream/tstream.h index e857cce70d..84f34e1426 100644 --- a/include/libs/stream/tstream.h +++ b/include/libs/stream/tstream.h @@ -345,7 +345,7 @@ typedef struct SStreamMeta { FTaskExpand* expandFunc; int32_t vgId; SRWLatch lock; - int8_t walScan; + int32_t walScan; bool quit; } SStreamMeta;