diff --git a/sdks/python/apache_beam/runners/portability/flink_runner_test.py b/sdks/python/apache_beam/runners/portability/flink_runner_test.py
index f038cf678392..6dd76347f039 100644
--- a/sdks/python/apache_beam/runners/portability/flink_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/flink_runner_test.py
@@ -396,7 +396,13 @@ def create_options(self):
       ] + options.view_as(DebugOptions).experiments
       return options
 
-    def test_external_transforms(self):
+    def test_external_transform(self):
+      raise unittest.SkipTest("BEAM-7252")
+
+    def test_expand_kafka_read(self):
+      raise unittest.SkipTest("BEAM-7252")
+
+    def test_expand_kafka_write(self):
       raise unittest.SkipTest("BEAM-7252")
 
     def test_sql(self):