From a1c17cdea6958948284db785997f0f2185a83b94 Mon Sep 17 00:00:00 2001 From: Kyle Weaver Date: Thu, 16 Jul 2020 16:29:49 -0700 Subject: [PATCH] [BEAM-8244] Split FlinkRunnerTest.test_external_transforms. This may help avoid timeouts. --- .../apache_beam/runners/portability/flink_runner_test.py | 4 +++- 1 file changed, 3 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 a34bb571f452..f038cf678392 100644 --- a/sdks/python/apache_beam/runners/portability/flink_runner_test.py +++ b/sdks/python/apache_beam/runners/portability/flink_runner_test.py @@ -202,7 +202,7 @@ def test_read(self): def test_no_subtransform_composite(self): raise unittest.SkipTest("BEAM-4781") - def test_external_transforms(self): + def test_external_transform(self): with self.create_pipeline() as p: res = ( p @@ -213,6 +213,7 @@ def test_external_transforms(self): assert_that(res, equal_to([i for i in range(1, 10)])) + def test_expand_kafka_read(self): # We expect to fail here because we do not have a Kafka cluster handy. # Nevertheless, we check that the transform is expanded by the # ExpansionService and that the pipeline fails during execution. @@ -239,6 +240,7 @@ def test_external_transforms(self): 'Expected to fail due to invalid bootstrap.servers, but ' 'failed due to:\n%s' % str(ctx.exception)) + def test_expand_kafka_write(self): # We just test the expansion but do not execute. # pylint: disable=expression-not-assigned (