From 8673a425ff6378303f5591ecae3e8b3255731ab8 Mon Sep 17 00:00:00 2001 From: zalmane Date: Sun, 8 Sep 2024 18:46:58 +0300 Subject: [PATCH] DBZ-8217 fix wrong log message --- .../main/java/io/debezium/relational/TableSchemaBuilder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java b/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java index 4e31812d4..e51b99637 100644 --- a/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java +++ b/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java @@ -328,7 +328,7 @@ protected StructGenerator createValueGenerator(Schema schema, TableId tableId, L result.put(fields[i], value); } catch (final Exception e) { - Column col = columns.get(i); + Column col = columnsThatShouldBeAdded.get(i); String message = "Failed to properly convert data value for '{}.{}' of type {}"; if (eventConvertingFailureHandlingMode == null) { Loggings.logErrorAndTraceRecord(LOGGER, row,