Commit 1a2f93e

committed

add test

1 parent cfa3e9a commit 1a2f93eCopy full SHA for 1a2f93e

3 files changed

+362

-0

lines changed

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test
- java/org/apache/flink/cdc/pipeline/tests
  - MysqlE2eITCase.java
  - MysqlToKafkaE2eITCase.java
- resources/expectedEvents/mysqlToKafka
  - debezium-json-with-schema.txt

3 files changed

+362

-0

lines changed

Comments

(0)