You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by he...@apache.org on 2021/05/12 22:52:21 UTC
[beam] branch master updated: [BEAM-12321] Failure in
test_run_packable_combine_per_key and test_run_packable_combine_globally
This is an automated email from the ASF dual-hosted git repository.
heejong 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 806d542 [BEAM-12321] Failure in test_run_packable_combine_per_key and test_run_packable_combine_globally
new 207d02b Merge pull request #14798 from ihji/BEAM-12324
806d542 is described below
commit 806d54236152da1efe775c98b08cb27042d1947b
Author: Heejong Lee <he...@gmail.com>
AuthorDate: Tue May 11 18:46:20 2021 -0700
[BEAM-12321] Failure in test_run_packable_combine_per_key and test_run_packable_combine_globally
---
.../portability/fn_api_runner/translations_test.py | 24 +++++++++++-----------
1 file changed, 12 insertions(+), 12 deletions(-)
diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner/translations_test.py b/sdks/python/apache_beam/runners/portability/fn_api_runner/translations_test.py
index e0a4efe..73e8648 100644
--- a/sdks/python/apache_beam/runners/portability/fn_api_runner/translations_test.py
+++ b/sdks/python/apache_beam/runners/portability/fn_api_runner/translations_test.py
@@ -236,21 +236,21 @@ class TranslationsTest(unittest.TestCase):
# These CombinePerKey stages will be packed if and only if
# translations.pack_combiners is enabled in the TestPipeline runner.
assert_that(
- pcoll | 'mean-perkey' >> combiners.Mean.PerKey(),
- equal_to([('a', 3.4)]),
- label='assert-mean-perkey')
+ pcoll | 'min-perkey' >> core.CombinePerKey(min),
+ equal_to([('a', -1)]),
+ label='assert-min-perkey')
assert_that(
pcoll | 'count-perkey' >> combiners.Count.PerKey(),
equal_to([('a', 10)]),
label='assert-count-perkey')
assert_that(
pcoll
- | 'largest-perkey' >> core.CombinePerKey(combiners.Largest(1)),
- equal_to([('a', [9])]),
+ | 'largest-perkey' >> combiners.Top.LargestPerKey(2),
+ equal_to([('a', [9, 6])]),
label='assert-largest-perkey')
with TestPipeline() as pipeline:
- vals = [6, 3, 1, 1, 9, 1, 5, 2, 0, 6]
+ vals = [6, 3, 1, -1, 9, 1, 5, 2, 0, 6]
_ = (
pipeline
| Create([('a', x) for x in vals])
@@ -267,21 +267,21 @@ class TranslationsTest(unittest.TestCase):
# translations.eliminate_common_key_with_void and
# translations.pack_combiners are enabled in the TestPipeline runner.
assert_that(
- pcoll | 'mean-globally' >> combiners.Mean.Globally(),
- equal_to([3.4]),
- label='assert-mean-globally')
+ pcoll | 'min-globally' >> core.CombineGlobally(min),
+ equal_to([-1]),
+ label='assert-min-globally')
assert_that(
pcoll | 'count-globally' >> combiners.Count.Globally(),
equal_to([10]),
label='assert-count-globally')
assert_that(
pcoll
- | 'largest-globally' >> core.CombineGlobally(combiners.Largest(1)),
- equal_to([[9]]),
+ | 'largest-globally' >> combiners.Top.Largest(2),
+ equal_to([[9, 6]]),
label='assert-largest-globally')
with TestPipeline() as pipeline:
- vals = [6, 3, 1, 1, 9, 1, 5, 2, 0, 6]
+ vals = [6, 3, 1, -1, 9, 1, 5, 2, 0, 6]
_ = pipeline | Create(vals) | 'multiple-combines' >> MultipleCombines()
def test_conditionally_packed_combiners(self):