alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1448 Misc. clean-up

Browse Source
This commit is contained in:
Gunnar Morling 2019-09-03 10:39:41 +02:00
parent 1aa7d70b0d
commit 3215a3ce0a
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
COPYRIGHT.txt
View File

@ -6,6 +6,7 @@ Alexander Kovryga
Amit Sela
Andreas Bergmeier
Andras Istvan Nagy
Andrew Garrett
Andrew Tongen
Andrey Pustovetov
Anton Martynov

8
debezium-core/src/test/java/io/debezium/transforms/ExtractNewRecordStateTest.java
View File

@ -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<SourceRecord> 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<SourceRecord> transform = new ExtractNewRecordState<>()) {
final Map<String, String> props = new HashMap<>();
@ -337,6 +338,7 @@ public void testAddSourceFieldHandleDeleteRewrite() {
}
@Test
@FixFor("DBZ-1448")
public void testAddSourceFieldsHandleDeleteRewrite() {
try (final ExtractNewRecordState<SourceRecord> transform = new ExtractNewRecordState<>()) {
final Map<String, String> 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!");
}
}
}
}