diff --git a/src/Processors/Sinks/SinkToStorage.cpp b/src/Processors/Sinks/SinkToStorage.cpp
index b26c905c458..586b41eb918 100644
--- a/src/Processors/Sinks/SinkToStorage.cpp
+++ b/src/Processors/Sinks/SinkToStorage.cpp
@@ -71,7 +71,12 @@ IProcessor::Status ExceptionKeepingTransform::prepare()
             return Status::PortFull;
         }
 
-        ready_input = true;
+        if (has_exception)
+            /// In case of exception, just drop all other data.
+            /// If transform is stateful, it's state may be broken after exception from transform()
+            data.chunk.clear();
+        else
+            ready_input = true;
     }
 
     return Status::Ready;