This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch dependabot/cargo/fluss-rust/clap-4.6.1
in repository https://gitbox.apache.org/repos/asf/fluss.git
omit 75f355896 chore: bump clap from 4.6.0 to 4.6.1 in /fluss-rust
add 6ecf55cd9 [rust/elixir] Align rustler version to 0.38.0 in mix.exs and
mix.lock (#3587)
add dfa33de7c [docs] Reorganize Streaming Lakehouse documentation to
higlight deployment and core features (#2699)
add dbdef8e70 [common] Limit default max bucket count to 20000
add cf180274c [server] Apply ZooKeeper max buffer size without config path
add 27bdac4b6 [test] Raise disk write-limit ratio in FlussClusterExtension
to avoid test flakiness (#3594)
add ceb2f6525 [ci] Fix stale elixir NIF cache; run client suites on
workflow change (#3598)
add 20b008ce5 [server] Limit max bucket num per table partition (#3597)
add 9f0284ddc [docs] Add rust/python/c++/elixir component tags (#3602)
add bfaaffb85 [fs] Support AWS S3 credentials provider mode
add c5a0c00a2 [docs] Document S3 custom AWS credentials provider mode
add 6320400ff [server] Reject KV leader promotion under disk write lock
(#3539)
add d1591a326 chore: bump arrow stack to 59 (#3600)
add daded0dac chore: bump clap from 4.6.0 to 4.6.1 in /fluss-rust
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (75f355896)
\
N -- N -- N refs/heads/dependabot/cargo/fluss-rust/clap-4.6.1
(daded0dac)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 2 +-
.github/workflows/client-integration.yml | 12 +-
AGENTS.md | 2 +-
.../java/org/apache/fluss/client/admin/Admin.java | 2 +-
.../fluss/client/admin/FlussAdminITCase.java | 117 +++++++--
.../org/apache/fluss/config/ConfigOptions.java | 20 +-
.../fluss/exception/TooManyBucketsException.java | 3 +-
.../java/org/apache/fluss/fs/s3/S3FileSystem.java | 4 +-
.../org/apache/fluss/fs/s3/S3FileSystemPlugin.java | 59 ++++-
.../fs/s3/token/S3DelegationTokenProvider.java | 72 +++++-
.../apache/fluss/fs/s3/S3FileSystemPluginTest.java | 68 ++++++
.../fs/s3/token/S3DelegationTokenProviderTest.java | 177 +++++++++++++-
fluss-rust/Cargo.lock | 129 +++++-----
fluss-rust/Cargo.toml | 2 +-
fluss-rust/bindings/elixir/mix.exs | 2 +-
fluss-rust/bindings/elixir/mix.lock | 2 +-
fluss-rust/bindings/python/Cargo.toml | 10 +-
fluss-rust/bindings/python/src/config.rs | 2 +-
fluss-rust/bindings/python/src/error.rs | 2 +-
fluss-rust/bindings/python/src/lib.rs | 2 +-
fluss-rust/bindings/python/src/metadata.rs | 14 +-
fluss-rust/bindings/python/src/table.rs | 38 +--
fluss-rust/crates/fluss/Cargo.toml | 2 +-
.../server/coordinator/AutoPartitionManager.java | 4 +-
.../server/coordinator/CoordinatorContext.java | 34 +++
.../coordinator/CoordinatorEventProcessor.java | 109 +++++++++
.../server/coordinator/CoordinatorServer.java | 22 ++
.../coordinator/LakeTableTieringManager.java | 2 +
.../fluss/server/coordinator/MetadataManager.java | 27 +--
.../coordinator/TableLifecycleThrottler.java | 2 +
...readEvent.java => RetryOfflineLeaderEvent.java} | 4 +-
.../coordinator/lease/KvSnapshotLeaseManager.java | 3 +
.../producer/ProducerOffsetsManager.java | 2 +
.../coordinator/rebalance/RebalanceManager.java | 2 +
.../fluss/server/replica/ReplicaManager.java | 17 +-
.../server/utils/TableDescriptorValidation.java | 2 +-
.../org/apache/fluss/server/zk/ZooKeeperUtils.java | 2 +-
.../coordinator/AutoPartitionManagerTest.java | 15 +-
.../server/coordinator/CoordinatorContextTest.java | 44 ++++
.../coordinator/CoordinatorEventProcessorTest.java | 270 ++++++++++++++++++++-
.../rebalance/RebalanceManagerTest.java | 10 +
.../statemachine/TableBucketStateMachineTest.java | 15 ++
.../fluss/server/replica/ReplicaManagerTest.java | 58 +++++
.../server/testutils/FlussClusterExtension.java | 2 +
.../fluss/server/zk/ZooKeeperClientTest.java | 20 ++
website/build_versioned_docs.sh | 8 +
.../bug-reports-feature-requests.md | 2 +-
.../community/how-to-contribute/contribute-code.md | 2 +-
website/docs/engine-flink/getting-started.md | 4 +-
.../deploying-streaming-lakehouse.md | 250 +++++++++++++++++++
website/docs/install-deploy/overview.md | 12 +-
website/docs/maintenance/configuration.md | 15 +-
website/docs/maintenance/operations/upgrading.md | 4 +-
.../maintenance/tiered-storage/_category_.json | 2 +-
.../filesystems/_category_.json | 2 +-
.../{ => tiered-storage}/filesystems/azure.md | 0
.../{ => tiered-storage}/filesystems/cos.md | 0
.../{ => tiered-storage}/filesystems/gs.md | 0
.../{ => tiered-storage}/filesystems/hdfs.md | 0
.../{ => tiered-storage}/filesystems/obs.md | 0
.../{ => tiered-storage}/filesystems/oss.md | 0
.../{ => tiered-storage}/filesystems/overview.md | 0
.../{ => tiered-storage}/filesystems/s3.md | 22 ++
.../tiered-storage/lakehouse-storage.md | 137 ++++-------
.../maintenance/tiered-storage/remote-storage.md | 2 +-
website/docs/quickstart/flink.md | 4 +-
website/docs/quickstart/lakehouse.md | 4 +-
.../datalake-catalogs/_category_.json | 4 +
.../catalogs => datalake-catalogs}/lakekeeper.md | 14 +-
.../catalogs => datalake-catalogs}/polaris.md | 12 +-
.../datalake-formats/_category_.json | 4 +
.../formats => datalake-formats}/iceberg.md | 64 +++--
.../formats => datalake-formats}/lance.md | 17 +-
.../formats => datalake-formats}/paimon.md | 12 +-
.../integrate-data-lakes/_category_.json | 4 -
.../integrate-data-lakes/catalogs/_category_.json | 4 -
.../integrate-data-lakes/formats/_category_.json | 4 -
website/docs/streaming-lakehouse/overview.md | 13 +-
.../docs/streaming-lakehouse/tiering-service.md | 102 ++++++++
website/docs/streaming-lakehouse/union-read.md | 113 +++++++++
.../table-design/data-distribution/partitioning.md | 2 +-
website/docs/table-design/table-types/log-table.md | 2 +-
website/docusaurus.config.ts | 31 ++-
83 files changed, 1886 insertions(+), 395 deletions(-)
copy
fluss-server/src/main/java/org/apache/fluss/server/coordinator/event/{ShutdownEventThreadEvent.java
=> RetryOfflineLeaderEvent.java} (86%)
create mode 100644 website/docs/install-deploy/deploying-streaming-lakehouse.md
rename website/docs/maintenance/{ =>
tiered-storage}/filesystems/_category_.json (65%)
rename website/docs/maintenance/{ => tiered-storage}/filesystems/azure.md
(100%)
rename website/docs/maintenance/{ => tiered-storage}/filesystems/cos.md (100%)
rename website/docs/maintenance/{ => tiered-storage}/filesystems/gs.md (100%)
rename website/docs/maintenance/{ => tiered-storage}/filesystems/hdfs.md (100%)
rename website/docs/maintenance/{ => tiered-storage}/filesystems/obs.md (100%)
rename website/docs/maintenance/{ => tiered-storage}/filesystems/oss.md (100%)
rename website/docs/maintenance/{ => tiered-storage}/filesystems/overview.md
(100%)
rename website/docs/maintenance/{ => tiered-storage}/filesystems/s3.md (75%)
create mode 100644
website/docs/streaming-lakehouse/datalake-catalogs/_category_.json
rename website/docs/streaming-lakehouse/{integrate-data-lakes/catalogs =>
datalake-catalogs}/lakekeeper.md (85%)
rename website/docs/streaming-lakehouse/{integrate-data-lakes/catalogs =>
datalake-catalogs}/polaris.md (90%)
create mode 100644
website/docs/streaming-lakehouse/datalake-formats/_category_.json
rename website/docs/streaming-lakehouse/{integrate-data-lakes/formats =>
datalake-formats}/iceberg.md (88%)
rename website/docs/streaming-lakehouse/{integrate-data-lakes/formats =>
datalake-formats}/lance.md (89%)
rename website/docs/streaming-lakehouse/{integrate-data-lakes/formats =>
datalake-formats}/paimon.md (95%)
delete mode 100644
website/docs/streaming-lakehouse/integrate-data-lakes/_category_.json
delete mode 100644
website/docs/streaming-lakehouse/integrate-data-lakes/catalogs/_category_.json
delete mode 100644
website/docs/streaming-lakehouse/integrate-data-lakes/formats/_category_.json
create mode 100644 website/docs/streaming-lakehouse/tiering-service.md
create mode 100644 website/docs/streaming-lakehouse/union-read.md