kudu code scan

Author: todd5167

kudu/kudu-side/kudu-all-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAllReqRow.java

@@ -227,9 +227,6 @@ private KuduScanner getConn(KuduSideTableInfo tableInfo) {
                 if (null != workerCount) {
                     kuduClientBuilder.workerCount(workerCount);
                 }
-                if (null != defaultSocketReadTimeoutMs) {
-                    kuduClientBuilder.defaultSocketReadTimeoutMs(defaultSocketReadTimeoutMs);
-                }
 
                 if (null != defaultOperationTimeoutMs) {
                     kuduClientBuilder.defaultOperationTimeoutMs(defaultOperationTimeoutMs);

kudu/kudu-side/kudu-async-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAsyncReqRow.java

@@ -82,9 +82,6 @@ private void connKuDu() throws KuduException {
             if (null != workerCount) {
                 asyncKuduClientBuilder.workerCount(workerCount);
             }
-            if (null != defaultSocketReadTimeoutMs) {
-                asyncKuduClientBuilder.defaultSocketReadTimeoutMs(defaultSocketReadTimeoutMs);
-            }
 
             if (null != defaultOperationTimeoutMs) {
                 asyncKuduClientBuilder.defaultOperationTimeoutMs(defaultOperationTimeoutMs);

kudu/kudu-side/kudu-side-core/src/main/java/com/dtstack/flink/sql/side/kudu/table/KuduSideParser.java

@@ -107,6 +107,7 @@ public Class dbTypeConvertToJavaType(String fieldType) {
                 return BigDecimal.class;
             case "binary":
                 return byte[].class;
+            default:
         }
 
         throw new RuntimeException("不支持 " + fieldType + " 类型");

kudu/kudu-side/kudu-side-core/src/main/java/com/dtstack/flink/sql/side/kudu/utils/KuduUtil.java

@@ -190,6 +190,7 @@ public static KuduPredicate buildKuduPredicate(Schema schema, PredicateInfo info
                 return KuduPredicate.newIsNotNullPredicate(column);
             case "IS NULL":
                 return KuduPredicate.newIsNullPredicate(column);
+            default:
         }
         return null;
 

kudu/kudu-sink/src/main/java/com/dtstack/flink/sql/sink/kudu/table/KuduSinkParser.java

@@ -86,6 +86,7 @@ public Class dbTypeConvertToJavaType(String fieldType) {
                 return BigDecimal.class;
             case "binary":
                 return byte[].class;
+            default:
         }
 
         throw new RuntimeException("不支持 " + fieldType + " 类型");