Skip to content

Commit 1d18d78

Browse files
author
李鹏程
committed
[cdc] clean code
1 parent 09d0227 commit 1d18d78

File tree

2 files changed

+0
-9
lines changed

2 files changed

+0
-9
lines changed

paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/AbstractJsonRecordParser.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -124,13 +124,7 @@ protected List<String> extractPrimaryKeys() {
124124
protected void processRecord(
125125
JsonNode jsonNode, RowKind rowKind, List<RichCdcMultiplexRecord> records) {
126126
RowType.Builder rowTypeBuilder = RowType.builder();
127-
<<<<<<< HEAD
128-
Map<String, String> rowData = this.extractRowData(jsonNode, rowTypeBuilder);
129-
evalComputedColumns(rowKind, rowData, rowTypeBuilder);
130-
=======
131127
Map<String, String> rowData = this.extractRowData(rowKind, jsonNode, rowTypeBuilder);
132-
133-
>>>>>>> 1e76b3018 ([cdc] Support audit time during cdc by computed columns)
134128
records.add(createRecord(rowKind, rowData, rowTypeBuilder.build().getFields()));
135129
}
136130

paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumAvroRecordParser.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -158,10 +158,7 @@ private Map<String, String> extractRowData(
158158
rowTypeBuilder.field(fieldName, avroToPaimonDataType(schema));
159159
}
160160

161-
<<<<<<< HEAD
162-
=======
163161
evalComputedColumns(rowKind, resultMap, rowTypeBuilder);
164-
>>>>>>> 1e76b3018 ([cdc] Support audit time during cdc by computed columns)
165162
return resultMap;
166163
}
167164

0 commit comments

Comments
 (0)