fix(stream): add return.
This commit is contained in:
parent
f7ee65d059
commit
41aa175099
|
@ -1231,6 +1231,7 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) {
|
||||||
bool updated = taskNodeIsUpdated(pMnode);
|
bool updated = taskNodeIsUpdated(pMnode);
|
||||||
if (updated) {
|
if (updated) {
|
||||||
mWarn("checkpoint ignore, stream task nodes update detected");
|
mWarn("checkpoint ignore, stream task nodes update detected");
|
||||||
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
{ // check if all tasks are in TASK_STATUS__READY status
|
{ // check if all tasks are in TASK_STATUS__READY status
|
||||||
|
|
Loading…
Reference in New Issue