See 
<https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow_V2/253/display/redirect?page=changes>

Changes:

[chamikara] Refactors X-Lang test pipelines.


------------------------------------------
[...truncated 20.97 MB...]
KeyError: u'beam:sink:runner:0.1'

generic::unknown: Traceback (most recent call last):
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 190, in _execute
    response = task()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 247, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 416, in do_instruction
    getattr(request, request_type), request.instruction_id)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 445, 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 319, in get
    self.data_channel_factory)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 744, 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 797, 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 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 783, in get_operation
    transform_id, transform_consumers)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 1112, in create_operation
    creator, parameter_type = self._known_urns[transform_proto.spec.urn]
KeyError: u'beam:sink:runner:0.1'

passed through:
==>
    dist_proc/dax/workflow/worker/fnapi_service.cc:588: 
process_bundle_response_and_done_->first
generic::unknown: Traceback (most recent call last):
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 190, in _execute
    response = task()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 247, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 416, in do_instruction
    getattr(request, request_type), request.instruction_id)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 445, 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 319, in get
    self.data_channel_factory)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 744, 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 797, 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 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 783, in get_operation
    transform_id, transform_consumers)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 1112, in create_operation
    creator, parameter_type = self._known_urns[transform_proto.spec.urn]
KeyError: u'beam:sink:runner:0.1'

generic::unknown: Traceback (most recent call last):
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 190, in _execute
    response = task()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 247, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 416, in do_instruction
    getattr(request, request_type), request.instruction_id)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 445, 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 319, in get
    self.data_channel_factory)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 744, 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 797, 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 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 783, in get_operation
    transform_id, transform_consumers)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 1112, in create_operation
    creator, parameter_type = self._known_urns[transform_proto.spec.urn]
KeyError: u'beam:sink:runner:0.1'

passed through:
==>
    dist_proc/dax/workflow/worker/fnapi_service.cc:588: 
process_bundle_response_and_done_->first
INFO:apache_beam.runners.dataflow.dataflow_runner:2020-03-31T23:35:12.972Z: 
JOB_MESSAGE_ERROR: generic::unknown: Traceback (most recent call last):
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 190, in _execute
    response = task()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 247, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 416, in do_instruction
    getattr(request, request_type), request.instruction_id)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 445, 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 319, in get
    self.data_channel_factory)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 744, 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 797, 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 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 783, in get_operation
    transform_id, transform_consumers)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 1112, in create_operation
    creator, parameter_type = self._known_urns[transform_proto.spec.urn]
KeyError: u'beam:sink:runner:0.1'

generic::unknown: Traceback (most recent call last):
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 190, in _execute
    response = task()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 247, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 416, in do_instruction
    getattr(request, request_type), request.instruction_id)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
 line 445, 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 319, in get
    self.data_channel_factory)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 744, 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 797, 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 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in get_operation
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 780, in <dictcomp>
    pcoll_id in descriptor.transforms[transform_id].outputs.items()
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 705, in wrapper
    result = cache[args] = func(*args)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 783, in get_operation
    transform_id, transform_consumers)
  File 
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
 line 1112, in create_operation
    creator, parameter_type = self._known_urns[transform_proto.spec.urn]
KeyError: u'beam:sink:runner:0.1'

passed through:
==>
    dist_proc/dax/workflow/worker/fnapi_service.cc:588: 
process_bundle_response_and_done_->first
Agent went offline during the build
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-2 is offline; cannot locate JDK 1.8 (latest)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to