add comment with learn.

Author: WTZ468071157

flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java

@@ -169,6 +169,7 @@ public Options getCustomCommandLineOptions() {
     protected void runApplication(String[] args) throws Exception {
         LOG.info("Running 'run-application' command.");
 
+        // 获取 run 动作默认的配置项
         final Options commandOptions = CliFrontendParser.getRunCommandOptions();
         final CommandLine commandLine = getCommandLine(commandOptions, args, true);
 
@@ -1145,6 +1146,7 @@ public static void main(final String[] args) {
     // --------------------------------------------------------------------------------------------
 
     public static String getConfigurationDirectoryFromEnv() {
+        // 从环境变量（config.sh）里获取参数路径
         String location = System.getenv(ConfigConstants.ENV_FLINK_CONF_DIR);
 
         if (location != null) {

flink-demo/src/main/java/com/wtz/demo/data/DataEntity.java

@@ -22,12 +22,8 @@ public class DataEntity {
 
     private Boolean sex;
 
-    public DataEntity(Integer id,
-                      String name,
-                      Timestamp birth,
-                      Time todayTime,
-                      Date todayDate,
-                      Boolean sex) {
+    public DataEntity(
+            Integer id, String name, Timestamp birth, Time todayTime, Date todayDate, Boolean sex) {
         this.id = id;
         this.name = name;
         this.birth = birth;

flink-demo/src/main/java/com/wtz/demo/table/TableDemoOne.java

@@ -1,11 +1,12 @@
 package com.wtz.demo.table;
 
-import com.wtz.demo.KafkaCore;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.apache.flink.table.api.EnvironmentSettings;
 import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
 
+import com.wtz.demo.KafkaCore;
+
 public class TableDemoOne {
     public static void main(String[] args) throws Exception {
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
@@ -16,9 +17,7 @@ public static void main(String[] args) throws Exception {
 
         DataStream<String> source =
                 KafkaCore.addKafkaSource(
-                        env,
-                        KafkaCore.buildKafkaConsumerProperties("kudu1:9092"),
-                        "tiezhu_in_one");
+                        env, KafkaCore.buildKafkaConsumerProperties("kudu1:9092"), "tiezhu_in_one");
 
         tableEnvironment.executeSql(
                 "CREATE TABLE printTable ("