This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
from 5c932f132 [docs] Use the "docker compose ps" to show the running
containers (#2229)
add 6868157aa [server] Introduce new rebalance API (#1380)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/fluss/client/admin/Admin.java | 98 +++++++++++++
.../org/apache/fluss/client/admin/FlussAdmin.java | 29 ++++
.../PendingFetch.java => admin/RebalancePlan.java} | 22 ++-
.../fluss/client/admin/RebalanceProgress.java | 65 +++++++++
.../apache/fluss/cluster/rebalance/GoalType.java | 60 ++++++++
.../cluster/rebalance/RebalancePlanForBucket.java | 112 ++++++++++++++
.../rebalance/RebalanceResultForBucket.java | 73 ++++++++++
.../rebalance/RebalanceStatus.java} | 31 ++--
.../apache/fluss/cluster/rebalance/ServerTag.java | 58 ++++++++
...on.java => NoRebalanceInProgressException.java} | 9 +-
...ception.java => RebalanceFailureException.java} | 15 +-
...Exception.java => ServerNotExistException.java} | 9 +-
...on.java => ServerTagAlreadyExistException.java} | 9 +-
...eption.java => ServerTagNotExistException.java} | 8 +-
.../TabletServerNotAvailableException.java | 2 +-
.../org/apache/fluss/rpc/gateway/AdminGateway.java | 26 ++++
.../org/apache/fluss/rpc/protocol/ApiKeys.java | 7 +-
.../java/org/apache/fluss/rpc/protocol/Errors.java | 14 +-
fluss-rpc/src/main/proto/FlussApi.proto | 64 +++++++-
.../server/coordinator/CoordinatorService.java | 38 +++++
.../apache/fluss/server/zk/ZooKeeperClient.java | 44 ++++++
.../apache/fluss/server/zk/data/RebalancePlan.java | 117 +++++++++++++++
.../server/zk/data/RebalancePlanJsonSerde.java | 161 +++++++++++++++++++++
.../{BucketAssignment.java => ServerTags.java} | 41 +++---
...nfigJsonSerde.java => ServerTagsJsonSerde.java} | 44 +++---
.../org/apache/fluss/server/zk/data/ZkData.java | 42 ++++++
.../server/coordinator/TestCoordinatorGateway.java | 38 +++++
.../fluss/server/zk/ZooKeeperClientTest.java | 83 +++++++++++
.../server/zk/data/RebalancePlanJsonSerdeTest.java | 99 +++++++++++++
...SerdeTest.java => ServerTagsJsonSerdeTest.java} | 31 ++--
30 files changed, 1337 insertions(+), 112 deletions(-)
copy
fluss-client/src/main/java/org/apache/fluss/client/{table/scanner/log/PendingFetch.java
=> admin/RebalancePlan.java} (61%)
create mode 100644
fluss-client/src/main/java/org/apache/fluss/client/admin/RebalanceProgress.java
create mode 100644
fluss-common/src/main/java/org/apache/fluss/cluster/rebalance/GoalType.java
create mode 100644
fluss-common/src/main/java/org/apache/fluss/cluster/rebalance/RebalancePlanForBucket.java
create mode 100644
fluss-common/src/main/java/org/apache/fluss/cluster/rebalance/RebalanceResultForBucket.java
copy
fluss-common/src/main/java/org/apache/fluss/{exception/InvalidMetadataException.java
=> cluster/rebalance/RebalanceStatus.java} (62%)
create mode 100644
fluss-common/src/main/java/org/apache/fluss/cluster/rebalance/ServerTag.java
copy
fluss-common/src/main/java/org/apache/fluss/exception/{KvSnapshotNotExistException.java
=> NoRebalanceInProgressException.java} (81%)
copy
fluss-common/src/main/java/org/apache/fluss/exception/{SecurityTokenException.java
=> RebalanceFailureException.java} (75%)
copy
fluss-common/src/main/java/org/apache/fluss/exception/{InvalidConfigException.java
=> ServerNotExistException.java} (84%)
copy
fluss-common/src/main/java/org/apache/fluss/exception/{KvSnapshotNotExistException.java
=> ServerTagAlreadyExistException.java} (81%)
copy
fluss-common/src/main/java/org/apache/fluss/exception/{KvSnapshotNotExistException.java
=> ServerTagNotExistException.java} (82%)
create mode 100644
fluss-server/src/main/java/org/apache/fluss/server/zk/data/RebalancePlan.java
create mode 100644
fluss-server/src/main/java/org/apache/fluss/server/zk/data/RebalancePlanJsonSerde.java
copy
fluss-server/src/main/java/org/apache/fluss/server/zk/data/{BucketAssignment.java
=> ServerTags.java} (59%)
copy
fluss-server/src/main/java/org/apache/fluss/server/zk/data/{ConfigJsonSerde.java
=> ServerTagsJsonSerde.java} (54%)
create mode 100644
fluss-server/src/test/java/org/apache/fluss/server/zk/data/RebalancePlanJsonSerdeTest.java
copy
fluss-server/src/test/java/org/apache/fluss/server/zk/data/{ConfigJsonSerdeTest.java
=> ServerTagsJsonSerdeTest.java} (59%)
