(beam) branch master updated: Ignore test_flatten_and_gbk for spark and samza runners. (#34663)

[yhu]

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 795e45d5215 Ignore test_flatten_and_gbk for spark and samza runners. 
(#34663)
795e45d5215 is described below

commit 795e45d5215a6febe2f892390f0e01f4a579a029
Author: Shunping Huang <shunp...@google.com>
AuthorDate: Fri Apr 18 11:14:34 2025 -0400

    Ignore test_flatten_and_gbk for spark and samza runners. (#34663)
---
 sdks/python/apache_beam/runners/portability/samza_runner_test.py | 4 +++-
 sdks/python/apache_beam/runners/portability/spark_runner_test.py | 4 +++-
 2 files changed, 6 insertions(+), 2 deletions(-)

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 e01fa461cc9..8dcd92ce503 100644
--- a/sdks/python/apache_beam/runners/portability/samza_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/samza_runner_test.py
@@ -145,7 +145,9 @@ class 
SamzaRunnerTest(portable_runner_test.PortableRunnerTest):
   def test_flatten_and_gbk(self):
     # Blocked on support for transcoding
     # https://github.com/apache/beam/issues/20984
-    super().test_flatten_and_gbk(with_transcoding=False)
+    # Also blocked on support of flatten and groupby sharing the same input
+    # https://github.com/apache/beam/issues/34647
+    raise unittest.SkipTest("https://github.com/apache/beam/issues/34647";)
 
   def test_pack_combiners(self):
     # Stages produced by translations.pack_combiners are fused
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 fd251021ba4..9fc7da2449f 100644
--- a/sdks/python/apache_beam/runners/portability/spark_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/spark_runner_test.py
@@ -180,7 +180,9 @@ class 
SparkRunnerTest(portable_runner_test.PortableRunnerTest):
   def test_flatten_and_gbk(self):
     # Blocked on support for transcoding
     # https://github.com/apache/beam/issues/19504
-    super().test_flatten_and_gbk(with_transcoding=False)
+    # Also blocked on support of flatten and groupby sharing the same input
+    # https://github.com/apache/beam/issues/34647
+    raise unittest.SkipTest("https://github.com/apache/beam/issues/34647";)
 
   def test_custom_merging_window(self):
     raise unittest.SkipTest("https://github.com/apache/beam/issues/20641";)