leonardBang commented on code in PR #3521:
URL: https://github.com/apache/flink-cdc/pull/3521#discussion_r1721300426
##########
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/SchemaEvolveE2eITCase.java:
##########
@@ -337,6 +347,13 @@ private void testGenericSchemaEvolution(
// triggers DropColumnEvent
stmt.execute("ALTER TABLE members DROP COLUMN biological_sex");
stmt.execute("INSERT INTO members VALUES (1013, 'Fiona', 16);");
+
+ // triggers TruncateTableEvent
+ stmt.execute("TRUNCATE TABLE members;");
+ stmt.execute("INSERT INTO members VALUES (1014, 'Gem', 17);");
+
+ // triggers DropTableEvent
+ stmt.execute("DROP TABLE members;");
Review Comment:
For LENIENT mode, we should skip dropping downstream table instead of EVOLVE
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
