Skip to content

Commit

Permalink
[Fix]: fix the cdc bug about NPE when the original table deletes a fi…
Browse files Browse the repository at this point in the history
…eld (#5579)

Co-authored-by: JohnZp <[email protected]>
  • Loading branch information
JohnZp and JohnZp authored Oct 3, 2023
1 parent 4117335 commit f5ed477
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -81,11 +81,11 @@ public SeaTunnelRow convert(SourceRecord record, Struct struct, Schema schema)
// physical column
for (int i = 0; i < physicalConverters.length; i++) {
String fieldName = fieldNames[i];
Object fieldValue = struct.get(fieldName);
Field field = schema.field(fieldName);
if (field == null) {
row.setField(i, null);
} else {
Object fieldValue = struct.get(fieldName);
Schema fieldSchema = field.schema();
Object convertedField =
SeaTunnelRowDebeziumDeserializationConverters.convertField(
Expand Down

0 comments on commit f5ed477

Please sign in to comment.