Skip to content

Commit b6a6b8a

Browse files
authored
[cdc] Correct the isDdl field for aliyun-json (#4996)
1 parent 5169a5c commit b6a6b8a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public class AliyunRecordParser extends AbstractJsonRecordParser {
6666

6767
private static final Logger LOG = LoggerFactory.getLogger(AliyunRecordParser.class);
6868

69-
private static final String FIELD_IS_DDL = "isDdl";
69+
private static final String FIELD_IS_DDL = "ddl";
7070
private static final String FIELD_TYPE = "op";
7171

7272
private static final String OP_UPDATE_BEFORE = "UPDATE_BEFORE";

0 commit comments

Comments
 (0)