Skip to content

Commit 1c6b293

Browse files
committed
[FLINK-39252][sqlserver] Fix spotless issue and timestamp startup test assertion
1 parent cf0583f commit 1c6b293

2 files changed

Lines changed: 5 additions & 3 deletions

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-sqlserver/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/SqlServerEventDeserializer.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@ public class SqlServerEventDeserializer extends DebeziumEventDeserializationSche
5151
private static final long serialVersionUID = 1L;
5252
private final boolean includeSchemaChanges;
5353
private final List<SqlServerReadableMetadata> readableMetadataList;
54+
5455
/**
5556
* Cache to compute schema differences for ALTER events.
5657
*

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/test/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactoryTest.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -313,9 +313,10 @@ void testTimestampStartupRequiresTimestampMillis() {
313313

314314
Assertions.assertThatThrownBy(() -> createTableSource(SCHEMA, properties))
315315
.isInstanceOf(ValidationException.class)
316-
.hasRootCauseMessage(
317-
"To use timestamp startup mode, the startup timestamp millis "
318-
+ "'scan.startup.timestamp-millis' must be set.");
316+
.hasRootCauseInstanceOf(ValidationException.class)
317+
.rootCause()
318+
.hasMessageContaining("scan.startup.timestamp-millis")
319+
.hasMessageContaining("must be set");
319320
}
320321

321322
private Map<String, String> getAllOptions() {

0 commit comments

Comments
 (0)