This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 54c6a0b20 [hotfix][e2e] Add missing default values field in E2e test
54c6a0b20 is described below
commit 54c6a0b2076cd0ca5a1f6cc174002390b2cd9967
Author: yuxiqian <[email protected]>
AuthorDate: Wed Aug 7 20:48:46 2024 +0800
[hotfix][e2e] Add missing default values field in E2e test
This closes #3516.
---
.../test/java/org/apache/flink/cdc/pipeline/tests/MysqlE2eITCase.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MysqlE2eITCase.java
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MysqlE2eITCase.java
index 28db063ef..43319558c 100644
---
a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MysqlE2eITCase.java
+++
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MysqlE2eITCase.java
@@ -127,7 +127,7 @@ public class MysqlE2eITCase extends PipelineTestEnvironment
{
List<String> expectedEvents =
Arrays.asList(
String.format(
- "CreateTableEvent{tableId=%s.customers,
schema=columns={`id` INT NOT NULL,`name` VARCHAR(255) NOT NULL,`address`
VARCHAR(1024),`phone_number` VARCHAR(512)}, primaryKeys=id, options=()}",
+ "CreateTableEvent{tableId=%s.customers,
schema=columns={`id` INT NOT NULL,`name` VARCHAR(255) NOT NULL
'flink',`address` VARCHAR(1024),`phone_number` VARCHAR(512)}, primaryKeys=id,
options=()}",
mysqlInventoryDatabase.getDatabaseName()),
String.format(
"DataChangeEvent{tableId=%s.customers,
before=[], after=[104, user_4, Shanghai, 123567891234], op=INSERT, meta=()}",
@@ -142,7 +142,7 @@ public class MysqlE2eITCase extends PipelineTestEnvironment
{
"DataChangeEvent{tableId=%s.customers,
before=[], after=[101, user_1, Shanghai, 123567891234], op=INSERT, meta=()}",
mysqlInventoryDatabase.getDatabaseName()),
String.format(
- "CreateTableEvent{tableId=%s.products,
schema=columns={`id` INT NOT NULL,`name` VARCHAR(255) NOT NULL,`description`
VARCHAR(512),`weight` FLOAT,`enum_c` STRING,`json_c` STRING,`point_c` STRING},
primaryKeys=id, options=()}",
+ "CreateTableEvent{tableId=%s.products,
schema=columns={`id` INT NOT NULL,`name` VARCHAR(255) NOT NULL
'flink',`description` VARCHAR(512),`weight` FLOAT,`enum_c` STRING
'red',`json_c` STRING,`point_c` STRING}, primaryKeys=id, options=()}",
mysqlInventoryDatabase.getDatabaseName()),
String.format(
"DataChangeEvent{tableId=%s.products,
before=[], after=[109, spare tire, 24 inch spare tire, 22.2, null, null, null],
op=INSERT, meta=()}",
