We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e438f54 commit 83429b2Copy full SHA for 83429b2
1 file changed
launcher/src/main/java/com/dtstack/flink/sql/launcher/ClusterClientFactory.java
@@ -25,6 +25,7 @@
25
import org.apache.commons.lang.StringUtils;
26
import org.apache.flink.client.program.ClusterClient;
27
import org.apache.flink.client.program.rest.RestClusterClient;
28
+import org.apache.flink.configuration.ConfigConstants;
29
import org.apache.flink.configuration.Configuration;
30
import org.apache.flink.configuration.GlobalConfiguration;
31
import org.apache.flink.configuration.JobManagerOptions;
@@ -39,6 +40,8 @@
39
40
import org.apache.hadoop.yarn.client.api.YarnClient;
41
import org.apache.hadoop.yarn.conf.YarnConfiguration;
42
import org.apache.hadoop.yarn.util.StringHelper;
43
+import org.slf4j.Logger;
44
+import org.slf4j.LoggerFactory;
45
46
import java.net.InetSocketAddress;
47
import java.net.URLDecoder;
0 commit comments