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

Changes:

[robertwb] Allow metrics update to be tolerant to uninitalized metric 
containers.


------------------------------------------
[...truncated 1016.22 KB...]
-------------------- >> begin captured logging << --------------------
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.20.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_transforms: INFO: 
==================== <function lift_combiners at 0x7f9b3d32b9b0> 
====================
apache_beam.runners.portability.fn_api_runner_transforms: DEBUG: 25 [1, 1, 1, 
1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1]
apache_beam.runners.portability.fn_api_runner_transforms: DEBUG: Stages: 
['ref_AppliedPTransform_create_col1/Impulse_3\n  
create_col1/Impulse:beam:transform:impulse:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_create_col1/FlatMap(<lambda at core.py:2637>)_4\n  
create_col1/FlatMap(<lambda at core.py:2637>):beam:transform:pardo:v1\n  must 
follow: \n  downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_create_col1/Map(decode)_6\n  
create_col1/Map(decode):beam:transform:pardo:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_create_col2/Impulse_8\n  
create_col2/Impulse:beam:transform:impulse:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_create_col2/FlatMap(<lambda at core.py:2637>)_9\n  
create_col2/FlatMap(<lambda at core.py:2637>):beam:transform:pardo:v1\n  must 
follow: \n  downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_create_col2/Map(decode)_11\n  
create_col2/Map(decode):beam:transform:pardo:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'external_3_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/pair_with_col2_4\n
  
ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/pair_with_col2:beam:transform:pardo:v1\n
  must follow: \n  downstream_side_inputs: <unknown>', 
'external_3_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/pair_with_col1_5\n
  
ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/pair_with_col1:beam:transform:pardo:v1\n
  must follow: \n  downstream_side_inputs: <unknown>', 
'external_3_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/Flatten_6\n
  
ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/Flatten:beam:transform:flatten:v1\n
  must follow: \n  downstream_side_inputs: <unknown>', 
'external_3_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GroupByKey_7\n
  
ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GroupByKey:beam:transform:group_by_key:v1\n
  must follow: \n  downstream_side_inputs: <unknown>', 
'external_3_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/Map(_merge_tagged_vals_under_key)_11\n
  
ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n
  must follow: \n  downstream_side_inputs: <unknown>', 
'external_3_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:cgbk)/ParDo(ConcatFn)_12\n
  
ExternalTransform(beam:transforms:xlang:test:cgbk)/ParDo(ConcatFn):beam:transform:pardo:v1\n
  must follow: \n  downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_Map(<lambda at validate_runner_xlang_test.py:122>)_13\n  
Map(<lambda at validate_runner_xlang_test.py:122>):beam:transform:pardo:v1\n  
must follow: \n  downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_assert_that/Create/Impulse_16\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:2637>)_17\n  assert_that/Create/FlatMap(<lambda at 
core.py:2637>):beam:transform:pardo:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_assert_that/Create/Map(decode)_19\n  
assert_that/Create/Map(decode):beam:transform:pardo:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_20\n  
assert_that/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n  must 
follow: \n  downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_assert_that/ToVoidKey_21\n  
assert_that/ToVoidKey:beam:transform:pardo:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_assert_that/Group/pair_with_0_23\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_24\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_25\n  
assert_that/Group/Flatten:beam:transform:flatten:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_assert_that/Group/GroupByKey_26\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)_30\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_31\n  
assert_that/Unkey:beam:transform:pardo:v1\n  must follow: \n  
downstream_side_inputs: <unknown>', 
'ref_AppliedPTransform_assert_that/Match_32\n  
assert_that/Match:beam:transform:pardo:v1\n  must follow: \n  
downstream_side_inputs: <unknown>']
--------------------- >> end captured logging << ---------------------

======================================================================
ERROR: test_combine_globally 
(apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/validate_runner_xlang_test.py";,>
 line 136, in test_combine_globally
    TEST_COMGL_URN, None, ValidateRunnerXlangTest.expansion_service))
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pvalue.py";,>
 line 139, in __or__
    return self.pipeline.apply(ptransform, self)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 600, in apply
    pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 198, in apply
    return m(transform, input, options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 228, in apply_PTransform
    return transform.expand(input)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/external.py";,>
 line 325, in expand
    channel).Expand(request)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 826, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 729, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
_InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
        status = StatusCode.UNAVAILABLE
        details = "failed to connect to all addresses"
        debug_error_string = 
