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

DBZ-2849 Fix value converter field lookups with sanitized field names

Browse Source
This commit is contained in:
Chris Cranford 2020-12-16 13:55:12 -05:00 committed by Gunnar Morling
parent d178365529
commit 8409282739
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java
View File

@ -318,7 +318,7 @@ protected ValueConverter[] convertersForColumns(Schema schema, TableId tableId,
for (int i = 0; i < columns.size(); i++) {
Column column = columns.get(i);
ValueConverter converter = createValueConverterFor(tableId, column, schema.field(column.name()));
ValueConverter converter = createValueConverterFor(tableId, column, schema.field(fieldNamer.fieldNameFor(column)));
converter = wrapInMappingConverterIfNeeded(mappers, tableId, column, converter);
if (converter == null) {