Skip to content

Commit 071cf0b

Browse files
author
李鹏程
committed
[cdc] resolve conflicts
1 parent b8789a5 commit 071cf0b

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumBsonRecordParserTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -241,7 +241,8 @@ public void bsonConvertJsonTest() throws Exception {
241241

242242
JsonNode bsonTextNode =
243243
new TextNode(JsonSerdeUtil.writeValueAsString(bsonRecord.getValue()));
244-
Map<String, String> resultMap = parser.extractRowData(bsonTextNode, RowType.builder());
244+
Map<String, String> resultMap =
245+
parser.extractRowData(RowKind.INSERT, bsonTextNode, RowType.builder());
245246

246247
ObjectNode expectNode = (ObjectNode) jsonRecord.getValue();
247248

0 commit comments

Comments
 (0)