parse flinkconfig

Author: todd5167

launcher/src/main/java/com/dtstack/flink/sql/launcher/factory/AbstractClusterClientFactory.java

@@ -41,7 +41,7 @@ public ClusterSpecification getClusterSpecification(Configuration configuration)
         final int jobManagerMemoryMB = ConfigurationUtils
                 .getJobManagerHeapMemory(configuration)
                 .getMebiBytes();
-        // taskmanager.memory.process.size
+
         final int taskManagerMemoryMB = TaskExecutorProcessUtils
                 .processSpecFromConfig(TaskExecutorProcessUtils.getConfigurationMapLegacyTaskManagerHeapSizeToConfigOption(
                         configuration, TaskManagerOptions.TOTAL_PROCESS_MEMORY))

launcher/src/main/java/com/dtstack/flink/sql/launcher/utils/JobGraphBuildUtil.java

@@ -88,8 +88,7 @@ protected static SavepointRestoreSettings dealSavepointRestoreSettings(Propertie
     }
 
     public static Configuration getFlinkConfiguration(String flinkConfDir, Properties confProperties) {
-        Configuration flinkConfig = StringUtils.isEmpty(flinkConfDir) ? new Configuration() :
-                GlobalConfiguration.loadConfiguration();
+        Configuration flinkConfig = StringUtils.isEmpty(flinkConfDir) ? new Configuration() : GlobalConfiguration.loadConfiguration(flinkConfDir);
 
         confProperties.forEach((key, val) -> flinkConfig.setString(key.toString(), val.toString()));
         return flinkConfig;