DBZ-1044 Fix broken test caused by previous commit

This commit is contained in:
Chris Cranford 2019-09-19 12:10:27 -04:00 committed by Jiri Pechanec
parent 910d00f6a2
commit 6dc37fc8f6

View File

@ -297,12 +297,6 @@ public void shouldSanitizeFieldNamesAndBuildTableSchemaFromTableWithoutPrimaryKe
assertThat(value.get("C4")).isEqualTo(4); assertThat(value.get("C4")).isEqualTo(4);
assertThat(value.get("C5")).isEqualTo(ByteBuffer.wrap(new byte[]{ 71, 117, 110, 110, 97, 114})); assertThat(value.get("C5")).isEqualTo(ByteBuffer.wrap(new byte[]{ 71, 117, 110, 110, 97, 114}));
assertThat(value.get("C6")).isEqualTo(Short.valueOf((short) 0)); assertThat(value.get("C6")).isEqualTo(Short.valueOf((short) 0));
TableSchema tableSchema = new TableSchemaBuilder(new JdbcValueConverters(), adjuster, SchemaBuilder.struct().build(), false)
.create(prefix, "sometopic", table, null, null);
Struct key = new Struct(tableSchema.keySchema()).put("C1", "c1").put("C2", "c2");
SourceRecord record = new SourceRecord(new HashMap<>(), new HashMap<>(), "sometopic", tableSchema.keySchema(), key, null, null);
} }
@Test @Test