From 66372bfb2c126d3fe5a06f8c9f1e379a708caac4 Mon Sep 17 00:00:00 2001 From: BePPPower Date: Thu, 4 Jul 2024 11:30:10 +0800 Subject: [PATCH] fix --- .../doris/trinoconnector/TrinoConnectorColumnValue.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/fe/be-java-extensions/trino-connector-scanner/src/main/java/org/apache/doris/trinoconnector/TrinoConnectorColumnValue.java b/fe/be-java-extensions/trino-connector-scanner/src/main/java/org/apache/doris/trinoconnector/TrinoConnectorColumnValue.java index c38e14ea55393d..35a2308ea00b0a 100644 --- a/fe/be-java-extensions/trino-connector-scanner/src/main/java/org/apache/doris/trinoconnector/TrinoConnectorColumnValue.java +++ b/fe/be-java-extensions/trino-connector-scanner/src/main/java/org/apache/doris/trinoconnector/TrinoConnectorColumnValue.java @@ -36,7 +36,6 @@ import io.trino.spi.type.SqlTimestampWithTimeZone; import io.trino.spi.type.TimeType; import io.trino.spi.type.Type; -import io.trino.util.DateTimeUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -44,7 +43,6 @@ import java.math.BigInteger; import java.time.LocalDate; import java.time.LocalDateTime; -import java.time.format.DateTimeFormatter; import java.util.List; public class TrinoConnectorColumnValue implements ColumnValue { @@ -155,7 +153,7 @@ public byte[] getStringAsBytes() { // block is IntArrayBlock @Override public LocalDate getDate() { - return LocalDate.parse(DateTimeUtils.printDate(block.getInt(position, 0)), DateTimeFormatter.ISO_DATE); + return LocalDate.ofEpochDay(block.getInt(position, 0)); } // block is LongArrayBlock