gongzexin commented on PR #3912: URL: https://github.com/apache/flink-cdc/pull/3912#issuecomment-2680469662
> It seems that `SchemaChangeResponse#ResponseCode` can only be SUCCESS now. Can we remove `SchemaChangeResponse#ResponseCode` and simplify the logic in `SchemaOperator#handleSchemaChangeEvent` ? @yuxiqian @Shawn-Hx Hi, Have you noticed that during fault tolerance, the same table will be flushed multiple times (related to the task parallelism).So I think SchemaChangeResponse#ResponseCode#DUPLICATE should not be deleted, but it should be strengthened. -- 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]
