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

Revert "DBZ-2166 Handling error condition where schema field can not be found in"

Browse Source 
This reverts commit 283740f37e.
This commit is contained in:
Gunnar Morling 2020-06-08 20:12:50 +02:00
parent 4254e29667
commit 1fdad23087
1 changed files with 6 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -313,28 +313,20 @@ protected Field[] fieldsForColumns(Schema schema, List<Column> columns) {
* @return the converters for each column in the rows; never null
*/
protected ValueConverter[] convertersForColumns(Schema schema, TableId tableId, List<Column> columns, ColumnMappers mappers) {
ValueConverter[] converters = new ValueConverter[columns.size()];
for (int i = 0; i < columns.size(); i++) {
Column column = columns.get(i);
ValueConverter converter = null;
Field field = schema.field(column.name());
if (field == null) {
ValueConverter converter = createValueConverterFor(tableId, column, schema.field(column.name()));
converter = wrapInMappingConverterIfNeeded(mappers, tableId, column, converter);
if (converter == null) {
LOGGER.warn(
"No schema field found for column {}.{} of type {}. The column will not be part of change events for that table.",
"No converter found for column {}.{} of type {}. The column will not be part of change events for that table.",
tableId, column.name(), column.typeName());
}
else {
converter = createValueConverterFor(tableId, column, field);
converter = wrapInMappingConverterIfNeeded(mappers, tableId, column, converter);
if (converter == null) {
LOGGER.warn(
"No converter found for column {}.{} of type {}. The column will not be part of change events for that table.",
tableId, column.name(), column.typeName());
}
}
// may be null if no converter found
converters[i] = converter;