This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 2164f661b [doc] Fix typo in mongo-cdc.md (#3413)
add 73a1e39e8 [cdc] Cdc sync normal json format to append table (#3389)
No new revisions were added by this update.
Summary of changes:
docs/content/flink/cdc-ingestion/kafka-cdc.md | 27 ++++-
docs/content/flink/cdc-ingestion/pulsar-cdc.md | 27 ++++-
.../paimon/flink/action/cdc/format/DataFormat.java | 4 +-
.../action/cdc/format/json/JsonRecordParser.java | 65 ++++++++++
.../cdc/kafka/KafkaJsonSyncTableActionITCase.java | 133 +++++++++++++++++++++
.../json/table/computedcolumn/json-data-1.txt | 2 +
.../json/table/schemaevolution/json-data-1.txt | 2 +
.../json/table/schemaevolution/json-data-2.txt | 2 +
8 files changed, 259 insertions(+), 3 deletions(-)
create mode 100644
paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/json/JsonRecordParser.java
create mode 100644
paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/kafka/KafkaJsonSyncTableActionITCase.java
copy copyright.txt =>
paimon-flink/paimon-flink-cdc/src/test/resources/kafka/json/table/computedcolumn/json-data-1.txt
(88%)
copy copyright.txt =>
paimon-flink/paimon-flink-cdc/src/test/resources/kafka/json/table/schemaevolution/json-data-1.txt
(88%)
copy copyright.txt =>
paimon-flink/paimon-flink-cdc/src/test/resources/kafka/json/table/schemaevolution/json-data-2.txt
(87%)
