hk-lrzy commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1612861870
##########
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/SchemaOperatorTranslator.java:
##########
@@ -58,12 +59,18 @@ public DataStream<Event> translate(
MetadataApplier metadataApplier,
List<RouteDef> routes) {
switch (schemaChangeBehavior) {
- case EVOLVE:
- return addSchemaOperator(input, parallelism, metadataApplier,
routes);
case IGNORE:
- return dropSchemaChangeEvent(input, parallelism);
+ return dropSchemaChangeEvent(
+ addSchemaOperator(input, parallelism, metadataApplier,
routes, true),
+ parallelism);
+ case TRY_EVOLVE:
+ return addSchemaOperator(input, parallelism, metadataApplier,
routes, true);
+ case EVOLVE:
+ return addSchemaOperator(input, parallelism, metadataApplier,
routes, false);
case EXCEPTION:
- return exceptionOnSchemaChange(input, parallelism);
+ return exceptionOnSchemaChange(
Review Comment:
I have some questions about the behavior for `IGNORE` and `EXCEPTION`.
Now when we setting the behavior as IGNORE or EXCEPTION, the job will be
failed, should it be fixed it or create a new PR for it?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
