milenkovicm opened a new issue, #17292:
URL: https://github.com/apache/datafusion/issues/17292
### Is your feature request related to a problem or challenge?
I'd like to run sort merge join in ballista but at the moment physical plan
serde will fail
Minimum reproducer:
```rust
#[tokio::main]
async fn main() -> datafusion::error::Result<()> {
let ctx = datafusion::prelude::SessionContext::new();
ctx.register_parquet("t0", "data/parquet/", Default::default())
.await?;
ctx.register_parquet("t1", "data/parquet/", Default::default())
.await?;
ctx.sql("SET datafusion.optimizer.prefer_hash_join = false")
.await?
.show()
.await?;
let plan = ctx
.sql("select t0.* from t0 join t1 on t0.id = t1.id")
.await?
.create_physical_plan()
.await?;
// will fail with
// Unsupported plan and extension codec failed with [This feature is not
implemented: PhysicalExtensionCodec is not provided]. Plan: SortMergeJoinExec
...
datafusion_proto::bytes::physical_plan_to_bytes(plan).unwrap();
Ok(())
}
```
will fail with unsupported serde for `SortMergeJoinExec`
### Describe the solution you'd like
Provide a proto support for `SortMergeJoinExec` as the first step of to
support SortMergeJoin
### Describe alternatives you've considered
_No response_
### Additional context
_No response_
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
