diff --git a/sdk/data/stream/extent_handler.go b/sdk/data/stream/extent_handler.go
index d25e962e17..a25631b867 100644
--- a/sdk/data/stream/extent_handler.go
+++ b/sdk/data/stream/extent_handler.go
@@ -612,6 +612,5 @@ func (eh *ExtentHandler) setRecovery() bool {
 }
 
 func (eh *ExtentHandler) setError() bool {
-	atomic.StoreInt32(&eh.stream.status, StreamerError)
 	return atomic.CompareAndSwapInt32(&eh.status, ExtentStatusRecovery, ExtentStatusError)
 }