保持一致

dapeng · dapeng · commit 37e7e62d5b58 · 2020-05-25T17:56:06.000+08:00
diff --git a/hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseOutputFormat.java b/hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseOutputFormat.java
@@ -298,7 +298,7 @@ public HbaseOutputFormat finish() {
                 String[] columns = keySet.toArray(new String[keySet.size()]);
                 for (int i = 0; i < columns.length; ++i) {
                     String col = columns[i];
-                    String[] part = col.split(":");
+                    String[] part = StringUtils.split(col, ":");;
                     families[i] = part[0];
                     qualifiers[i] = part[1];
                 }

Original file line number	Diff line number	Diff line change
`@@ -298,7 +298,7 @@ public HbaseOutputFormat finish() {`
`298`	`298`	`String[] columns = keySet.toArray(new String[keySet.size()]);`
`299`	`299`	`for (int i = 0; i < columns.length; ++i) {`
`300`	`300`	`String col = columns[i];`
`301`		`- String[] part = col.split(":");`
	`301`	`+ String[] part = StringUtils.split(col, ":");;`
`302`	`302`	`families[i] = part[0];`
`303`	`303`	`qualifiers[i] = part[1];`
`304`	`304`	`}`