From 05a204dd6c51717c78a0640816bf66528c42b93f Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 30 Apr 2024 19:30:56 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/libs/stream/src/streamMeta.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index aca0a38d48..a091a866a0 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -314,6 +314,7 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF } if (streamMetaMayCvtDbFormat(pMeta) < 0) { + stError("vgId:%d convert sub info format failed, open stream meta failed", pMeta->vgId); goto _err; } @@ -372,8 +373,8 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF pMeta->numOfPausedTasks = 0; pMeta->numOfStreamTasks = 0; - stInfo("vgId:%d open stream meta successfully, latest checkpoint:%" PRId64 ", stage:%" PRId64, vgId, pMeta->chkpId, - stage); + + stInfo("vgId:%d open stream meta succ, latest checkpoint:%" PRId64 ", stage:%" PRId64, vgId, pMeta->chkpId, stage); pMeta->rid = taosAddRef(streamMetaId, pMeta);