alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1688 Misc clean-up

Browse Source
This commit is contained in:
Gunnar Morling 2020-01-02 12:32:03 +01:00
parent 6028d78e76
commit f110c13e2d
3 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
COPYRIGHT.txt
View File

@ -75,6 +75,7 @@ Jork Zijlstra
Josh Arenberg
Josh Stanfield
Joy Gao
Jun Du
Jure Kajzer
Keith Barber
Kevin Pullin

1
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerSnapshotChangeEventSource.java
View File

@ -215,7 +215,6 @@ protected Optional<String> getSnapshotSelect(SnapshotContext snapshotContext, Ta
@Override
protected Object getColumnValue(ResultSet rs, int columnIndex, Column column) throws SQLException {
final ResultSetMetaData metaData = rs.getMetaData();
final int columnType = metaData.getColumnType(columnIndex);

2
debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/AbstractSqlServerDatatypesTest.java
View File

@ -144,7 +144,7 @@ public abstract class AbstractSqlServerDatatypesTest extends AbstractConnectorTe
.atOffset(ZoneOffset.UTC)
.toInstant())),
new SchemaAndValueField("val_time", org.apache.kafka.connect.data.Time.builder().optional().build(),
java.util.Date.from(LocalTime.of(10, 23, 45, 678_900_000).atDate(LocalDate.ofEpochDay(0)) // value truncated by the driver
java.util.Date.from(LocalTime.of(10, 23, 45, 678_900_000).atDate(LocalDate.ofEpochDay(0))
.atOffset(ZoneOffset.UTC)
.toInstant())),
new SchemaAndValueField("val_datetime2", org.apache.kafka.connect.data.Timestamp.builder().optional().build(),