[debezium] Correct variable name in RowDataDebeziumDeserializeSchema#extractBeforeRow

4 years ago · 6aa9f43a4e
parent f37f3998e2
commit 6aa9f43a4e
1 changed files with 3 additions and 3 deletions
--- a/flink-connector-debezium/src/main/java/com/alibaba/ververica/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java
+++ b/flink-connector-debezium/src/main/java/com/alibaba/ververica/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java
@ -128,9 +128,9 @@ public final class RowDataDebeziumDeserializeSchema
    }

    private GenericRowData extractBeforeRow(Struct value, Schema valueSchema) throws Exception {
-        Schema afterSchema = valueSchema.field(Envelope.FieldName.BEFORE).schema();
-        Struct after = value.getStruct(Envelope.FieldName.BEFORE);
-        return (GenericRowData) runtimeConverter.convert(after, afterSchema);
+        Schema beforeSchema = valueSchema.field(Envelope.FieldName.BEFORE).schema();
+        Struct before = value.getStruct(Envelope.FieldName.BEFORE);
+        return (GenericRowData) runtimeConverter.convert(before, beforeSchema);
    }

    @Override