Skip to content

Commit 73521c2

Browse files
author
xuchao
committed
修改hbase all row req 填充维表数据bug
1 parent 2c1186c commit 73521c2

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • hbase/hbase-side/hbase-all-side/src/main/java/com/dtstack/flink/sql/side/hbase

hbase/hbase-side/hbase-all-side/src/main/java/com/dtstack/flink/sql/side/hbase/HbaseAllReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,10 +112,10 @@ public Row fillData(Row input, Object sideInput) {
112112
row.setField(entry.getKey(), null);
113113
}else{
114114
String key = sideInfo.getSideFieldNameIndex().get(entry.getKey());
115+
key = aliasNameInversion.get(key);
115116
row.setField(entry.getKey(), sideInputList.get(key));
116117
}
117118
}
118-
119119
return row;
120120
}
121121

0 commit comments

Comments
 (0)