thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-17 21:24:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update SinkToStorage.cpp

Browse Source
This commit is contained in:
Nikolai Kochetov 2021-09-09 15:46:06 +03:00
parent aea1871755
commit 5c220d62b3
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Processors/Sinks/SinkToStorage.cpp
View File

@ -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;