fix(stream):fix error in unit test cases.
This commit is contained in:
parent
665107ad3a
commit
87dfc1f931
|
@ -62,8 +62,8 @@ SRpcMsg buildHbReq() {
|
||||||
entry.id.taskId = 5;
|
entry.id.taskId = 5;
|
||||||
entry.id.streamId = defStreamId;
|
entry.id.streamId = defStreamId;
|
||||||
|
|
||||||
entry.checkpointId = 1;
|
entry.checkpointInfo.activeId = 1;
|
||||||
entry.checkpointFailed = true;
|
entry.checkpointInfo.failed = true;
|
||||||
|
|
||||||
taosArrayPush(msg.pTaskStatus, &entry);
|
taosArrayPush(msg.pTaskStatus, &entry);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue