fix timestamp type

apache · Mar 15, 2024 · d146085 · d146085
1 parent 0942b04
commit d146085
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...is/src/main/java/com/datastrato/gravitino/catalog/doris/converter/DorisTypeConverter.java b/...is/src/main/java/com/datastrato/gravitino/catalog/doris/converter/DorisTypeConverter.java
@@ -45,7 +45,7 @@ public Type toGravitinoType(JdbcTypeBean typeBean) {
       case DATE:
         return Types.DateType.get();
       case DATETIME:
-        return Types.TimeType.get();
+        return Types.TimestampType.withTimeZone();
       case CHAR:
         return Types.FixedCharType.of(Integer.parseInt(typeBean.getColumnSize()));
       case VARCHAR:
@@ -83,7 +83,7 @@ public String fromGravitinoType(Type type) {
           + ")";
     } else if (type instanceof Types.DateType) {
       return DATE;
-    } else if (type instanceof Types.TimeType) {
+    } else if (type instanceof Types.TimestampType) {
       return DATETIME;
     } else if (type instanceof Types.VarCharType) {
       return VARCHAR + "(" + ((Types.VarCharType) type).length() + ")";

diff --git a/...c/main/java/com/datastrato/gravitino/catalog/doris/operation/DorisDatabaseOperations.java b/...c/main/java/com/datastrato/gravitino/catalog/doris/operation/DorisDatabaseOperations.java
@@ -28,7 +28,7 @@ public String generateCreateDatabaseSql(
       String databaseName, String comment, Map<String, String> properties) {
     if (StringUtils.isNotEmpty(comment)) {
       LOG.warn(
-          "Ignoring comment option on database create. doris does not support comment option on database create.");
+          "Ignoring comment option on database create. Doris does not support comment option on database create.");
     }
     StringBuilder sqlBuilder = new StringBuilder("CREATE DATABASE ");