Skip to content

[pull] trunk from spiceai:trunk#858

Merged
pull[bot] merged 3 commits into
TheRakeshPurohit:trunkfrom
spiceai:trunk
May 22, 2026
Merged

[pull] trunk from spiceai:trunk#858
pull[bot] merged 3 commits into
TheRakeshPurohit:trunkfrom
spiceai:trunk

Conversation

@pull
Copy link
Copy Markdown

@pull pull Bot commented May 22, 2026

See Commits and Changes for more details.


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

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

phillipleblanc and others added 3 commits May 22, 2026 08:10
Two independent fixes:

* EmbeddingTable::get_logical_plan now returns None. The forwarding
  added in #10795 caused LogicalPlanBuilder::scan to inline the inner
  ViewTable's logical plan (base columns only), then fail when the
  caller projected the embedding columns that EmbeddingTable adds on
  top. This made test_multi_column_search_view (and likely the flaky
  s3_vectors view+embeddings tests) consistently fail. Mirrors the
  existing IndexedTableProvider pattern, which already returns None
  for the same reason.

* Add the missing snapshot files for test_explicit_dataset_search-
  ability_validation (introduced in #10968 without them):
    - explicit_non_searchable_dataset_errors_error_response
    - explicit_mixed_datasets_fail_fast_error_response
    - explicit_searchable_dataset_no_matches_returns_empty_response
…napshot exists (#10979)

Co-authored-by: Phillip LeBlanc <879445+phillipleblanc@users.noreply.github.com>
…start (#11007)

* fix lint

* fix: re-insert offsets on seek failure and fix clippy redundant closures

* fix(kafka): stash sidecar offsets at construction to close subscribe race

The previous fix had callers invoke restore_offsets() after subscribe(),
relying on the post_rebalance callback to fire later. Under cold-start
or slow-broker conditions the assignment can arrive before the setter
writes the stash — the callback sees None and the consumer falls back
to auto.offset.reset=smallest, silently replaying from the beginning.

Move the offsets into the consumer context at construction so the stash
is in place before subscribe() can trigger a rebalance. The standalone
restore_offsets() method is replaced by an argument on
create_with_existing_group_id. Debezium's consumer construction moves
below the schema-evolution check so post-evolution metadata.offsets are
the ones threaded through.

---------

Co-authored-by: Phillip LeBlanc <879445+phillipleblanc@users.noreply.github.com>
@pull pull Bot locked and limited conversation to collaborators May 22, 2026
@pull pull Bot added the ⤵️ pull label May 22, 2026
@pull pull Bot merged commit 70f76b5 into TheRakeshPurohit:trunk May 22, 2026
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants