You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by hg...@apache.org on 2026/09/01 14:17:37 UTC
(iggy) branch fix/iceberg-partition-routing updated (7ad501923 -> 1a1cce689)
This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch fix/iceberg-partition-routing
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 7ad501923 fix(connectors): add iceberg store_path_style_access, reject non-JSON
add 0270b76b6 refactor(server): make the module graph a DAG and enforce it (#4023)
add 3aed9f458 fix(shard): keep a parked prepare's stamp and op order on re-dispatch (#4005)
new 1a1cce689 Merge branch 'master' into fix/iceberg-partition-routing
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
Cargo.lock | 16 +-
Cargo.toml | 2 -
bdd/docker-compose.cluster.yml | 6 +
core/integration/src/harness/handle/server.rs | 49 +-
core/integration/tests/cluster/mod.rs | 1 +
.../tests/cluster/parked_frame_redispatch.rs | 363 +++++++++++++++
core/partitions/src/send_messages2.rs | 17 -
core/server/Cargo.toml | 7 +-
core/server/build.rs | 23 +
core/server/src/auth.rs | 14 +-
core/server/src/bootstrap.rs | 187 +-------
core/server/src/consumer_group.rs | 6 +-
core/server/src/dispatch.rs | 58 ++-
core/server/src/dispatch/authz.rs | 2 +-
core/server/src/http.rs | 8 +-
core/server/src/http/forward.rs | 19 +-
core/server/src/http/handlers.rs | 67 +++
core/server/src/http/metrics.rs | 101 +---
core/server/src/http/reads.rs | 2 +-
core/server/src/http/state.rs | 23 +-
core/server/src/http/submit.rs | 2 +-
core/server/src/{ => http}/web.rs | 0
core/server/src/lib.rs | 53 ++-
core/server/src/partition_helpers.rs | 4 +-
core/server/src/partition_reconciler.rs | 398 +++++++++-------
core/server/src/pat.rs | 4 +-
core/server/src/personal_access_token_cleaner.rs | 2 +-
core/server/src/responses.rs | 40 +-
core/server/src/segment_cleaner.rs | 2 +-
core/server/src/server_error.rs | 2 +-
.../src/lib.rs => server/src/shard_allocator.rs} | 51 +--
core/server/src/shell.rs | 202 ++++++++
core/server/src/users.rs | 4 +-
core/server/src/wire.rs | 12 +-
core/server/tests/module_graph.rs | 319 +++++++++++++
core/shard/src/lib.rs | 508 +++++++++++----------
core/shard/src/metrics.rs | 35 +-
core/shard/src/router.rs | 109 ++++-
core/shard_allocator/Cargo.toml | 41 --
core/shard_allocator/build.rs | 43 --
core/simulator/src/lib.rs | 271 ++++++++++-
core/simulator/src/replica.rs | 3 +-
42 files changed, 2077 insertions(+), 999 deletions(-)
create mode 100644 core/integration/tests/cluster/parked_frame_redispatch.rs
delete mode 100644 core/partitions/src/send_messages2.rs
rename core/server/src/{ => http}/web.rs (100%)
rename core/{shard_allocator/src/lib.rs => server/src/shard_allocator.rs} (93%)
create mode 100644 core/server/src/shell.rs
create mode 100644 core/server/tests/module_graph.rs
delete mode 100644 core/shard_allocator/Cargo.toml
delete mode 100644 core/shard_allocator/build.rs
(iggy) 01/01: Merge branch 'master' into fix/iceberg-partition-routing
Posted by hg...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a commit to branch fix/iceberg-partition-routing
in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 1a1cce68962deda4b0570b8decb5f70b1cb88918
Merge: 7ad501923 3aed9f458
Author: Hubert Gruszecki <h....@gmail.com>
AuthorDate: Tue Sep 1 16:17:33 2026 +0200
Merge branch 'master' into fix/iceberg-partition-routing
Cargo.lock | 16 +-
Cargo.toml | 2 -
bdd/docker-compose.cluster.yml | 6 +
core/integration/src/harness/handle/server.rs | 49 +-
core/integration/tests/cluster/mod.rs | 1 +
.../tests/cluster/parked_frame_redispatch.rs | 363 +++++++++++++++
core/partitions/src/send_messages2.rs | 17 -
core/server/Cargo.toml | 7 +-
core/server/build.rs | 23 +
core/server/src/auth.rs | 14 +-
core/server/src/bootstrap.rs | 187 +-------
core/server/src/consumer_group.rs | 6 +-
core/server/src/dispatch.rs | 58 ++-
core/server/src/dispatch/authz.rs | 2 +-
core/server/src/http.rs | 8 +-
core/server/src/http/forward.rs | 19 +-
core/server/src/http/handlers.rs | 67 +++
core/server/src/http/metrics.rs | 101 +---
core/server/src/http/reads.rs | 2 +-
core/server/src/http/state.rs | 23 +-
core/server/src/http/submit.rs | 2 +-
core/server/src/{ => http}/web.rs | 0
core/server/src/lib.rs | 53 ++-
core/server/src/partition_helpers.rs | 4 +-
core/server/src/partition_reconciler.rs | 398 +++++++++-------
core/server/src/pat.rs | 4 +-
core/server/src/personal_access_token_cleaner.rs | 2 +-
core/server/src/responses.rs | 40 +-
core/server/src/segment_cleaner.rs | 2 +-
core/server/src/server_error.rs | 2 +-
.../src/lib.rs => server/src/shard_allocator.rs} | 51 +--
core/server/src/shell.rs | 202 ++++++++
core/server/src/users.rs | 4 +-
core/server/src/wire.rs | 12 +-
core/server/tests/module_graph.rs | 319 +++++++++++++
core/shard/src/lib.rs | 508 +++++++++++----------
core/shard/src/metrics.rs | 35 +-
core/shard/src/router.rs | 109 ++++-
core/shard_allocator/Cargo.toml | 41 --
core/shard_allocator/build.rs | 43 --
core/simulator/src/lib.rs | 271 ++++++++++-
core/simulator/src/replica.rs | 3 +-
42 files changed, 2077 insertions(+), 999 deletions(-)