address comment

apache · May 23, 2023 · eba609c · eba609c
1 parent c048f32
commit eba609c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerTypeUtils.java b/...src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerTypeUtils.java
@@ -65,6 +65,9 @@ private static DataType convertFromColumn(Column column) {
                 return DataTypes.DATE();
             case Types.TIMESTAMP:
             case Types.TIMESTAMP_WITH_TIMEZONE:
+                return column.length() >= 0
+                        ? DataTypes.TIMESTAMP(column.length())
+                        : DataTypes.TIMESTAMP();
             case Types.BOOLEAN:
                 return DataTypes.BOOLEAN();
             default:

diff --git a/...dc/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java b/...dc/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java
@@ -46,6 +46,7 @@
 import java.util.stream.Collectors;
 
 /**
+ * Copied from Debezium project(1.6.4.final) to add method {@link SqlServerStreamingChangeEventSource#afterHandleLsn(SqlServerOffsetContext)}.
  * A {@link StreamingChangeEventSource} based on SQL Server change data capture functionality. A
  * main loop polls database DDL change and change data tables and turns them into change events.
  *