Make inputReceived error not fatal

Rafał Hibner · Rafał Hibner · commit d1fea1de94e3 · 2025-10-07T12:35:57.000Z
diff --git a/cpp/src/arrow/acero/sorted_merge_node.cc b/cpp/src/arrow/acero/sorted_merge_node.cc
@@ -559,7 +559,7 @@ class SortedMergeNode : public ExecNode {
         out_b.index = batches_produced++;
         Status st = output_->InputReceived(this, std::move(out_b));
         if (!st.ok()) {
-          ARROW_LOG(FATAL) << "Error in output_::InputReceived: " << st.ToString();
+          ARROW_LOG(ERROR) << "Error in output_::InputReceived: " << st.ToString();
           EndFromProcessThread(std::move(st));
         }
       } else {

Original file line number	Diff line number	Diff line change
`@@ -559,7 +559,7 @@ class SortedMergeNode : public ExecNode {`
`559`	`559`	`out_b.index = batches_produced++;`
`560`	`560`	`Status st = output_->InputReceived(this, std::move(out_b));`
`561`	`561`	`if (!st.ok()) {`
`562`		`- ARROW_LOG(FATAL) << "Error in output_::InputReceived: " << st.ToString();`
	`562`	`+ ARROW_LOG(ERROR) << "Error in output_::InputReceived: " << st.ToString();`
`563`	`563`	`EndFromProcessThread(std::move(st));`
`564`	`564`	`}`
`565`	`565`	`} else {`