Refactor CALL procedure "sys.xxx_cluster_config" to support multiple conifg keys

sd4324530 · sd4324530 · commit 5148940c09ab · 2026-01-05T22:03:48.000+08:00
Signed-off-by: Pei Yu &lt;125331682@qq.com&gt;
diff --git a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/GetClusterConfigsProcedure.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/GetClusterConfigsProcedure.java
@@ -109,8 +109,6 @@ private Row[] getConfigs(@Nullable String... configKeys) throws Exception {
                                         entry.source() != null
                                                 ? entry.source().name()
                                                 : "UNKNOWN"));
-                    } else {
-                        results.add(Row.of());
                     }
                 }
             }

Original file line number	Diff line number	Diff line change
`@@ -109,8 +109,6 @@ private Row[] getConfigs(@Nullable String... configKeys) throws Exception {`
`109`	`109`	`entry.source() != null`
`110`	`110`	`? entry.source().name()`
`111`	`111`	`: "UNKNOWN"));`
`112`		`- } else {`
`113`		`- results.add(Row.of());`
`114`	`112`	`}`
`115`	`113`	`}`
`116`	`114`	`}`