Skip to content

Commit 979cb11

Browse files
committed
Refactor CALL procedure "sys.xxx_cluster_config" to support multiple conifg keys
Signed-off-by: Pei Yu <[email protected]>
1 parent aef3258 commit 979cb11

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/GetClusterConfigsProcedure.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,8 @@ private Row[] getConfigs(@Nullable String... configKeys) throws Exception {
109109
entry.source() != null
110110
? entry.source().name()
111111
: "UNKNOWN"));
112+
} else {
113+
results.add(Row.of());
112114
}
113115
}
114116
}

0 commit comments

Comments
 (0)