diff --git a/stream_writer.go b/stream_writer.go
index a3d563f1a..90e0476df 100644
--- a/stream_writer.go
+++ b/stream_writer.go
@@ -273,12 +273,13 @@ func (sw *StreamWriter) Flush() error {
 	if !sw.db.opt.managedTxns {
 		if sw.db.orc != nil {
 			sw.db.orc.Stop()
-		}
 
-		if curMax := sw.db.orc.readTs(); curMax >= sw.maxVersion {
-			sw.maxVersion = curMax
+			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)