diff --git a/src/Processors/Formats/Impl/ParallelFormattingOutputFormat.h b/src/Processors/Formats/Impl/ParallelFormattingOutputFormat.h index 2287bec1ab3..e8157708af7 100644 --- a/src/Processors/Formats/Impl/ParallelFormattingOutputFormat.h +++ b/src/Processors/Formats/Impl/ParallelFormattingOutputFormat.h @@ -52,7 +52,7 @@ public: { need_flush = true; if (!IOutputFormat::finalized) - std::terminate(); + finalize(); finishAndWait(); } @@ -70,7 +70,6 @@ public: void onCancel() override { - std::cout << "onCancel" << std::endl; finishAndWait(); }