Repository navigation
[Rust] Test Arrow mux lifecycle - #867
Draft
danilonajkov-db wants to merge 7 commits into
Draft
danilonajkov-db wants to merge 7 commits into
danilonajkov-db wants to merge 7 commits into
Conversation
This was referenced Sep 22, 2026
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
2 times, most recently
from
September 22, 2026 13:52
783912e to
0a351a6
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
September 23, 2026 11:08
fbcdcbe to
846642f
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
September 23, 2026 11:08
0a351a6 to
c7a4214
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
September 23, 2026 12:52
846642f to
fe46935
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
September 23, 2026 12:52
c7a4214 to
928c3ad
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
September 23, 2026 14:54
fe46935 to
e208838
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
2 times, most recently
from
September 23, 2026 15:18
9827eb0 to
2fe2309
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
2 times, most recently
from
September 25, 2026 10:49
71e31cb to
5e2aa6d
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
September 25, 2026 10:49
2fe2309 to
ce2a23f
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
September 25, 2026 13:32
5e2aa6d to
7876529
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
September 25, 2026 13:32
ce2a23f to
b6ad666
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
September 25, 2026 15:58
7876529 to
28e40c3
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
September 25, 2026 15:58
b6ad666 to
c37ad58
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
September 28, 2026 16:59
28e40c3 to
21a7300
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
2 times, most recently
from
September 30, 2026 14:58
edc7a91 to
a0918bc
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
September 30, 2026 14:58
21a7300 to
117c993
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
October 1, 2026 14:04
a0918bc to
b80c1be
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
October 1, 2026 14:04
117c993 to
3724f79
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
2 times, most recently
from
October 1, 2026 15:46
b87386b to
cf83653
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
October 5, 2026 15:31
97aa0ee to
48c4c0d
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
October 5, 2026 15:31
cf83653 to
8e691ce
Compare
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow-api
branch
from
October 13, 2026 14:01
48c4c0d to
85c275b
Compare
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
2 times, most recently
from
October 13, 2026 14:01
8e691ce to
f435ac3
Compare
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
October 14, 2026 11:37
f435ac3 to
c1fc03d
Compare
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
October 14, 2026 11:49
c1fc03d to
ef6b06d
Compare
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
danilonajkov-db
force-pushed
the
danilo-najkov_data/effort/mux-streams-arrow
branch
from
October 14, 2026 12:08
ef6b06d to
230c538
Compare
Base automatically changed from
danilo-najkov_data/effort/mux-streams-arrow-api
to
main
October 14, 2026 13:43
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
What changes are proposed in this pull request?
Add nine Arrow mux integration tests covering terminal poisoning, healthy-lane waits, partial-ack suffix retrieval, retryable replay, mux-wide backpressure, capacity timeout and cancellation, interrupted close/recovery, construction cleanup, and poisoned capacity waiters. The mock Flight server can script individual connections so failures and healthy sibling lanes can be exercised independently. Timing-sensitive cases use virtual time and synchronization barriers.
This PR changes tests only. Stack base: #866.
How is this tested?
make testandmake lintmatrices passed for the combined stack.