diff --git a/dbms/src/DataStreams/ParallelParsingBlockInputStream.cpp b/dbms/src/DataStreams/ParallelParsingBlockInputStream.cpp index 1613671e240..12f977c6feb 100644 --- a/dbms/src/DataStreams/ParallelParsingBlockInputStream.cpp +++ b/dbms/src/DataStreams/ParallelParsingBlockInputStream.cpp @@ -103,7 +103,6 @@ void ParallelParsingBlockInputStream::parserThreadFunction(size_t current_unit_n unit.status = READY_TO_READ; reader_condvar.notify_all(); } - } catch (...) {