diff --git a/src/test/java/io/debezium/connector/spanner/SpannerConnectorConfigTest.java b/src/test/java/io/debezium/connector/spanner/SpannerConnectorConfigTest.java index c9ab2f9..9891994 100644 --- a/src/test/java/io/debezium/connector/spanner/SpannerConnectorConfigTest.java +++ b/src/test/java/io/debezium/connector/spanner/SpannerConnectorConfigTest.java @@ -57,7 +57,7 @@ void testGetSourceInfoStructMaker() { .schema(); assertTrue(schemaResult instanceof ConnectSchema); assertNull(schemaResult.defaultValue()); - assertNull(schemaResult.version()); + assertEquals(1, schemaResult.version()); assertEquals(Schema.Type.STRUCT, schemaResult.type()); assertNull(schemaResult.parameters()); assertEquals("com.google.spanner.connector.Source", schemaResult.name()); diff --git a/src/test/java/io/debezium/connector/spanner/SpannerSourceInfoStructMakerTest.java b/src/test/java/io/debezium/connector/spanner/SpannerSourceInfoStructMakerTest.java index 0c02500..3e02ce5 100644 --- a/src/test/java/io/debezium/connector/spanner/SpannerSourceInfoStructMakerTest.java +++ b/src/test/java/io/debezium/connector/spanner/SpannerSourceInfoStructMakerTest.java @@ -46,7 +46,7 @@ void testConstructor() { assertTrue(schemaResult instanceof ConnectSchema); assertNull(schemaResult.defaultValue()); - assertNull(schemaResult.version()); + assertEquals(1, schemaResult.version()); assertEquals(Schema.Type.STRUCT, schemaResult.type()); assertNull(schemaResult.parameters()); assertEquals("com.google.spanner.connector.Source", schemaResult.name());