File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -141,7 +141,7 @@ class PipeSinkNode : public ExecNode {
141141 return pipe_->InputFinished (total_batches);
142142 }
143143
144- Status Init () { return pipe_->Init (inputs_[0 ]->output_schema ()); }
144+ Status Init () override { return pipe_->Init (inputs_[0 ]->output_schema ()); }
145145
146146 Status StartProducing () override { return Status::OK (); }
147147
@@ -243,7 +243,8 @@ Status PipeSource::Validate(const Ordering& ordering) {
243243 return Status::Invalid (" Pipe does not have sink" );
244244 }
245245 if (!ordering.IsSuborderOf (pipe_->ordering ()))
246- return Status::Invalid (" Pipe source ordering is not subordering of pipe sink" );
246+ if (!(ordering.is_implicit () && pipe_->ordering ().is_implicit ()))
247+ return Status::Invalid (" Pipe source ordering is not subordering of pipe sink" );
247248
248249 return Status::OK ();
249250}
You can’t perform that action at this time.
0 commit comments