"{"created":"@1582623591.160395976","description":"Failed to pick 
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3941,"referenced_errors":[{"created":"@1582623591.160391348","description":"failed
 to connect to all 
addresses","file":"src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc","file_line":393,"grpc_status":14}]}"
>

======================================================================
ERROR: test_combine_per_key 
(apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/validate_runner_xlang_test.py";,>
 line 151, in test_combine_per_key
    TEST_COMPK_URN, None, ValidateRunnerXlangTest.expansion_service))
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pvalue.py";,>
 line 139, in __or__
    return self.pipeline.apply(ptransform, self)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 600, in apply
    pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 198, in apply
    return m(transform, input, options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 228, in apply_PTransform
    return transform.expand(input)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/external.py";,>
 line 325, in expand
    channel).Expand(request)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 826, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 729, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
_InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
        status = StatusCode.UNAVAILABLE
        details = "failed to connect to all addresses"
        debug_error_string = 
"{"created":"@1582623591.316150648","description":"Failed to pick 
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3941,"referenced_errors":[{"created":"@1582623591.316145872","description":"failed
 to connect to all 
addresses","file":"src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc","file_line":393,"grpc_status":14}]}"
>

======================================================================
ERROR: test_flatten 
(apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/validate_runner_xlang_test.py";,>
 line 167, in test_flatten
    ValidateRunnerXlangTest.expansion_service))
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/ptransform.py";,>
 line 553, in __ror__
    result = p.apply(self, pvalueish, label)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 600, in apply
    pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 198, in apply
    return m(transform, input, options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 228, in apply_PTransform
    return transform.expand(input)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/external.py";,>
 line 325, in expand
    channel).Expand(request)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 826, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 729, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
_InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
        status = StatusCode.UNAVAILABLE
        details = "failed to connect to all addresses"
        debug_error_string = 
"{"created":"@1582623591.509289848","description":"Failed to pick 
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3941,"referenced_errors":[{"created":"@1582623591.509285180","description":"failed
 to connect to all 
addresses","file":"src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc","file_line":393,"grpc_status":14}]}"
>

======================================================================
ERROR: test_group_by_key 
(apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/validate_runner_xlang_test.py";,>
 line 103, in test_group_by_key
    | beam.Map(lambda x: "{}:{}".format(x[0], ','.join(sorted(x[1])))))
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pvalue.py";,>
 line 139, in __or__
    return self.pipeline.apply(ptransform, self)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 600, in apply
    pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 198, in apply
    return m(transform, input, options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 228, in apply_PTransform
    return transform.expand(input)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/external.py";,>
 line 325, in expand
    channel).Expand(request)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 826, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 729, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
_InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
        status = StatusCode.UNAVAILABLE
        details = "failed to connect to all addresses"
        debug_error_string = 
"{"created":"@1582623591.550452269","description":"Failed to pick 
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3941,"referenced_errors":[{"created":"@1582623591.550447494","description":"failed
 to connect to all 
addresses","file":"src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc","file_line":393,"grpc_status":14}]}"
>

======================================================================
ERROR: test_multi_input_output_with_sideinput 
(apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/validate_runner_xlang_test.py";,>
 line 85, in test_multi_input_output_with_sideinput
    TEST_MULTI_URN, None, ValidateRunnerXlangTest.expansion_service)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/ptransform.py";,>
 line 553, in __ror__
    result = p.apply(self, pvalueish, label)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 600, in apply
    pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 198, in apply
    return m(transform, input, options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 228, in apply_PTransform
    return transform.expand(input)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/external.py";,>
 line 325, in expand
    channel).Expand(request)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 826, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 729, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
_InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
        status = StatusCode.UNAVAILABLE
        details = "failed to connect to all addresses"
        debug_error_string = 
"{"created":"@1582623591.638032877","description":"Failed to pick 
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3941,"referenced_errors":[{"created":"@1582623591.638026989","description":"failed
 to connect to all 
addresses","file":"src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc","file_line":393,"grpc_status":14}]}"
>

======================================================================
ERROR: test_partition 
(apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/validate_runner_xlang_test.py";,>
 line 183, in test_partition
    ValidateRunnerXlangTest.expansion_service))
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pvalue.py";,>
 line 139, in __or__
    return self.pipeline.apply(ptransform, self)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 600, in apply
    pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 198, in apply
    return m(transform, input, options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 228, in apply_PTransform
    return transform.expand(input)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/external.py";,>
 line 325, in expand
    channel).Expand(request)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 826, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 729, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
_InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
        status = StatusCode.UNAVAILABLE
        details = "failed to connect to all addresses"
        debug_error_string = 
"{"created":"@1582623591.738256240","description":"Failed to pick 
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3941,"referenced_errors":[{"created":"@1582623591.738249993","description":"failed
 to connect to all 
addresses","file":"src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc","file_line":393,"grpc_status":14}]}"
>

======================================================================
ERROR: test_prefix 
(apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/validate_runner_xlang_test.py";,>
 line 68, in test_prefix
    ValidateRunnerXlangTest.expansion_service))
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pvalue.py";,>
 line 139, in __or__
    return self.pipeline.apply(ptransform, self)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 600, in apply
    pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 198, in apply
    return m(transform, input, options)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/runners/runner.py";,>
 line 228, in apply_PTransform
    return transform.expand(input)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/apache_beam/transforms/external.py";,>
 line 325, in expand
    channel).Expand(request)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 826, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File 
"<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/grpc/_channel.py";,>
 line 729, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
_InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
        status = StatusCode.UNAVAILABLE
        details = "failed to connect to all addresses"
        debug_error_string = 
"{"created":"@1582623591.846620442","description":"Failed to pick 
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3941,"referenced_errors":[{"created":"@1582623591.846614514","description":"failed
 to connect to all 
addresses","file":"src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc","file_line":393,"grpc_status":14}]}"
>

----------------------------------------------------------------------
XML: nosetests-xlangValidateRunner.xml
----------------------------------------------------------------------
XML: 
<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/nosetests.xml>
----------------------------------------------------------------------
Ran 10 tests in 64.896s

FAILED (errors=8)

> Task 
> :runners:flink:1.9:job-server:validatesCrossLanguageRunnerPythonUsingPython 
> FAILED
> Task :runners:flink:1.9:job-server:validatesCrossLanguageRunnerCleanup
> Task :runners:flink:1.9:job-server:flinkJobServerCleanup

FAILURE: Build completed with 3 failures.

1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task 
':runners:flink:1.9:job-server:validatesCrossLanguageRunnerJavaUsingPython'.
> There were failing tests. See the report at: 
> file://<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/runners/flink/1.9/job-server/build/reports/tests/validatesCrossLanguageRunnerJavaUsingPython/index.html>

* 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 
':runners:flink:1.9:job-server: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.
==============================================================================

3: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task 
':runners:flink:1.9:job-server: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.
==============================================================================

* 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 22m 37s
113 actionable tasks: 86 executed, 25 from cache, 2 up-to-date

Publishing build scan...
https://gradle.com/s/j7bqcshfvgfik

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]

Reply via email to