We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d3f904d commit bbc22feCopy full SHA for bbc22fe
launcher/src/main/java/com/dtstack/flink/sql/launcher/ClusterClientFactory.java
@@ -26,6 +26,7 @@
26
import org.apache.commons.lang.StringUtils;
27
import org.apache.flink.client.program.ClusterClient;
28
import org.apache.flink.client.program.MiniClusterClient;
29
+import org.apache.flink.configuration.ConfigConstants;
30
import org.apache.flink.configuration.Configuration;
31
import org.apache.flink.configuration.GlobalConfiguration;
32
import org.apache.flink.configuration.JobManagerOptions;
0 commit comments