fix bug 30520

simenliuxing · simenliuxing · commit 633e83a106ca · 2020-09-17T14:59:35.000+08:00
diff --git a/hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/table/HbaseSinkParser.java b/hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/table/HbaseSinkParser.java
@@ -129,7 +129,7 @@ public void parseFieldsInfo(String fieldsInfo, HbaseTableInfo tableInfo){
     }
 
     private Map<String, String> parseColumnFamily(Map<String, String> physicalFieldMap){
-        Map<String, String> columnFamiles = Maps.newHashMap();
+        Map<String, String> columnFamiles = Maps.newLinkedHashMap();
         physicalFieldMap.values().forEach(x -> {
             String[] columnFamily = StringUtils.split(x.trim(), ":");
             columnFamiles.put(x, columnFamily[1]);

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,7 @@ public void parseFieldsInfo(String fieldsInfo, HbaseTableInfo tableInfo){`
`129`	`129`	`}`
`130`	`130`
`131`	`131`	`private Map<String, String> parseColumnFamily(Map<String, String> physicalFieldMap){`
`132`		`- Map<String, String> columnFamiles = Maps.newHashMap();`
	`132`	`+ Map<String, String> columnFamiles = Maps.newLinkedHashMap();`
`133`	`133`	`physicalFieldMap.values().forEach(x -> {`
`134`	`134`	`String[] columnFamily = StringUtils.split(x.trim(), ":");`
`135`	`135`	`columnFamiles.put(x, columnFamily[1]);`