DBZ-8499 Make source info versioned

debezium · Jan 14, 2025 · 47cdff1 · 47cdff1
1 parent cb8c9b5
commit 47cdff1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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());