setup oracle correctly in stream writer dgraph-io#1968

mYmNeo · Sep 4, 2024 · 1e11857 · 1e11857
1 parent 5d16ecf
commit 1e11857
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/stream_writer.go b/stream_writer.go
@@ -225,6 +225,11 @@ func (sw *StreamWriter) Flush() error {
 		if sw.db.orc != nil {
 			sw.db.orc.Stop()
 		}
+
+		if curMax := sw.db.orc.readTs(); curMax >= sw.maxVersion {
+			sw.maxVersion = curMax
+		}
+
 		sw.db.orc = newOracle(sw.db.opt)
 		sw.db.orc.nextTxnTs = sw.maxVersion
 		sw.db.orc.txnMark.Done(sw.maxVersion)