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

DBZ-6037 Data no longer logged on error

Browse Source
This commit is contained in:
Jiri Pechanec 2023-01-26 12:02:56 +01:00
parent 8a6fdab5d7
commit 795014e040
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -34,6 +34,7 @@
import io.debezium.schema.FieldNameSelector;
import io.debezium.schema.FieldNameSelector.FieldNamer;
import io.debezium.spi.topic.TopicNamingStrategy;
import io.debezium.util.Loggings;
import io.debezium.util.SchemaNameAdjuster;
/**
@ -206,8 +207,9 @@ protected StructGenerator createKeyGenerator(Schema schema, TableId columnSetNam
}
catch (DataException e) {
Column col = columns.get(i);
LOGGER.error("Failed to properly convert key value for '{}.{}' of type {} for row {}:",
columnSetName, col.name(), col.typeName(), row, e);
Loggings.logErrorAndTraceRecord(LOGGER, row,
"Failed to properly convert key value for '{}.{}' of type {}", columnSetName,
col.name(), col.typeName(), e);
}
}
}
@ -279,13 +281,15 @@ protected StructGenerator createValueGenerator(Schema schema, TableId tableId, L
}
catch (DataException | IllegalArgumentException e) {
Column col = columns.get(i);
LOGGER.error("Failed to properly convert data value for '{}.{}' of type {} for row {}:",
tableId, col.name(), col.typeName(), row, e);
Loggings.logErrorAndTraceRecord(LOGGER, row,
"Failed to properly convert data value for '{}.{}' of type {}", tableId,
col.name(), col.typeName(), e);
}
catch (final Exception e) {
Column col = columns.get(i);
LOGGER.error("Failed to properly convert data value for '{}.{}' of type {} for row {}:",
tableId, col.name(), col.typeName(), row, e);
Loggings.logErrorAndTraceRecord(LOGGER, row,
"Failed to properly convert data value for '{}.{}' of type {}", tableId,
col.name(), col.typeName(), e);
}
}
}