Details
-
Sub-task
-
Status: Resolved
-
P2
-
Resolution: Duplicate
-
None
-
None
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.
Attachments
Issue Links
- is a child of
-
BEAM-6983 Python 3.6 Support
- Resolved