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 1055e42c4 [flink] Add RuntimeContext adapter for Flink 2.x
compatibility (#2241)
add 07aa237da [server] Support AddServerTag and RemoveServerTag (#1400)
No new revisions were added by this update.
Summary of changes:
.../org/apache/fluss/client/admin/FlussAdmin.java | 10 +-
.../fluss/client/admin/FlussAdminITCase.java | 78 +++++++++++++
.../flink/procedure/AddServerTagProcedure.java | 47 ++++++++
.../fluss/flink/procedure/ProcedureManager.java | 4 +-
.../flink/procedure/RemoveServerTagProcedure.java | 77 +++++++++++++
.../flink/procedure/FlinkProcedureITCase.java | 121 ++++++++++++++++----
.../server/coordinator/CoordinatorContext.java | 25 +++++
.../coordinator/CoordinatorEventProcessor.java | 123 +++++++++++++++++++++
.../server/coordinator/CoordinatorService.java | 28 ++++-
...srReceivedEvent.java => AddServerTagEvent.java} | 36 +++---
...hutdownEvent.java => RemoveServerTagEvent.java} | 38 ++++---
.../apache/fluss/server/zk/ZooKeeperClient.java | 4 +
12 files changed, 533 insertions(+), 58 deletions(-)
create mode 100644
fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/AddServerTagProcedure.java
create mode 100644
fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/RemoveServerTagProcedure.java
copy
fluss-server/src/main/java/org/apache/fluss/server/coordinator/event/{AdjustIsrReceivedEvent.java
=> AddServerTagEvent.java} (54%)
copy
fluss-server/src/main/java/org/apache/fluss/server/coordinator/event/{ControlledShutdownEvent.java
=> RemoveServerTagEvent.java} (54%)
