This is an automated email from the ASF dual-hosted git repository. bli pushed a commit to branch ktest in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7b7d600936d338d8f9cf5295f7f095885f7054e3 Author: Bowen Li <[email protected]> AuthorDate: Tue Jan 13 12:36:13 2026 -0800 [hotfix] re-enable unit tests in pyflink test_kafka.py --- flink-python/pyflink/datastream/connectors/tests/test_kafka.py | 5 ----- 1 file changed, 5 deletions(-) diff --git a/flink-python/pyflink/datastream/connectors/tests/test_kafka.py b/flink-python/pyflink/datastream/connectors/tests/test_kafka.py index 5abc4c5c73b..f64a1512406 100644 --- a/flink-python/pyflink/datastream/connectors/tests/test_kafka.py +++ b/flink-python/pyflink/datastream/connectors/tests/test_kafka.py @@ -43,10 +43,8 @@ from pyflink.testing.test_case_utils import ( from pyflink.util.java_utils import to_jarray, is_instance_of, get_field_value [email protected]("Disable due to Kafka connector need to release a new version 2.0") class KafkaSourceTests(PyFlinkStreamingTestCase): - @unittest.skip("Disabled due to cyclic dependencies: Should be removed with Flink 2.0") def test_legacy_kafka_connector(self): source_topic = 'test_source_topic' sink_topic = 'test_sink_topic' @@ -422,7 +420,6 @@ class KafkaSourceTests(PyFlinkStreamingTestCase): return Configuration(j_configuration=j_configuration) [email protected]("Disable due to Kafka connector need to release a new version 2.0") class KafkaSinkTests(PyFlinkStreamingTestCase): def test_compile(self): @@ -512,7 +509,6 @@ class KafkaSinkTests(PyFlinkStreamingTestCase): .build() [email protected]("Disable due to Kafka connector need to release a new version 2.0") class KafkaRecordSerializationSchemaTests(PyFlinkTestCase): def test_set_topic(self): @@ -536,7 +532,6 @@ class KafkaRecordSerializationSchemaTests(PyFlinkTestCase): self.assertIsNone(j_record.key()) self.assertEqual(j_record.value(), b'{"f0":"test"}') - @unittest.skip("Disable due to Kafka connector need to release a new version 2.0") def test_set_topic_selector(self): def _select(data): data = data[0]
