Skip to content

Commit 417b1a7

Browse files
WTZ468071157WTZ468071157
authored andcommitted
add log
1 parent fa77a64 commit 417b1a7

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

launcher/src/main/java/com/dtstack/flink/sql/launcher/ClusterClientFactory.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,11 @@ public static ClusterClient createClusterClient(Options launcherOptions) throws
7070
public static ClusterClient createStandaloneClient(Options launcherOptions) throws Exception {
7171
String flinkConfDir = launcherOptions.getFlinkconf();
7272
Configuration config = GlobalConfiguration.loadConfiguration(flinkConfDir);
73+
74+
LOG.info("------------config params-------------------------");
75+
config.toMap().forEach((key, value) -> LOG.info("{}: {}", key, value));
76+
LOG.info("-------------------------------------------");
77+
7378
RestClusterClient clusterClient = new RestClusterClient<>(config, "clusterClient");
7479
LeaderConnectionInfo connectionInfo = clusterClient.getClusterConnectionInfo();
7580
InetSocketAddress address = AkkaUtils.getInetSocketAddressFromAkkaURL(connectionInfo.getAddress());

0 commit comments

Comments
 (0)