revert pom

Author: todd5167

launcher/src/main/java/com/dtstack/flink/sql/launcher/executor/StandaloneExecutor.java

@@ -68,8 +68,8 @@ public void exec() throws Exception {
 
 
         JobExecutionResult jobExecutionResult = ClientUtils.submitJob(clusterClient, jobGraph);
-        String jobID = jobExecutionResult.getJobID().toString();
-        System.out.println("jobID:" + jobID);
+        String jobId = jobExecutionResult.getJobID().toString();
+        System.out.println("jobID:" + jobId);
 
     }
 

launcher/src/main/java/com/dtstack/flink/sql/launcher/executor/YarnSessionClusterExecutor.java

@@ -75,8 +75,8 @@ public void exec() throws Exception {
         }
 
         JobExecutionResult jobExecutionResult = ClientUtils.submitJob(clusterClient, jobGraph);
-        String jobID = jobExecutionResult.getJobID().toString();
-        System.out.println("jobID:" + jobID);
+        String jobId = jobExecutionResult.getJobID().toString();
+        System.out.println("jobID:" + jobId);
 
     }
 

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

@@ -38,11 +38,11 @@ public abstract class AbstractClusterClientFactory {
     public ClusterSpecification getClusterSpecification(Configuration configuration) {
         checkNotNull(configuration);
 
-        final int jobManagerMemoryMB = ConfigurationUtils
+        final int jobManagerMemoryMb = ConfigurationUtils
                 .getJobManagerHeapMemory(configuration)
                 .getMebiBytes();
 
-        final int taskManagerMemoryMB = TaskExecutorProcessUtils
+        final int taskManagerMemoryMb = TaskExecutorProcessUtils
                 .processSpecFromConfig(TaskExecutorProcessUtils.getConfigurationMapLegacyTaskManagerHeapSizeToConfigOption(
                         configuration, TaskManagerOptions.TOTAL_PROCESS_MEMORY))
                 .getTotalProcessMemorySize()
@@ -51,12 +51,18 @@ public ClusterSpecification getClusterSpecification(Configuration configuration)
         int slotsPerTaskManager = configuration.getInteger(TaskManagerOptions.NUM_TASK_SLOTS);
 
         return new ClusterSpecification.ClusterSpecificationBuilder()
-                .setMasterMemoryMB(jobManagerMemoryMB)
-                .setTaskManagerMemoryMB(taskManagerMemoryMB)
+                .setMasterMemoryMB(jobManagerMemoryMb)
+                .setTaskManagerMemoryMB(taskManagerMemoryMb)
                 .setSlotsPerTaskManager(slotsPerTaskManager)
                 .createClusterSpecification();
     }
 
-    abstract ClusterDescriptor createClusterDescriptor(String clusterConfPath,Configuration flinkConfig);
+    /**
+     *  create ClusterDescriptor
+     * @param clusterConfPath  cluster configuration path , E.g. yarn conf dir
+     * @param flinkConfig
+     * @return
+     */
+    abstract ClusterDescriptor createClusterDescriptor(String clusterConfPath, Configuration flinkConfig);
 
 }

pom.xml

@@ -10,28 +10,28 @@
     <url>http://maven.apache.org</url>
     <modules>
         <module>core</module>
-        <!--<module>kafka09</module>-->
-        <!--<module>kafka10</module>-->
-        <!--<module>kafka11</module>-->
-        <!--<module>kafka</module>-->
-        <!--<module>mysql</module>-->
-        <!--<module>hbase</module>-->
-        <!--<module>elasticsearch5</module>-->
-        <!--<module>mongo</module>-->
-        <!--<module>redis5</module>-->
+        <module>kafka09</module>
+        <module>kafka10</module>
+        <module>kafka11</module>
+        <module>kafka</module>
+        <module>mysql</module>
+        <module>hbase</module>
+        <module>elasticsearch5</module>
+        <module>mongo</module>
+        <module>redis5</module>
         <module>launcher</module>
-        <!--<module>rdb</module>-->
-        <!--<module>sqlserver</module>-->
-        <!--<module>oracle</module>-->
-        <!--<module>cassandra</module>-->
-        <!--<module>kudu</module>-->
-        <!--<module>postgresql</module>-->
-        <!--<module>serversocket</module>-->
-        <!--<module>console</module>-->
-        <!--<module>clickhouse</module>-->
-        <!--<module>impala</module>-->
-        <!--<module>db2</module>-->
-        <!--<module>polardb</module>-->
+        <module>rdb</module>
+        <module>sqlserver</module>
+        <module>oracle</module>
+        <module>cassandra</module>
+        <module>kudu</module>
+        <module>postgresql</module>
+        <module>serversocket</module>
+        <module>console</module>
+        <module>clickhouse</module>
+        <module>impala</module>
+        <module>db2</module>
+        <module>polardb</module>
 
     </modules>