thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-25 11:10:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Better exception safety for SourceFromInputStream.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-05-15 14:59:13 +03:00
parent b2a3835195
commit f5e20027a7
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
dbms/src/Processors/Sources/SourceFromInputStream.cpp
View File

@ -63,7 +63,20 @@ IProcessor::Status SourceFromInputStream::prepare()
void SourceFromInputStream::work()
{
if (!is_generating_finished)
return ISource::work();
{
try
{
ISource::work();
}
catch (...)
{
/// Won't read suffix in case of exception.
is_stream_finished = true;
throw;
}
return;
}
if (is_stream_finished)
return;