Update sdks/java/io/debezium/src/main/java/org/apache/beam/io/debeziu…

…m/KafkaConnectUtils.java Co-authored-by: Ahmed Abualsaud <65791736+ahmedabu98@users.noreply.github.com>
apache · Dec 20, 2022 · 40a4438 · 40a4438
1 parent d5c9751
commit 40a4438
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/KafkaConnectUtils.java b/sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/KafkaConnectUtils.java
@@ -98,7 +98,7 @@ private Row beamRowFromKafkaStruct(Struct kafkaStruct, Schema beamSchema) {
               Schema fieldSchema = f.getType().getRowSchema();
               if (fieldSchema == null) {
                 throw new IllegalArgumentException(
-                    "Improper schema for Beam record " + fieldSchema);
+                    String.format("Improper schema for Beam record: %s has no row schema to build a Row from.", f.getName());
               }
               if (structField == null) {
                 // If the field is null, then we must add a null field to ensure we encode things