Skip to content

Commit 795e45d

Browse files
authored
Ignore test_flatten_and_gbk for spark and samza runners. (#34663)
1 parent 90b77e7 commit 795e45d

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

sdks/python/apache_beam/runners/portability/samza_runner_test.py

+3-1
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,9 @@ def test_flattened_side_input(self):
145145
def test_flatten_and_gbk(self):
146146
# Blocked on support for transcoding
147147
# https://github.com/apache/beam/issues/20984
148-
super().test_flatten_and_gbk(with_transcoding=False)
148+
# Also blocked on support of flatten and groupby sharing the same input
149+
# https://github.com/apache/beam/issues/34647
150+
raise unittest.SkipTest("https://github.com/apache/beam/issues/34647")
149151

150152
def test_pack_combiners(self):
151153
# Stages produced by translations.pack_combiners are fused

sdks/python/apache_beam/runners/portability/spark_runner_test.py

+3-1
Original file line numberDiff line numberDiff line change
@@ -180,7 +180,9 @@ def test_flattened_side_input(self):
180180
def test_flatten_and_gbk(self):
181181
# Blocked on support for transcoding
182182
# https://github.com/apache/beam/issues/19504
183-
super().test_flatten_and_gbk(with_transcoding=False)
183+
# Also blocked on support of flatten and groupby sharing the same input
184+
# https://github.com/apache/beam/issues/34647
185+
raise unittest.SkipTest("https://github.com/apache/beam/issues/34647")
184186

185187
def test_custom_merging_window(self):
186188
raise unittest.SkipTest("https://github.com/apache/beam/issues/20641")

0 commit comments

Comments
 (0)