Jzjsnow commented on PR #3802: URL: https://github.com/apache/flink-cdc/pull/3802#issuecomment-2567311869
> Thanks for @Jzjsnow's clear and detailed diagram! > > Just noticed that we still lack failover tests for pipeline jobs. Could we add some recovering tests like `MySqlSourceITCase#testMySqlParallelSource` and trigger TM/JM Failures in different phases? `flink-cdc-composer` unit tests might be a place for it. @yuxiqian Thanks for the suggestion, I have added some tests to the `flink-cdc-runtime` unit test for testing DataSinkOperator's handling of schema change events, which was lacking. Among them, `DataSinkOperatorWithSchemaEvolveTest#testSchemaChangeEventAfterFailover` is used to test the underlying schema change process after failure recovery, which is applicable to the scenario of restarting after jm/tm failure. -- 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]
