You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by ja...@apache.org on 2026/09/02 03:08:38 UTC
(fluss) branch main updated (79c71c24a -> e01a94eaf)
This is an automated email from the ASF dual-hosted git repository.
wuchong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
from 79c71c24a [rust] Preserve highest_field_id during Schema JSON deserialization (#4184)
add e01a94eaf [server][rpc] Return ISR and bucket epoch in bucket metadata (#3785)
No new revisions were added by this update.
Summary of changes:
fluss-rpc/src/main/proto/FlussApi.proto | 5 +-
fluss-rust/crates/fluss/proto/FlussApi.proto | 5 +-
fluss-rust/crates/fluss/src/proto/fluss.rs | 7 +-
.../coordinator/CoordinatorRequestBatch.java | 14 +++-
.../fluss/server/metadata/BucketMetadata.java | 44 +++++++++-
.../metadata/CoordinatorMetadataProvider.java | 39 ++++++---
.../fluss/server/utils/ServerRpcMessageUtils.java | 13 ++-
.../apache/fluss/server/zk/ZooKeeperClient.java | 7 +-
.../coordinator/CoordinatorEventProcessorTest.java | 14 +++-
.../fluss/server/metadata/BucketMetadataTest.java | 83 +++++++++++++++++++
.../metadata/CoordinatorMetadataProviderTest.java | 69 ++++++++++++++++
.../server/metadata/MetadataUpdateITCase.java | 10 ++-
.../metadata/ZkBasedMetadataProviderTest.java | 19 ++++-
.../server/utils/ServerRpcMessageUtilsTest.java | 96 ++++++++++++++++++++++
14 files changed, 398 insertions(+), 27 deletions(-)
create mode 100644 fluss-server/src/test/java/org/apache/fluss/server/metadata/BucketMetadataTest.java
create mode 100644 fluss-server/src/test/java/org/apache/fluss/server/metadata/CoordinatorMetadataProviderTest.java