[bugfix][hbase]fix hbase date type (#1406)

Co-authored-by: linchen <linchen@dtstack.com>
DTStack · Nov 20, 2022 · 703f79c · 703f79c
1 parent fd449ca
commit 703f79c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...ase/src/main/java/com/dtstack/chunjun/connector/hbase/converter/HBaseColumnConverter.java b/...ase/src/main/java/com/dtstack/chunjun/connector/hbase/converter/HBaseColumnConverter.java
@@ -430,6 +430,12 @@ protected ISerializationConverter<Mutation> createExternalConverter(LogicalType
                     ((Put) output).addColumn(qualifier[0], qualifier[1], bytes);
                 };
             case DATE:
+                return (rowData, pos, output) -> {
+                    String value = ((ColumnRowData) rowData).getField(pos).asSqlDate().toString();
+                    byte[] bytes = Bytes.toBytes(value);
+                    byte[][] qualifier = familyAndQualifier[pos];
+                    ((Put) output).addColumn(qualifier[0], qualifier[1], bytes);
+                };
             case INTERVAL_YEAR_MONTH:
             case INTEGER:
                 return (rowData, pos, output) -> {