[FLINK-36891[[source-connector][mysql] Fix corrupted state in case of… #2151

Job	Run time
License Check	3m 0s
Migration Tests / data_stream_migration_test (1.19.1)	25m 43s
Migration Tests / migration_test_ut	3m 45s
Migration Tests / pipeline_migration_test (1.19.1)	6m 40s
Migration Tests / data_stream_migration_test (1.20.0)	25m 38s
Pipeline E2E Tests (8, 1.19.1, pipeline_e2e) / compile_and_test	27m 53s
Pipeline E2E Tests (8, 1.20.0, pipeline_e2e) / compile_and_test	26m 52s
Migration Tests / pipeline_migration_test (1.20.0)	5m 8s
Source E2E Tests (8, 1.19.1, source_e2e) / compile_and_test	24m 9s
Source E2E Tests (8, 1.20.0, source_e2e) / compile_and_test	24m 32s
Unit Tests (8, core) / compile_and_test	12m 8s
Unit Tests (8, db2) / compile_and_test	20m 0s
Unit Tests (8, mysql) / compile_and_test	36m 32s
Unit Tests (8, mongodb7) / compile_and_test	33m 7s
Unit Tests (8, mongodb6) / compile_and_test	34m 36s
Unit Tests (8, oceanbase) / compile_and_test	5m 15s
Unit Tests (8, oracle) / compile_and_test	28m 43s
Unit Tests (8, pipeline_connectors) / compile_and_test	16m 4s
Unit Tests (8, postgres) / compile_and_test	24m 1s
Unit Tests (8, sqlserver) / compile_and_test	12m 43s
Unit Tests (8, tidb) / compile_and_test	3m 4s
Unit Tests (8, vitess) / compile_and_test	3m 9s
	6h 42m 42s

Provide feedback