See
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/125/display/redirect?page=changes>
Changes:
[Etienne Chauchot] [BEAM-10471] change the test condition for
testEstimatedSizeBytes to
[Colm O hEigeartaigh] BEAM-10668 - Replace toLowerCase().equals() with
equalsIgnoreCase
[noreply] [BEAM-10361] upgrade Kotlin version in example (#12497)
------------------------------------------
[...truncated 1.77 MB...]
data_channel=factory.data_channel_factory.create_data_channel(grpc_port))
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 193, in __init__
get_perf_runtime_type_hints(self))
File "apache_beam/runners/worker/operations.py", line 115, in
apache_beam.runners.worker.operations.ConsumerSet.create
return SingletonConsumerSet(
File "apache_beam/runners/worker/operations.py", line 207, in
apache_beam.runners.worker.operations.SingletonConsumerSet.__init__
super(SingletonConsumerSet, self).__init__(
File "apache_beam/runners/worker/operations.py", line 141, in
apache_beam.runners.worker.operations.ConsumerSet.__init__
self.opcounter = opcounters.OperationCounters(
File "apache_beam/runners/worker/opcounters.py", line 209, in
apache_beam.runners.worker.opcounters.OperationCounters.__init__
self.output_type_constraints = producer_type_hints
AttributeError: 'apache_beam.runners.worker.opcounters.OperationCounters'
object has no attribute 'output_type_constraints'
-------------------- >> begin captured logging << --------------------
apache_beam.utils.subprocess_server: INFO: Using pre-built snapshot at
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.24.0-SNAPSHOT.jar>
apache_beam.utils.subprocess_server: INFO: Starting service with ['java' '-jar'
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.24.0-SNAPSHOT.jar'>
'36545']
root: DEBUG: Waiting for grpc channel to be ready at localhost:36545.
apache_beam.utils.subprocess_server: INFO: Starting expansion service at
localhost:36545
apache_beam.utils.subprocess_server: INFO: Aug 10, 2020 6:44:50 PM
org.apache.beam.sdk.expansion.service.ExpansionService loadRegisteredTransforms
apache_beam.utils.subprocess_server: INFO: INFO: Registering external
transforms: [beam:external:java:sql:v1, beam:external:java:generate_sequence:v1]
apache_beam.utils.subprocess_server: INFO: beam:external:java:sql:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$1/1567581361@504bae78
apache_beam.utils.subprocess_server: INFO:
beam:external:java:generate_sequence:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$1/1567581361@3b764bce
root: DEBUG: Waiting for grpc channel to be ready at localhost:36545.
root: DEBUG: Waiting for grpc channel to be ready at localhost:36545.
root: DEBUG: Waiting for grpc channel to be ready at localhost:36545.
root: DEBUG: Waiting for grpc channel to be ready at localhost:36545.
root: DEBUG: Waiting for grpc channel to be ready at localhost:36545.
apache_beam.utils.subprocess_server: INFO: Aug 10, 2020 6:44:51 PM
org.apache.beam.sdk.expansion.service.ExpansionService expand
apache_beam.utils.subprocess_server: INFO: INFO: Expanding
'SqlTransform(beam:external:java:sql:v1)' with URN 'beam:external:java:sql:v1'
root: DEBUG: Sending SIGINT to job_server
root: WARNING: Make sure that locally built Python SDK docker image has Python
2.7 interpreter.
root: INFO: Using Python SDK docker image:
apache/beam_python2.7_sdk:2.24.0.dev. If the image is not available at local,
we will try to pull from hub.docker.com
root: WARNING: Make sure that locally built Python SDK docker image has Python
2.7 interpreter.
root: INFO: Using Python SDK docker image:
apache/beam_python2.7_sdk:2.24.0.dev. If the image is not available at local,
we will try to pull from hub.docker.com
apache_beam.runners.portability.fn_api_runner.translations: INFO:
==================== <function lift_combiners at 0x7f096e05bcf8>
====================
apache_beam.runners.portability.fn_api_runner.translations: DEBUG: 16 [1, 1, 1,
1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1]
apache_beam.runners.portability.fn_api_runner.translations: DEBUG: Stages:
['external_8SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/Impulse\n
SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/Impulse:beam:transform:impulse:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'external_8SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/MapElements/Map/ParMultiDo(Anonymous)\n
SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/MapElements/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'external_8SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)\n
SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'external_8SqlTransform(beam:external:java:sql:v1)/BeamZetaSqlCalcRel_17/ParDo(Calc)/ParMultiDo(Calc)\n
SqlTransform(beam:external:java:sql:v1)/BeamZetaSqlCalcRel_17/ParDo(Calc)/ParMultiDo(Calc):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Create/Impulse_5\n
assert_that/Create/Impulse:beam:transform:impulse:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2826>)_6\n
assert_that/Create/FlatMap(<lambda at core.py:2826>):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Create/Map(decode)_8\n
assert_that/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_9\n
assert_that/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must
follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/ToVoidKey_10\n
assert_that/ToVoidKey:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/pair_with_0_12\n
assert_that/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/pair_with_1_13\n
assert_that/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/Flatten_14\n
assert_that/Group/Flatten:beam:transform:flatten:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/GroupByKey_15\n
assert_that/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_16\n
assert_that/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Unkey_17\n
assert_that/Unkey:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Match_18\n
assert_that/Match:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>']
apache_beam.runners.portability.portable_runner: INFO: Job state changed to
STOPPED
apache_beam.runners.portability.portable_runner: INFO: Job state changed to
STARTING
apache_beam.runners.portability.portable_runner: INFO: Job state changed to
RUNNING
root: INFO: ==================== <function annotate_downstream_side_inputs at
0x7f6c9c7e7cf8> ====================
root: INFO: ==================== <function fix_side_input_pcoll_coders at
0x7f6c9c7e7de8> ====================
root: INFO: ==================== <function lift_combiners at 0x7f6c9c7e7e60>
====================
root: INFO: ==================== <function expand_sdf at 0x7f6c9c7e7ed8>
====================
root: INFO: ==================== <function expand_gbk at 0x7f6c9c7e7f50>
====================
root: INFO: ==================== <function sink_flattens at 0x7f6c9c7ec0c8>
====================
root: INFO: ==================== <function greedily_fuse at 0x7f6c9c7ec140>
====================
root: INFO: ==================== <function read_to_impulse at 0x7f6c9c7ec1b8>
====================
root: INFO: ==================== <function impulse_to_input at 0x7f6c9c7ec230>
====================
root: INFO: ==================== <function sort_stages at 0x7f6c9c7ec410>
====================
root: INFO: ==================== <function setup_timer_mapping at
0x7f6c9c7ec398> ====================
root: INFO: ==================== <function populate_data_channel_coders at
0x7f6c9c7ec488> ====================
root: INFO: starting control server on port 41875
root: INFO: starting data server on port 38765
root: INFO: starting state server on port 44145
root: INFO: starting logging server on port 42845
root: INFO: Created Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
object at 0x7f6c9483e590> for environment external_8beam:env:docker:v1
(beam:env:docker:v1, '\n\x1fapache/beam_java_sdk:2.24.0.dev')
root: INFO: Unable to pull image apache/beam_java_sdk:2.24.0.dev
root: INFO: Waiting for docker to start up.Current status is running
root: INFO: Docker container is running. container_id =
7adfa47ef3f81120f54302291d18f3b524f4618a0e927c336041d3e838ac0e6b, worker_id =
worker_57
root: INFO: Running
((external_8SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/Impulse)+(external_8SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/MapElements/Map/ParMultiDo(Anonymous)))+((SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/PairWithRestriction)+((SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/SplitAndSizeRestriction)+(external_8SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/MapElements/Map/ParMultiDo(Anonymous).output_split/Write)))
root: INFO: Running
((external_8SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/MapElements/Map/ParMultiDo(Anonymous).output_split/Read)+(SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_13/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/Process))+((external_8SqlTransform(beam:external:java:sql:v1)/BeamZetaSqlCalcRel_17/ParDo(Calc)/ParMultiDo(Calc))+(ref_PCollection_PCollection_1/Write))
root: INFO: Created Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
object at 0x7f6c94854290> for environment
ref_Environment_default_environment_1 (beam:env:docker:v1,
'\n$apache/beam_python2.7_sdk:2.24.0.dev')
root: INFO: Unable to pull image apache/beam_python2.7_sdk:2.24.0.dev
root: INFO: Waiting for docker to start up.Current status is running
root: INFO: Docker container is running. container_id =
0bf9488f066ec8e12b96c6f87762e9fa0ba6c792ac7896175d42c3e1f9432c20, worker_id =
worker_58
root: INFO: Running
(ref_AppliedPTransform_assert_that/Create/Impulse_5)+(((ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda
at
core.py:2826>)_6)+(ref_AppliedPTransform_assert_that/Create/Map(decode)_8))+(((ref_AppliedPTransform_assert_that/Group/pair_with_0_12)+(assert_that/Group/Flatten/Transcode/0))+(assert_that/Group/Flatten/Write/0)))
root: ERROR: Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/local_job_service.py";,>
line 271, in _run_job
self._pipeline_proto)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 186, in run_via_runner_api
return self.run_stages(stage_context, stages)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 344, in run_stages
bundle_context_manager,
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 523, in _run_stage
bundle_manager)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 561, in _run_bundle
data_input, data_output, input_timers, expected_timer_output)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 945, in process_bundle
timer_inputs)):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/concurrent/futures/_base.py";,>
line 641, in result_iterator
yield fs.pop().result()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/concurrent/futures/_base.py";,>
line 462, in result
return self.__get_result()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/utils/thread_pool_executor.py";,>
line 44, in run
self._future.set_result(self._fn(*self._fn_args, **self._fn_kwargs))
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 941, in execute
dry_run)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 880, in process_bundle
raise RuntimeError(result.error)
RuntimeError: Traceback (most recent call last):
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 256, in _execute
response = task()
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 313, 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 483, 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 512, 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 385, in get
self.data_channel_factory)
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 849, 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 904, 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 793, in wrapper
result = cache[args] = func(*args)
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 890, in get_operation
transform_id, transform_consumers)
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1177, 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 1283, in create_source_runner
data_channel=factory.data_channel_factory.create_data_channel(grpc_port))
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 193, in __init__
get_perf_runtime_type_hints(self))
File "apache_beam/runners/worker/operations.py", line 115, in
apache_beam.runners.worker.operations.ConsumerSet.create
return SingletonConsumerSet(
File "apache_beam/runners/worker/operations.py", line 207, in
apache_beam.runners.worker.operations.SingletonConsumerSet.__init__
super(SingletonConsumerSet, self).__init__(
File "apache_beam/runners/worker/operations.py", line 141, in
apache_beam.runners.worker.operations.ConsumerSet.__init__
self.opcounter = opcounters.OperationCounters(
File "apache_beam/runners/worker/opcounters.py", line 209, in
apache_beam.runners.worker.opcounters.OperationCounters.__init__
self.output_type_constraints = producer_type_hints
AttributeError: 'apache_beam.runners.worker.opcounters.OperationCounters'
object has no attribute 'output_type_constraints'
root: ERROR: Error running pipeline.
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/local_job_service.py";,>
line 271, in _run_job
self._pipeline_proto)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 186, in run_via_runner_api
return self.run_stages(stage_context, stages)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 344, in run_stages
bundle_context_manager,
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 523, in _run_stage
bundle_manager)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 561, in _run_bundle
data_input, data_output, input_timers, expected_timer_output)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 945, in process_bundle
timer_inputs)):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/concurrent/futures/_base.py";,>
line 641, in result_iterator
yield fs.pop().result()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/concurrent/futures/_base.py";,>
line 462, in result
return self.__get_result()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/utils/thread_pool_executor.py";,>
line 44, in run
self._future.set_result(self._fn(*self._fn_args, **self._fn_kwargs))
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 941, in execute
dry_run)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,>
line 880, in process_bundle
raise RuntimeError(result.error)
RuntimeError: Traceback (most recent call last):
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 256, in _execute
response = task()
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 313, 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 483, 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 512, 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 385, in get
self.data_channel_factory)
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 849, 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 904, 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 793, in wrapper
result = cache[args] = func(*args)
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 890, in get_operation
transform_id, transform_consumers)
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1177, 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 1283, in create_source_runner
data_channel=factory.data_channel_factory.create_data_channel(grpc_port))
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 193, in __init__
get_perf_runtime_type_hints(self))
File "apache_beam/runners/worker/operations.py", line 115, in
apache_beam.runners.worker.operations.ConsumerSet.create
return SingletonConsumerSet(
File "apache_beam/runners/worker/operations.py", line 207, in
apache_beam.runners.worker.operations.SingletonConsumerSet.__init__
super(SingletonConsumerSet, self).__init__(
File "apache_beam/runners/worker/operations.py", line 141, in
apache_beam.runners.worker.operations.ConsumerSet.__init__
self.opcounter = opcounters.OperationCounters(
File "apache_beam/runners/worker/opcounters.py", line 209, in
apache_beam.runners.worker.opcounters.OperationCounters.__init__
self.output_type_constraints = producer_type_hints
AttributeError: 'apache_beam.runners.worker.opcounters.OperationCounters'
object has no attribute 'output_type_constraints'
apache_beam.runners.portability.portable_runner: INFO: Job state changed to
FAILED
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
XML: nosetests-xlangSqlValidateRunner.xml
----------------------------------------------------------------------
XML:
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/nosetests.xml>
----------------------------------------------------------------------
Ran 8 tests in 186.566s
FAILED (errors=8)
> Task
> :sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerPythonUsingSql
> FAILED
> Task :sdks:python:test-suites:direct:xlang:fnApiJobServerCleanup
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/apache_beam/__init__.py>:82:
UserWarning: You are using Apache Beam with Python 2. New releases of Apache
Beam will soon support Python 3 only.
'You are using Apache Beam with Python 2. '
FAILURE: Build completed with 3 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task
':sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerPythonUsingJava'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task
':sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerPythonUsingPython'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
==============================================================================
3: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task
':sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerPythonUsingSql'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 45m 6s
128 actionable tasks: 95 executed, 31 from cache, 2 up-to-date
Publishing build scan...
https://gradle.com/s/2uezhvuzu3emc
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
