You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by fa...@apache.org on 2022/10/11 03:53:47 UTC

[incubator-seatunnel] branch dev updated: [Bug] [sqlserver] timestamp convert exception (#3024)

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 99ac1a655 [Bug] [sqlserver] timestamp convert exception (#3024)
99ac1a655 is described below

commit 99ac1a655e0721518d50b450a451000fb97a2795
Author: chenhongyu <27...@qq.com>
AuthorDate: Tue Oct 11 11:53:41 2022 +0800

    [Bug] [sqlserver] timestamp convert exception (#3024)
    
    Co-authored-by: chenhongyu05 <ch...@corp.netease.com>
    Co-authored-by: Hisoka <fa...@qq.com>
---
 .../seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java
index d7a11563f..d77677747 100644
--- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java
+++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlserverTypeMapper.java
@@ -111,10 +111,10 @@ public class SqlserverTypeMapper implements JdbcDialectTypeMapper {
                 return LocalTimeType.LOCAL_TIME_TYPE;
             case SQLSERVER_DATETIME:
             case SQLSERVER_DATETIME2:
-            case SQLSERVER_TIMESTAMP:
             case SQLSERVER_SMALLDATETIME:
             case SQLSERVER_DATETIMEOFFSET:
                 return LocalTimeType.LOCAL_DATE_TIME_TYPE;
+            case SQLSERVER_TIMESTAMP:
             case SQLSERVER_BINARY:
             case SQLSERVER_VARBINARY:
             case SQLSERVER_IMAGE: