valid iter
This commit is contained in:
parent
fe18c77809
commit
511e1c8f1a
|
@ -3337,7 +3337,7 @@ int32_t streamStateClear_rocksdb(SStreamState* pState) {
|
|||
return 0;
|
||||
}
|
||||
void streamStateCurNext_rocksdb(SStreamStateCur* pCur) {
|
||||
if (pCur) {
|
||||
if (pCur && pCur->iter && rocksdb_iter_valid(pCur->iter)) {
|
||||
rocksdb_iter_next(pCur->iter);
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue