(flink) branch ktest created (now 7b7d600936d)

[bl...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bli pushed a change to branch ktest
in repository https://gitbox.apache.org/repos/asf/flink.git


      at 7b7d600936d [hotfix] re-enable unit tests in pyflink test_kafka.py

This branch includes the following new commits:

     new 7b7d600936d [hotfix] re-enable unit tests in pyflink test_kafka.py

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(flink) 01/01: [hotfix] re-enable unit tests in pyflink test_kafka.py

[bl...@apache.org]

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 <bo...@openai.com>
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
 
 
-@unittest.skip("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)
 
 
-@unittest.skip("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()
 
 
-@unittest.skip("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]