See
<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/2453/display/redirect?page=changes>
Changes:
[github] [BEAM-9443] update document about direct_num_workers=0 for FnApi
------------------------------------------
[...truncated 1.41 MB...]
INFO:apache_beam.utils.subprocess_server:SELECT `PCOLLECTION`.`int`,
`PCOLLECTION`.`str`, `PCOLLECTION`.`flt`
INFO:apache_beam.utils.subprocess_server:FROM `beam`.`PCOLLECTION` AS
`PCOLLECTION`
INFO:apache_beam.utils.subprocess_server:WHERE `PCOLLECTION`.`str` = 'bar'
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:49:57 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO:apache_beam.utils.subprocess_server:INFO: SQLPlan>
INFO:apache_beam.utils.subprocess_server:LogicalProject(int=[$0], str=[$1],
flt=[$2])
INFO:apache_beam.utils.subprocess_server: LogicalFilter(condition=[=($1,
'bar')])
INFO:apache_beam.utils.subprocess_server: BeamIOSourceRel(table=[[beam,
PCOLLECTION]])
INFO:apache_beam.utils.subprocess_server:
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:49:57 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO:apache_beam.utils.subprocess_server:INFO: BEAMPlan>
INFO:apache_beam.utils.subprocess_server:BeamCalcRel(expr#0..2=[{inputs}],
expr#3=['bar':VARCHAR], expr#4=[=($t1, $t3)], proj#0..2=[{exprs}],
$condition=[$t4])
INFO:apache_beam.utils.subprocess_server: BeamIOSourceRel(table=[[beam,
PCOLLECTION]])
INFO:apache_beam.utils.subprocess_server:
DEBUG:root:Sending SIGINT to job_server
WARNING:root:Make sure that locally built Python SDK docker image has Python
2.7 interpreter.
INFO:root:Using Python SDK docker image: apache/beam_python2.7_sdk:2.22.0.dev.
If the image is not available at local, we will try to pull from hub.docker.com
WARNING:root:Make sure that locally built Python SDK docker image has Python
2.7 interpreter.
INFO:root:Using Python SDK docker image: apache/beam_python2.7_sdk:2.22.0.dev.
If the image is not available at local, we will try to pull from hub.docker.com
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f4c7cb37ed8> ====================
DEBUG:apache_beam.runners.portability.fn_api_runner.translations:22 [1, 1, 1,
1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1]
DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages:
['ref_AppliedPTransform_Create/Impulse_3\n
Create/Impulse:beam:transform:impulse:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2714>)_4\n
Create/FlatMap(<lambda at core.py:2714>):beam:transform:pardo:v1\n must
follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/AddRandomKeys_7\n
Create/MaybeReshuffle/Reshuffle/AddRandomKeys:beam:transform:pardo:v1\n must
follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)_9\n
Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey_10\n
Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey:beam:transform:group_by_key:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)_14\n
Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys_15\n
Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys:beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/Map(decode)_16\n
Create/Map(decode):beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'external_2SqlTransform(beam:external:java:sql:v1)/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous)\n
SqlTransform(beam:external:java:sql:v1)/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'external_2SqlTransform(beam:external:java:sql:v1)/BeamCalcRel_30/ParDo(Calc)/ParMultiDo(Calc)\n
SqlTransform(beam:external:java:sql:v1)/BeamCalcRel_30/ParDo(Calc)/ParMultiDo(Calc):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Create/Impulse_20\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:2714>)_21\n assert_that/Create/FlatMap(<lambda at
core.py:2714>):beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Create/Map(decode)_23\n
assert_that/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_24\n
assert_that/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must
follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/ToVoidKey_25\n
assert_that/ToVoidKey:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/pair_with_0_27\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_28\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_29\n
assert_that/Group/Flatten:beam:transform:flatten:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/GroupByKey_30\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)_34\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_35\n
assert_that/Unkey:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Match_36\n
assert_that/Match:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>']
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'dataflow_kms_key' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'enable_streaming_engine' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'project'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_region' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_zone' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'zone' was
already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'job_name'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'runner'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'temp_location' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'streaming'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'experiments' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'flink_master' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'pubsub_root_url' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'environment_cache_millis' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'files_to_stage' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'job_endpoint' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'output_executable_path' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'sdk_worker_parallelism' was already added
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
RUNNING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
ok
test_generate_data (apache_beam.transforms.sql_test.SqlTransformTest) ...
INFO:apache_beam.utils.subprocess_server:Using pre-built snapshot at
<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.22.0-SNAPSHOT.jar>
INFO:apache_beam.utils.subprocess_server:Using pre-built snapshot at
<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.22.0-SNAPSHOT.jar>
INFO:apache_beam.utils.subprocess_server:Starting service with ['java' '-jar'
'<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.22.0-SNAPSHOT.jar'>
'46079']
DEBUG:root:Waiting for grpc channel to be ready at localhost:46079.
DEBUG:root:Waiting for grpc channel to be ready at localhost:46079.
INFO:apache_beam.utils.subprocess_server:Starting expansion service at
localhost:46079
DEBUG:root:Waiting for grpc channel to be ready at localhost:46079.
INFO:apache_beam.utils.subprocess_server: beam:external:java:sql:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$1/598446861@deb6432
INFO:apache_beam.utils.subprocess_server:
beam:external:java:generate_sequence:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$1/598446861@28ba21f3
DEBUG:root:Waiting for grpc channel to be ready at localhost:46079.
DEBUG:root:Waiting for grpc channel to be ready at localhost:46079.
DEBUG:root:Waiting for grpc channel to be ready at localhost:46079.
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:50:29 PM
org.apache.beam.sdk.expansion.service.ExpansionService expand
INFO:apache_beam.utils.subprocess_server:INFO: Expanding
'SqlTransform(beam:external:java:sql:v1)' with URN 'beam:external:java:sql:v1'
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:50:31 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO:apache_beam.utils.subprocess_server:INFO: SQL:
INFO:apache_beam.utils.subprocess_server:SELECT CAST(1 AS INTEGER) AS `int`,
CAST('foo' AS VARCHAR) AS `str`, CAST(3.14 AS DOUBLE) AS `flt`
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:50:32 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO:apache_beam.utils.subprocess_server:INFO: SQLPlan>
INFO:apache_beam.utils.subprocess_server:LogicalProject(int=[1],
str=['foo':VARCHAR], flt=[3.14:DOUBLE])
INFO:apache_beam.utils.subprocess_server: LogicalValues(tuples=[[{ 0 }]])
INFO:apache_beam.utils.subprocess_server:
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:50:32 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO:apache_beam.utils.subprocess_server:INFO: BEAMPlan>
INFO:apache_beam.utils.subprocess_server:BeamCalcRel(expr#0=[{inputs}],
expr#1=[1], expr#2=['foo':VARCHAR], expr#3=[3.14:DOUBLE], int=[$t1], str=[$t2],
flt=[$t3])
INFO:apache_beam.utils.subprocess_server: BeamValuesRel(tuples=[[{ 0 }]])
INFO:apache_beam.utils.subprocess_server:
DEBUG:root:Sending SIGINT to job_server
WARNING:root:Make sure that locally built Python SDK docker image has Python
2.7 interpreter.
INFO:root:Using Python SDK docker image: apache/beam_python2.7_sdk:2.22.0.dev.
If the image is not available at local, we will try to pull from hub.docker.com
WARNING:root:Make sure that locally built Python SDK docker image has Python
2.7 interpreter.
INFO:root:Using Python SDK docker image: apache/beam_python2.7_sdk:2.22.0.dev.
If the image is not available at local, we will try to pull from hub.docker.com
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f4c7cb37ed8> ====================
DEBUG:apache_beam.runners.portability.fn_api_runner.translations:16 [1, 1, 1,
1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1]
DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages:
['external_3SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_15/Create.Values/Read(CreateSource)/Impulse\n
SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_15/Create.Values/Read(CreateSource)/Impulse:beam:transform:impulse:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'external_3SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_15/Create.Values/Read(CreateSource)/MapElements/Map/ParMultiDo(Anonymous)\n
SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_15/Create.Values/Read(CreateSource)/MapElements/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'external_3SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_15/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)\n
SqlTransform(beam:external:java:sql:v1)/BeamValuesRel_15/Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'external_3SqlTransform(beam:external:java:sql:v1)/BeamCalcRel_19/ParDo(Calc)/ParMultiDo(Calc)\n
SqlTransform(beam:external:java:sql:v1)/BeamCalcRel_19/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:2714>)_6\n
assert_that/Create/FlatMap(<lambda at core.py:2714>):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)_19\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_20\n
assert_that/Unkey:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Match_21\n
assert_that/Match:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>']
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'dataflow_kms_key' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'enable_streaming_engine' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'project'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_region' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_zone' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'zone' was
already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'job_name'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'runner'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'temp_location' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'streaming'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'experiments' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'flink_master' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'pubsub_root_url' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'environment_cache_millis' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'files_to_stage' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'job_endpoint' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'output_executable_path' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'sdk_worker_parallelism' was already added
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
RUNNING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
ok
test_project (apache_beam.transforms.sql_test.SqlTransformTest) ...
INFO:apache_beam.utils.subprocess_server:Using pre-built snapshot at
<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.22.0-SNAPSHOT.jar>
INFO:apache_beam.utils.subprocess_server:Using pre-built snapshot at
<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.22.0-SNAPSHOT.jar>
INFO:apache_beam.utils.subprocess_server:Starting service with ['java' '-jar'
'<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.22.0-SNAPSHOT.jar'>
'36553']
DEBUG:root:Waiting for grpc channel to be ready at localhost:36553.
INFO:apache_beam.utils.subprocess_server:Starting expansion service at
localhost:36553
DEBUG:root:Waiting for grpc channel to be ready at localhost:36553.
INFO:apache_beam.utils.subprocess_server: beam:external:java:sql:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$1/598446861@deb6432
INFO:apache_beam.utils.subprocess_server:
beam:external:java:generate_sequence:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$1/598446861@28ba21f3
DEBUG:root:Waiting for grpc channel to be ready at localhost:36553.
DEBUG:root:Waiting for grpc channel to be ready at localhost:36553.
DEBUG:root:Waiting for grpc channel to be ready at localhost:36553.
DEBUG:root:Waiting for grpc channel to be ready at localhost:36553.
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:51:06 PM
org.apache.beam.sdk.expansion.service.ExpansionService expand
INFO:apache_beam.utils.subprocess_server:INFO: Expanding
'SqlTransform(beam:external:java:sql:v1)' with URN 'beam:external:java:sql:v1'
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:51:08 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO:apache_beam.utils.subprocess_server:INFO: SQL:
INFO:apache_beam.utils.subprocess_server:SELECT `PCOLLECTION`.`int`,
`PCOLLECTION`.`flt`
INFO:apache_beam.utils.subprocess_server:FROM `beam`.`PCOLLECTION` AS
`PCOLLECTION`
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:51:08 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO:apache_beam.utils.subprocess_server:INFO: SQLPlan>
INFO:apache_beam.utils.subprocess_server:LogicalProject(int=[$0], flt=[$2])
INFO:apache_beam.utils.subprocess_server: BeamIOSourceRel(table=[[beam,
PCOLLECTION]])
INFO:apache_beam.utils.subprocess_server:
INFO:apache_beam.utils.subprocess_server:Apr 28, 2020 5:51:08 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel
INFO:apache_beam.utils.subprocess_server:INFO: BEAMPlan>
INFO:apache_beam.utils.subprocess_server:BeamCalcRel(expr#0..2=[{inputs}],
int=[$t0], flt=[$t2])
INFO:apache_beam.utils.subprocess_server: BeamIOSourceRel(table=[[beam,
PCOLLECTION]])
INFO:apache_beam.utils.subprocess_server:
DEBUG:root:Sending SIGINT to job_server
WARNING:root:Make sure that locally built Python SDK docker image has Python
2.7 interpreter.
INFO:root:Using Python SDK docker image: apache/beam_python2.7_sdk:2.22.0.dev.
If the image is not available at local, we will try to pull from hub.docker.com
WARNING:root:Make sure that locally built Python SDK docker image has Python
2.7 interpreter.
INFO:root:Using Python SDK docker image: apache/beam_python2.7_sdk:2.22.0.dev.
If the image is not available at local, we will try to pull from hub.docker.com
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f4c7cb37ed8> ====================
DEBUG:apache_beam.runners.portability.fn_api_runner.translations:17 [1, 1, 1,
1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1]
DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages:
['ref_AppliedPTransform_Create/Impulse_3\n
Create/Impulse:beam:transform:impulse:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2714>)_4\n
Create/FlatMap(<lambda at core.py:2714>):beam:transform:pardo:v1\n must
follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_Create/Map(decode)_6\n
Create/Map(decode):beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'external_4SqlTransform(beam:external:java:sql:v1)/BeamIOSourceRel_2/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous)\n
SqlTransform(beam:external:java:sql:v1)/BeamIOSourceRel_2/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'external_4SqlTransform(beam:external:java:sql:v1)/BeamCalcRel_18/ParDo(Calc)/ParMultiDo(Calc)\n
SqlTransform(beam:external:java:sql:v1)/BeamCalcRel_18/ParDo(Calc)/ParMultiDo(Calc):beam:transform:pardo:v1\n
must follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Create/Impulse_10\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:2714>)_11\n assert_that/Create/FlatMap(<lambda at
core.py:2714>):beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Create/Map(decode)_13\n
assert_that/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_14\n
assert_that/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must
follow: \n downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/ToVoidKey_15\n
assert_that/ToVoidKey:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/pair_with_0_17\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_18\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_19\n
assert_that/Group/Flatten:beam:transform:flatten:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Group/GroupByKey_20\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)_24\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_25\n
assert_that/Unkey:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>',
'ref_AppliedPTransform_assert_that/Match_26\n
assert_that/Match:beam:transform:pardo:v1\n must follow: \n
downstream_side_inputs: <unknown>']
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'dataflow_kms_key' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'enable_streaming_engine' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'project'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_region' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_zone' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'zone' was
already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'job_name'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'runner'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'temp_location' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'streaming'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'experiments' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'flink_master' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'pubsub_root_url' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'environment_cache_millis' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'files_to_stage' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'job_endpoint' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'output_executable_path' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'sdk_worker_parallelism' was already added
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
RUNNING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
ok
----------------------------------------------------------------------
XML: nosetests-xlangSqlValidateRunner.xml
----------------------------------------------------------------------
XML:
<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/ws/src/sdks/python/nosetests.xml>
----------------------------------------------------------------------
Ran 5 tests in 178.888s
OK
> Task :runners:flink:1.10:job-server:flinkJobServerCleanup
Stopping job server pid: 25566.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':runners:flink:1.10: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 21m 47s
135 actionable tasks: 32 executed, 103 up-to-date
Publishing build scan...
https://gradle.com/s/uv52zjwh5srks
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]
