[Bug]Fix flink 1.19 cli bug (#3717)

Co-authored-by: gaoyan1998 <[email protected]>
DataLinkDC · Aug 15, 2024 · 708ebce · 708ebce
1 parent b8c2da8
commit 708ebce
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/dinky-client/dinky-client-1.19/src/main/java/org/dinky/gateway/FlinkSqlClient.java b/dinky-client/dinky-client-1.19/src/main/java/org/dinky/gateway/FlinkSqlClient.java
@@ -116,7 +116,9 @@ public static EmbeddedGateway create(DefaultContext defaultContext) {
             Configuration restConfig = new Configuration();
             // always use localhost
             restConfig.set(SqlGatewayRestOptions.ADDRESS, ADDRESS);
+            restConfig.set(SqlGatewayRestOptions.BIND_ADDRESS, ADDRESS);
             restConfig.set(SqlGatewayRestOptions.PORT, port.getPort());
+            restConfig.set(SqlGatewayRestOptions.BIND_PORT, port.getPort() + "");
             defaultConfig.addAll(
                     restConfig,
                     SqlGatewayEndpointFactoryUtils.getSqlGatewayOptionPrefix(SqlGatewayRestEndpointFactory.IDENTIFIER));