Merge pull request #28189 from taosdata/fix/TD-32387

valid iter
2024-10-30 14:05:48 +08:00 · 2024-10-30 14:05:48 +08:00 · 8c07f93c71
parent 19da0f627e 511e1c8f1a
commit 8c07f93c71
1 changed files with 1 additions and 1 deletions
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@ -3364,7 +3364,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);
  }
 }