sink_node can use sync source

Rafał Hibner · Rafał Hibner · commit b85e49620df0 · 2025-02-11T15:21:48.000Z
diff --git a/cpp/src/arrow/acero/pipe_node.cc b/cpp/src/arrow/acero/pipe_node.cc
@@ -142,7 +142,7 @@ class PipeSinkNode : public ExecNode {
   }
 
   Status Init() override {
-    ARROW_RETURN_NOT_OK(pipe_->Init(inputs_[0]->output_schema()));
+    ARROW_RETURN_NOT_OK(pipe_->Init(inputs_[0]->output_schema(), true));
     return ExecNode::Init();
   }
 

Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,7 @@ class PipeSinkNode : public ExecNode {`
`142`	`142`	`}`
`143`	`143`
`144`	`144`	`Status Init() override {`
`145`		`- ARROW_RETURN_NOT_OK(pipe_->Init(inputs_[0]->output_schema()));`
	`145`	`+ ARROW_RETURN_NOT_OK(pipe_->Init(inputs_[0]->output_schema(), true));`
`146`	`146`	`return ExecNode::Init();`
`147`	`147`	`}`
`148`	`148`