This is an automated email from the ASF dual-hosted git repository.
yhu 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 389e1067c9d Disable unsupported custom window type test on samza and
spark. (#30680)
389e1067c9d is described below
commit 389e1067c9d1f9bcc99b338ffb46e4923f692cae
Author: Robert Bradshaw <[email protected]>
AuthorDate: Tue Mar 19 17:17:24 2024 -0700
Disable unsupported custom window type test on samza and spark. (#30680)
---
sdks/python/apache_beam/runners/portability/samza_runner_test.py | 3 +++
sdks/python/apache_beam/runners/portability/spark_runner_test.py | 3 +++
2 files changed, 6 insertions(+)
diff --git a/sdks/python/apache_beam/runners/portability/samza_runner_test.py
b/sdks/python/apache_beam/runners/portability/samza_runner_test.py
index a56be8da11c..ceb5240924b 100644
--- a/sdks/python/apache_beam/runners/portability/samza_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/samza_runner_test.py
@@ -176,6 +176,9 @@ class
SamzaRunnerTest(portable_runner_test.PortableRunnerTest):
# Skip until Samza runner supports merging window fns
raise unittest.SkipTest("https://github.com/apache/beam/issues/21049";)
+ def test_custom_window_type(self):
+ raise unittest.SkipTest("https://github.com/apache/beam/issues/21049";)
+
if __name__ == '__main__':
# Run the tests.
diff --git a/sdks/python/apache_beam/runners/portability/spark_runner_test.py
b/sdks/python/apache_beam/runners/portability/spark_runner_test.py
index 5530caa1e97..d4879190738 100644
--- a/sdks/python/apache_beam/runners/portability/spark_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/spark_runner_test.py
@@ -180,6 +180,9 @@ class
SparkRunnerTest(portable_runner_test.PortableRunnerTest):
def test_custom_merging_window(self):
raise unittest.SkipTest("https://github.com/apache/beam/issues/20641";)
+ def test_custom_window_type(self):
+ raise unittest.SkipTest("https://github.com/apache/beam/issues/20641";)
+
# Inherits all other tests from PortableRunnerTest.
