Details
Description
In https://issues.apache.org/jira/browse/FLINK-36245 , we disabled some test cases because Kafka connector still used some removed class temporarily, After Kafka connector releases a new version that completed the deprecated work, we need to release these disabled test cases.
1. The temporary disabled test cases include:
- SqlClientITCase#testMatchRecognize
- connector test under flink-python/pyflink/datastream/conntectors/tests
2. Classes that skipped compile by maven plugin:
- org.apache.flink.schema.registry.test.TestAvroConsumerConfluent
- org.apache.flink.streaming.examples.statemachine.KafkaEventsGeneratorJob