From 3215a3ce0ae950ef94e3759edf942ae87cd3de58 Mon Sep 17 00:00:00 2001 From: Gunnar Morling Date: Tue, 3 Sep 2019 10:39:41 +0200 Subject: [PATCH] DBZ-1448 Misc. clean-up --- COPYRIGHT.txt | 1 + .../io/debezium/transforms/ExtractNewRecordStateTest.java | 8 +++++--- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/COPYRIGHT.txt b/COPYRIGHT.txt index c7efef746..e2afaae80 100644 --- a/COPYRIGHT.txt +++ b/COPYRIGHT.txt @@ -6,6 +6,7 @@ Alexander Kovryga Amit Sela Andreas Bergmeier Andras Istvan Nagy +Andrew Garrett Andrew Tongen Andrey Pustovetov Anton Martynov diff --git a/debezium-core/src/test/java/io/debezium/transforms/ExtractNewRecordStateTest.java b/debezium-core/src/test/java/io/debezium/transforms/ExtractNewRecordStateTest.java index 206e3a57c..417f702ca 100644 --- a/debezium-core/src/test/java/io/debezium/transforms/ExtractNewRecordStateTest.java +++ b/debezium-core/src/test/java/io/debezium/transforms/ExtractNewRecordStateTest.java @@ -306,7 +306,7 @@ public void testAddSourceFields() { assertThat(((Struct) unwrapped.value()).getString("__version")).isEqualTo("version!"); } } - + @Test(expected = ConfigException.class) public void testAddSourceNonExistantField() { try (final ExtractNewRecordState transform = new ExtractNewRecordState<>()) { @@ -316,12 +316,13 @@ public void testAddSourceNonExistantField() { final SourceRecord createRecord = createComplexCreateRecord(); final SourceRecord unwrapped = transform.apply(createRecord); - + assertThat(((Struct) unwrapped.value()).schema().field("__nope")).isNull(); } } @Test + @FixFor("DBZ-1448") public void testAddSourceFieldHandleDeleteRewrite() { try (final ExtractNewRecordState transform = new ExtractNewRecordState<>()) { final Map props = new HashMap<>(); @@ -337,6 +338,7 @@ public void testAddSourceFieldHandleDeleteRewrite() { } @Test + @FixFor("DBZ-1448") public void testAddSourceFieldsHandleDeleteRewrite() { try (final ExtractNewRecordState transform = new ExtractNewRecordState<>()) { final Map props = new HashMap<>(); @@ -350,5 +352,5 @@ public void testAddSourceFieldsHandleDeleteRewrite() { assertThat(((Struct) unwrapped.value()).get("__lsn")).isEqualTo(1234); assertThat(((Struct) unwrapped.value()).getString("__version")).isEqualTo("version!"); } - } + } }