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 b7dffe3 [BEAM-8244] Don't run external transform tests with
pre_optimize=all.
new f7b23ec Merge pull request #12303 from ibzib/BEAM-8244
b7dffe3 is described below
commit b7dffe386c3703bd382e1178e7810060562c601b
Author: Kyle Weaver <[email protected]>
AuthorDate: Fri Jul 17 12:05:00 2020 -0700
[BEAM-8244] Don't run external transform tests with pre_optimize=all.
---
sdks/python/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 f038cf6..6dd7634 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 @@ if __name__ == '__main__':
] + 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):
