[
https://issues.apache.org/jira/browse/BEAM-9137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018354#comment-17018354
]
Boyuan Zhang commented on BEAM-9137:
Thanks for your confirmation and update! Turns out this test target only fails
on Py2 and even the last successful commit also failed on the same error:
Error processing instruction -77. Original traceback is Traceback (most recent
call last): File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 161, in _execute response = task() File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 217, in lambda: self.create_worker().do_instruction(request),
request) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 346, in do_instruction request.instruction_id) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 374, in process_bundle instruction_id,
request.process_bundle_descriptor_id) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 282, in get self.data_channel_factory) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 717, in __init__ self.ops =
self.create_execution_tree(self.process_bundle_descriptor) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 766, in create_execution_tree descriptor.transforms,
key=topological_height, reverse=True)]) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 680, in wrapper result = cache[args] = func(*args) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 748, in get_operation in
descriptor.transforms[transform_id].outputs.items() File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 747, in for tag, pcoll_id File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 680, in wrapper result = cache[args] = func(*args) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 748, in get_operation in
descriptor.transforms[transform_id].outputs.items() File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 747, in for tag, pcoll_id File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 680, in wrapper result = cache[args] = func(*args) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 748, in get_operation in
descriptor.transforms[transform_id].outputs.items() File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 747, in for tag, pcoll_id File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 680, in wrapper result = cache[args] = func(*args) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 751, in get_operation transform_id, transform_consumers) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1053, in create_operation return creator(self, transform_id,
transform_proto, payload, consumers) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1168, in create output_coder =
factory.get_only_input_coder(transform_proto) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1099, in get_only_input_coder return
only_element(list(self.get_input_coders(transform_proto).values())) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1094, in get_input_coders for tag, pcoll_id in
transform_proto.inputs.items() File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1094, in for tag, pcoll_id in transform_proto.inputs.items()
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1069, in get_windowed_coder coder =
self.get_coder(self.descriptor.pcollections[pcoll_id].coder_id) File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1065, in get_coder json.loads(coder_proto.spec.payload.decode('utf-8')))
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/operation_specs.py",
line 331, in get_coder_from_spec get_coder_from_spec(c) for c in
coder_spec['component_encodings']] File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/operation_specs.py",
line 349, in get_coder_from_spec
get_coder_from_spec(coder_spec['component_encodings'][0])) File
