From b7dffe386c3703bd382e1178e7810060562c601b Mon Sep 17 00:00:00 2001 From: Kyle Weaver Date: Fri, 17 Jul 2020 12:05:00 -0700 Subject: [PATCH] [BEAM-8244] Don't run external transform tests with pre_optimize=all. --- .../apache_beam/runners/portability/flink_runner_test.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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):