From c08cbd10d46bf8baf286025ad51d6371745d13e8 Mon Sep 17 00:00:00 2001
From: kyotom <kyotom@163.com>
Date: Tue, 15 Jul 2025 11:35:53 +0800
Subject: [PATCH] [hotfix-#1952][core|doris] Fix ARRAY and LARGEINT type
 conversion exceptions

---
 .../connector/doris/converter/DorisRawTypeMapper.java  |  2 ++
 .../main/java/com/dtstack/chunjun/util/DateUtil.java   | 10 +++++++++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/converter/DorisRawTypeMapper.java b/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/converter/DorisRawTypeMapper.java
index ff6a1e7475..836bcb9801 100644
--- a/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/converter/DorisRawTypeMapper.java
+++ b/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/converter/DorisRawTypeMapper.java
@@ -68,6 +68,8 @@ public static DataType apply(TypeConfig type) {
             case "JSON":
             case "ENUM":
             case "SET":
+            case "LARGEINT":
+            case "ARRAY":
                 return DataTypes.STRING();
             case "DATE":
                 return DataTypes.DATE();
diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/util/DateUtil.java b/chunjun-core/src/main/java/com/dtstack/chunjun/util/DateUtil.java
index f6fbc466b8..688c30f6d0 100644
--- a/chunjun-core/src/main/java/com/dtstack/chunjun/util/DateUtil.java
+++ b/chunjun-core/src/main/java/com/dtstack/chunjun/util/DateUtil.java
@@ -48,6 +48,9 @@ public class DateUtil {
 
     private static final String TIME_ZONE = "GMT+8";
 
+    private static final boolean isUseLocalTimeZone =
+            Boolean.parseBoolean(System.getProperty("USE_LOCAL_TIMEZONE"));
+
     private static final String STANDARD_DATETIME_FORMAT = "standardDatetimeFormatter";
 
     private static final String STANDARD_DATETIME_FORMAT_FOR_MILLISECOND =
@@ -97,7 +100,12 @@ public class DateUtil {
     public static ThreadLocal<Map<String, SimpleDateFormat>> datetimeFormatter =
             ThreadLocal.withInitial(
                     () -> {
-                        TimeZone timeZone = TimeZone.getTimeZone(TIME_ZONE);
+                        TimeZone timeZone;
+                        if (isUseLocalTimeZone) {
+                            timeZone = TimeZone.getDefault();
+                        } else {
+                            timeZone = TimeZone.getTimeZone(TIME_ZONE);
+                        }
 
                         Map<String, SimpleDateFormat> formatterMap = new HashMap<>();
                         SimpleDateFormat standardDatetimeFormatter =