Skip to content

Commit 40fb964

Browse files
WTZ468071157WTZ468071157
authored andcommitted
fix
1 parent 417b1a7 commit 40fb964

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,6 @@ public static ClusterClient createYarnSessionClient(Options launcherOptions) {
126126
config.toMap().forEach((key, value) -> LOG.info("{}: {}", key, value));
127127
LOG.info("-------------------------------------------");
128128

129-
130129
AbstractYarnClusterDescriptor clusterDescriptor = new YarnClusterDescriptor(config, yarnConf, flinkConfDir, yarnClient, false);
131130
ClusterClient clusterClient = clusterDescriptor.retrieve(applicationId);
132131
clusterClient.setDetached(true);

0 commit comments

Comments
 (0)