From 04c0091e590b863917971a0828683e56c47a910b Mon Sep 17 00:00:00 2001 From: Jiri Pechanec Date: Wed, 22 May 2024 09:35:19 +0200 Subject: [PATCH] DBZ-7880 Make schema backward compatible --- .../java/io/debezium/connector/vitess/SourceInfoTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/io/debezium/connector/vitess/SourceInfoTest.java b/src/test/java/io/debezium/connector/vitess/SourceInfoTest.java index 1948dffd..03e19af4 100644 --- a/src/test/java/io/debezium/connector/vitess/SourceInfoTest.java +++ b/src/test/java/io/debezium/connector/vitess/SourceInfoTest.java @@ -125,8 +125,8 @@ public void schemaIsCorrect() { .field("snapshot", AbstractSourceInfoStructMaker.SNAPSHOT_RECORD_SCHEMA) .field("db", Schema.STRING_SCHEMA) .field("sequence", Schema.OPTIONAL_STRING_SCHEMA) - .field("ts_us", Schema.INT64_SCHEMA) - .field("ts_ns", Schema.INT64_SCHEMA) + .field("ts_us", Schema.OPTIONAL_INT64_SCHEMA) + .field("ts_ns", Schema.OPTIONAL_INT64_SCHEMA) .field("keyspace", Schema.STRING_SCHEMA) .field("table", Schema.STRING_SCHEMA) .field("shard", Schema.STRING_SCHEMA)