This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new a1c17cd [BEAM-8244] Split FlinkRunnerTest.test_external_transforms.
new 60d84dc Merge pull request #12286 from ibzib/BEAM-8244
a1c17cd is described below
commit a1c17cdea6958948284db785997f0f2185a83b94
Author: Kyle Weaver <[email protected]>
AuthorDate: Thu Jul 16 16:29:49 2020 -0700
[BEAM-8244] Split FlinkRunnerTest.test_external_transforms.
This may help avoid timeouts.
---
sdks/python/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 a34bb57..f038cf6 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 @@ if __name__ == '__main__':
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 @@ if __name__ == '__main__':
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 @@ if __name__ == '__main__':
'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
(
