[BEAM-6878] test_multimap_side_input in fn_api.runner_test fails on Python 3.6

• Type: Sub-task
• Status: Resolved
• Priority: P2
• Resolution: Duplicate
• Fix Version/s: Not applicable
• Component/s: sdk-py-core
• Assignee: Robbe
• Reporter: Robbe
• Created: 21/Mar/19 15:48
• Updated: 24/Jul/20 19:58
• Resolved: 03/Apr/19 09:27

Description

The test fails for each Test class with the following stacktrace:

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.

Issue Links

• is a child of: BEAM-6983 Python 3.6 Support