[
https://issues.apache.org/jira/browse/BEAM-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robbe closed BEAM-6878.
-----------------------
Resolution: Duplicate
Assignee: Robbe
Fix Version/s: Not applicable
This is a duplicate of BEAM-6429.
> test_multimap_side_input in fn_api.runner_test fails on Python 3.6
> ------------------------------------------------------------------
>
> Key: BEAM-6878
> URL: https://issues.apache.org/jira/browse/BEAM-6878
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
> Reporter: Robbe
> Assignee: Robbe
> Priority: Major
> Fix For: Not applicable
>
>
> The test fails for each Test class with the following stacktrace:
> {noformat}
> Traceback (most recent call last):
> File
> "/home/robbe/workspace/beam/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py",
> line 233, in test_multimap_side_input
> equal_to([('a', [1, 3]), ('b', [2])]))
> File "/home/robbe/workspace/beam/sdks/python/apache_beam/pipeline.py", line
> 426, in __exit__
> self.run().wait_until_finish()
> File "/home/robbe/workspace/beam/sdks/python/apache_beam/pipeline.py", line
> 406, in run
> self._options).run(False)
> File "/home/robbe/workspace/beam/sdks/python/apache_beam/pipeline.py", line
> 419, in run
> return self.runner.run_pipeline(self, self._options)
> File
> "/home/robbe/workspace/beam/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 276, in run_pipeline
> default_environment=self._default_environment))
> File
> "/home/robbe/workspace/beam/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 280, in run_via_runner_api
> return self.run_stages(*self.create_stages(pipeline_proto))
> File
> "/home/robbe/workspace/beam/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 356, in run_stages
> stage_context.safe_coders)
> File
> "/home/robbe/workspace/beam/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 450, in run_stage
> elements_by_window = _WindowGroupingBuffer(si, value_coder)
> File
> "/home/robbe/workspace/beam/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 199, in __init__
> self._key_coder = coder.wrapped_value_coder.key_coder()
> File "/home/robbe/workspace/beam/sdks/python/apache_beam/coders/coders.py",
> line 182, in key_coder
> raise ValueError('Not a KV coder: %s.' % self)
> ValueError: Not a KV coder: BytesCoder.{noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
