Disables test

XComp · Sep 12, 2024 · 995306e · 995306e
1 parent 6078af6
commit 995306e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/flink-python/pyflink/datastream/connectors/tests/test_kafka.py b/flink-python/pyflink/datastream/connectors/tests/test_kafka.py
@@ -17,6 +17,7 @@
 ################################################################################
 import json
 from typing import Dict
+import unittest
 
 import pyflink.datastream.data_stream as data_stream
 from pyflink.common import typeinfo
@@ -45,6 +46,7 @@
 
 class KafkaSourceTests(PyFlinkStreamingTestCase):
 
+    @unittest.skip("Disabled due to cyclic dependencies: The connector PyFlink tests are planned to be moved out of Flink as part of 2.0")
     def test_legacy_kafka_connector(self):
         source_topic = 'test_source_topic'
         sink_topic = 'test_sink_topic'