yuxiqian opened a new pull request, #3712: URL: https://github.com/apache/flink-cdc/pull/3712
This fixes a mysterious test failure in OceanBaseMySQLModeITCase like [this](https://github.com/apache/flink-cdc/actions/runs/11720914709/job/32647267237). Recently it is happening quite frequently, and it's possibly brought in by #3439. This could be stably reproduced locally, by running `OceanBaseMySqlModeITCase` locally, and make sure `testMetadataColumns` is executed right after `testSnapshotOnly`. This test case will because instead of getting expected ``` +I(test,inventory,products,101,scooter,Small 2-wheel scooter,3.1400000000), +I(test,inventory,products,102,car battery,12V car battery,8.1000000000), +I(test,inventory,products,103,12-pack drill bits,12-pack of drill bits with sizes ranging from #40 to #3,0.8000000000), +I(test,inventory,products,104,hammer,12oz carpenter's hammer,0.7500000000), +I(test,inventory,products,105,hammer,14oz carpenter's hammer,0.8750000000), +I(test,inventory,products,106,hammer,16oz carpenter's hammer,1.0000000000), +I(test,inventory,products,107,rocks,box of assorted rocks,5.3000000000), +I(test,inventory,products,108,jacket,water resistent black wind breaker,0.1000000000), +I(test,inventory,products,109,spare tire,24 inch spare tire,22.2000000000), +U(test,inventory,products,106,hammer,18oz carpenter hammer,1.0000000000) ``` values, it is actually receiving: ``` +I(test,inventory,products,101,scooter,Small 2-wheel scooter,3.1400000000), +I(test,inventory,products,102,car battery,12V car battery,8.1000000000), +I(test,inventory,products,103,12-pack drill bits,12-pack of drill bits with sizes ranging from #40 to #3,0.8000000000), +I(test,inventory,products,104,hammer,12oz carpenter's hammer,0.7500000000), +I(test,inventory,products,105,hammer,14oz carpenter's hammer,0.8750000000), +I(test,inventory,products,106,hammer,16oz carpenter's hammer,1.0000000000), +I(test,inventory,products,107,rocks,box of assorted rocks,5.3000000000), +I(test,inventory,products,108,jacket,water resistent black wind breaker,0.1000000000), +I(test,inventory,products,109,spare tire,24 inch spare tire,22.2000000000), +I(test,inventory,products,101,scooter,Small 2-wheel scooter,3.1400000000), +I(test,inventory,products,102,car battery,12V car battery,8.1000000000), +I(test,inventory,products,103,12-pack drill bits,12-pack of drill bits with sizes ranging from #40 to #3,0.8000000000), +I(test,inventory,products,104,hammer,12oz carpenter's hammer,0.7500000000), +I(test,inventory,products,105,hammer,14oz carpenter's hammer,0.8750000000), +I(test,inventory,products,106,hammer,16oz carpenter's hammer,1.0000000000), +I(test,inventory,products,107,rocks,box of assorted rocks,5.3000000000), +I(test,inventory,products,108,jacket,water resistent black wind breaker,0.1000000000), +I(test,inventory,products,109,spare tire,24 inch spare tire,22.2000000000), +I(test,inventory,products,101,scooter,Small 2-wheel scooter,3.1400000000), +I(test,inventory,products,102,car battery,12V car battery,8.1000000000) ``` which makes totally no sense, just like previous data records have not been cleaned up correctly. Running either `testSnapshotOnly` or `testMetadataColumns` independently is OK, so this PR creates & destroys OceanBase containers for each test case to avoid breaking CI, as a temporary hackaround. I'm a little worried that this behavior might not be caused by a bad test case but reflects some connector implementation issue. Needs some advice from @whhe. -- 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]
