Add comment in ParallelInputFormat, remove unneded include

This commit is contained in:
avogar 2023-09-15 13:07:04 +00:00
parent dbd24b240c
commit 35d975bfea
2 changed files with 4 additions and 1 deletions

View File

@ -3,7 +3,6 @@
#include <Processors/Formats/Impl/JSONEachRowRowOutputFormat.h>
#include <Formats/FormatFactory.h>
#include <Formats/JSONUtils.h>
#include <Common/logger_useful.h>
namespace DB

View File

@ -29,6 +29,10 @@ namespace DB
}
}
/// The code below is required to write valid output in case of exception during parallel parsing,
/// because we finish formatting and collecting threads in case of exception.
/// So, in case of exception after finalize we could still not output prefix/suffix or finalize underlying format.
if (collected_prefix && collected_suffix && collected_finalize)
return;