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

Co-authored-by: linchen <linchen@dtstack.com> (cherry picked from commit 703f79c)
DTStack · Mar 3, 2023 · d863ff6 · d863ff6
1 parent 1198c92
commit d863ff6
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) -> {