Skip to content

Commit 4114079

Browse files
committed
Merge branch 'hotfix_1.10_4.0.x_31982' into '1.10_release_4.0.x'
[fix] Hbase维表Timestamp转化异常 See merge request dt-insight-engine/flinkStreamSQL!183
2 parents 6e3fe25 + c01dfc3 commit 4114079

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

hbase/hbase-side/hbase-async-side/src/main/java/com/dtstack/flink/sql/side/hbase/rowkeydealer/AbstractRowKeyModeDealer.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -94,9 +94,6 @@ protected Row fillData(Row input, Object sideInput){
9494
Row row = new Row(outFieldInfoList.size());
9595
for(Map.Entry<Integer, Integer> entry : inFieldIndex.entrySet()){
9696
Object obj = input.getField(entry.getValue());
97-
if(obj instanceof Timestamp){
98-
obj = ((Timestamp)obj).getTime();
99-
}
10097
row.setField(entry.getKey(), obj);
10198
}
10299

0 commit comments

Comments
 (0)