fix(stream): update the msg struct.

This commit is contained in:
Haojun Liao 2024-02-27 12:59:08 +08:00
parent de1c67f773
commit d05c55f3fe
1 changed files with 1 additions and 1 deletions

View File

@ -486,7 +486,7 @@ int32_t tqStreamTaskProcessCheckRsp(SStreamMeta* pMeta, SRpcMsg* pMsg, bool isLe
}
typedef struct SMStreamCheckpointReadyRspMsg {
int8_t placeholder;
SMsgHead head;
}SMStreamCheckpointReadyRspMsg;
int32_t tqStreamTaskProcessCheckpointReadyMsg(SStreamMeta* pMeta, SRpcMsg* pMsg) {