Merge branch '1.8_release_4.0.x' into 1.10_release_4.0.x

gituser · gituser · commit 8d5a53188102 · 2021-04-22T15:59:11.000+08:00
diff --git a/flinkx-kudu/flinkx-kudu-core/src/main/java/com/dtstack/flinkx/kudu/core/KuduUtil.java b/flinkx-kudu/flinkx-kudu-core/src/main/java/com/dtstack/flinkx/kudu/core/KuduUtil.java
@@ -99,7 +99,9 @@ public static List<KuduScanToken> getKuduScanToken(KuduConfig config, List<MetaC
 
             List<String> columnNames = new ArrayList<>(columns.size());
             for (MetaColumn column : columns) {
-                columnNames.add(column.getName());
+               if(column.getValue() == null){
+                   columnNames.add(column.getName());
+               }
             }
 
             KuduScanToken.KuduScanTokenBuilder builder = client.newScanTokenBuilder(kuduTable)

Original file line number	Diff line number	Diff line change
`@@ -99,7 +99,9 @@ public static List<KuduScanToken> getKuduScanToken(KuduConfig config, List<MetaC`
`99`	`99`
`100`	`100`	`List<String> columnNames = new ArrayList<>(columns.size());`
`101`	`101`	`for (MetaColumn column : columns) {`
`102`		`- columnNames.add(column.getName());`
	`102`	`+ if(column.getValue() == null){`
	`103`	`+ columnNames.add(column.getName());`
	`104`	`+ }`
`103`	`105`	`}`
`104`	`106`
`105`	`107`	`KuduScanToken.KuduScanTokenBuilder builder = client.newScanTokenBuilder(kuduTable)`