(fluss) 02/19: Fix list rebalance procedure throw ClassCastException (#2637)

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch release-0.9
in repository https://gitbox.apache.org/repos/asf/fluss.git

commit b3d1103b6ad4031cc527b81fdaa2875b467dabce
Author: Pei Yu <125331...@qq.com>
AuthorDate: Wed Feb 11 10:15:44 2026 +0800

    Fix list rebalance procedure throw ClassCastException (#2637)
    
    Signed-off-by: peiyu <125331...@qq.com>
---
 .../org/apache/fluss/flink/procedure/ListRebalanceProcessProcedure.java | 2 +-
 .../java/org/apache/fluss/flink/procedure/FlinkProcedureITCase.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/ListRebalanceProcessProcedure.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/ListRebalanceProcessProcedure.java
index 9ebb227b7..6dd06d6b3 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/ListRebalanceProcessProcedure.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/ListRebalanceProcessProcedure.java
@@ -71,7 +71,7 @@ public class ListRebalanceProcessProcedure extends 
ProcedureBase {
         return new Row[] {
             Row.of(
                     progress.rebalanceId(),
-                    progress.status(),
+                    progress.status().toString(),
                     progress.formatAsPercentage(),
                     new String(
                             JsonSerdeUtils.writeValueAsBytes(
diff --git 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/procedure/FlinkProcedureITCase.java
 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/procedure/FlinkProcedureITCase.java
index 5e22c3ff0..8b2817e32 100644
--- 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/procedure/FlinkProcedureITCase.java
+++ 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/procedure/FlinkProcedureITCase.java
@@ -776,7 +776,7 @@ public abstract class FlinkProcedureITCase {
                         Row row = listProgressResult.get(0);
                         assertThat(row.getArity()).isEqualTo(4);
                         
assertThat(row.getField(0)).isEqualTo(progress.rebalanceId());
-                        
assertThat(row.getField(1)).isEqualTo(RebalanceStatus.COMPLETED);
+                        
assertThat(row.getField(1)).isEqualTo(RebalanceStatus.COMPLETED.toString());
                         assertThat((String) row.getField(2)).endsWith("%");
                         assertThat((String) 
row.getField(3)).startsWith("{\"rebalance_id\":");
                     }