codeview fix

Author: dapeng

console/console-sink/src/main/java/com/dtstack/flink/sql/sink/console/table/TablePrintUtil.java

@@ -58,7 +58,9 @@ public static TablePrintUtil build(String[][] data) {
     public static <T> TablePrintUtil build(List<T> data) {
         TablePrintUtil self = new TablePrintUtil();
         self.data = new ArrayList<>();
-        if (data.size() <= 0) throw new RuntimeException("数据源至少得有一行吧");
+        if (data.size() <= 0) {
+            throw new RuntimeException("数据源至少得有一行吧");
+        }
         Object obj = data.get(0);
 
 
@@ -70,7 +72,9 @@ public static <T> TablePrintUtil build(List<T> data) {
             int length = ((List) obj).size();
             for (Object item : data) {
                 List<String> col = (List<String>) item;
-                if (col.size() != length) throw new RuntimeException("数据源每列长度必须一致");
+                if (col.size() != length) {
+                    throw new RuntimeException("数据源每列长度必须一致");
+                }
                 self.data.add(col.toArray(new String[length]));
             }
         } else {
@@ -163,7 +167,9 @@ private int[] getColLengths() {
         if (equilong) {//如果等宽表格
             int max = 0;
             for (int len : result) {
-                if (len > max) max = len;
+                if (len > max) {
+                    max = len;
+                }
             }
             for (int i = 0; i < result.length; i++) {
                 result[i] = max;

launcher/src/main/java/com/dtstack/flink/sql/launcher/ClusterClientFactory.java

@@ -89,7 +89,7 @@ public static ClusterClient createYarnSessionClient(Options launcherOptions) {
 
         if (StringUtils.isNotBlank(yarnConfDir)) {
             try {
-                config.setString(ConfigConstants.PATH_HADOOP_CONFIG, yarnConfDir);
+                config.setString("fs.hdfs.hadoopconf", yarnConfDir);
                 FileSystem.initialize(config);
 
                 YarnConfiguration yarnConf = YarnConfLoader.getYarnConf(yarnConfDir);
@@ -166,7 +166,7 @@ private static ApplicationId getYarnClusterApplicationId(YarnClient yarnClient)
 
     private static ApplicationId toApplicationId(String appIdStr) {
         Iterator<String> it = StringHelper._split(appIdStr).iterator();
-        if (!(it.next()).equals("application")) {
+        if (!"application".equals(it.next())) {
             throw new IllegalArgumentException("Invalid ApplicationId prefix: " + appIdStr + ". The valid ApplicationId should start with prefix " + "application");
         } else {
             try {