Skip to content

[pull] trunk from spiceai:trunk#43

Merged
pull[bot] merged 2 commits into
TheRakeshPurohit:trunkfrom
spiceai:trunk
Apr 22, 2025
Merged

[pull] trunk from spiceai:trunk#43
pull[bot] merged 2 commits into
TheRakeshPurohit:trunkfrom
spiceai:trunk

Conversation

@pull
Copy link
Copy Markdown

@pull pull Bot commented Apr 22, 2025

See Commits and Changes for more details.


Created by pull[bot] (v2.0.0-alpha.1)

Can you help keep this open source service alive? 💖 Please sponsor : )

kczimm and others added 2 commits April 22, 2025 14:58
* allow parameter queries with no parameters

* use Bytes::default
* Support unparsing UNION for distinct results

* Update cargo.lock

---------

Co-authored-by: Luke Kim <80174+lukekim@users.noreply.github.com>
@pull pull Bot added the ⤵️ pull label Apr 22, 2025
@pull pull Bot merged commit 6e0658a into TheRakeshPurohit:trunk Apr 22, 2025
pull Bot pushed a commit that referenced this pull request May 22, 2026
…tafusion-ballista PRs #42 + #43) (spiceai#10919)

Bumps ballista-core / ballista-executor / ballista-scheduler to spiceai-52.5
tip (07be66a8), which carries:

  1. (#42) Wrap ObjectStoreShuffleStorage in object_store::prefix::PrefixStore
     so the URL path is reattached to every key — without this, writers
     uploaded to s3://bucket/<job>/... while readers looked under
     s3://bucket/<prefix>/<job>/... and got NotFound on every reduce stage.

  2. (#43) Dispatch s3:// partition paths inside BallistaClient::fetch_partition
     to the existing object-store reader. Before this the gRPC FetchPartition
     handler called tokio::fs::File::open("s3://...") and failed every
     single-batch query (q1) and reduce-stage fetch (q2+).

  3. (#43) Replace per-batch serialize_batch_to_ipc_bytes with a long-lived
     StreamingMultipartIpcUploader: one StreamWriter per output partition
     means the IPC stream has one header and one EOS marker instead of one
     stream per batch concatenated together. Fixes the
     ArrowError(IpcError("Unexpected EOS")) we saw on multi-batch hash-
     repartition queries.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants