apache / fluss

Code / Commits / c1f7a11
Change the ListRebalanceProcessProcedure result from String[] to row[] (#2341)
Signed-off-by: Pei Yu <125331682@qq.com>
Pei Yu Pei Yu committed on Jan 16, 2026, 03:07 AM
Showing 5 changed files +210 additions -50 deletions
M fluss-common/src/main/java/org/apache/fluss/cluster/rebalance/RebalanceProgress.java +10
A fluss-common/src/main/java/org/apache/fluss/cluster/rebalance/RebalanceProgressJsonSerializer.java +95
A fluss-common/src/test/java/org/apache/fluss/cluster/rebalance/RebalanceProgressJsonSerializerTest.java +76
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/ListRebalanceProcessProcedure.java +21 -39
M fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/procedure/FlinkProcedureITCase.java +8 -11
Browse files at this commit →