See
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/1654/display/redirect?page=changes>
Changes:
[heejong] [BEAM-12838] Update artifact local path for DataflowRunner Java
[Valentyn Tymofieiev] Disable Kafka perf tests.
[heejong] separate into resolveArtifacts method
[heejong] add test
[Andrew Pilloud] [BEAM-12850] Calcite drops empty Calc now
[Andrew Pilloud] [BEAM-12853] VALUES produces a UNION, window can't be set
afterwards
[Andrew Pilloud] [BEAM-12852] Revert BigTable changes, just cast to bigint
[heejong] update
[heejong] fix formatting
[Andrew Pilloud] [BEAM-12851] Map output table names
[Luke Cwik] [BEAM-12802] Define a prefetchable iterator and iterable and utility
------------------------------------------
[...truncated 24.33 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "fn/write/ref_PCollection_PCollection_10:1:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM":
"ref_AppliedPTransform_assert_that-Create-FlatMap-lambda-at-core-py-2965-_8"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_3:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Group-_CoGBKImpl-Flatten_17"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Create-Map-decode-_10"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Group-_CoGBKImpl-Flatten_17"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Create-Map-decode-_10"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Group-_CoGBKImpl-Flatten_17"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_3:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_3:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Group-_CoGBKImpl-Tag-0-_15"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_3:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "ref_AppliedPTransform_assert_that-Group-_CoGBKImpl-Tag-0-_15"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:element_count:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PCOLLECTION": "ref_PCollection_PCollection_5"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "fn/write/ref_PCollection_PCollection_10:1:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "fn/write/ref_PCollection_PCollection_10:1:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:data_channel:read_index:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_3:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:element_count:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PCOLLECTION": "ref_PCollection_PCollection_4"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:element_count:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PCOLLECTION": "ref_PCollection_PCollection_3"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AQ0NDQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PCOLLECTION": "ref_PCollection_PCollection_3"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "ARQUFA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PCOLLECTION": "ref_PCollection_PCollection_10:1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AQ8PDw==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PCOLLECTION": "ref_PCollection_PCollection_5"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AQ8PDw==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PCOLLECTION": "ref_PCollection_PCollection_4"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"payload": "AREREQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'
"PCOLLECTION": "ref_PCollection_PCollection_8"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'}'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.resourcemanager.ResourceManager
deregisterApplication'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Shut down cluster because application is in CANCELED, diagnostics
DispatcherResourceManagerComponent has been closed..'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
closeAsyncInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Closing components.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess
closeInternal'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopping SessionDispatcherLeaderProcess.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.dispatcher.Dispatcher onStop'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopping dispatcher akka://flink/user/rpc/dispatcher_2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.dispatcher.Dispatcher
terminateRunningJobs'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopping all currently running jobs of dispatcher
akka://flink/user/rpc/dispatcher_2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.dispatcher.Dispatcher lambda$onStop$0'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopped dispatcher akka://flink/user/rpc/dispatcher_2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Closing the slot manager.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
suspend'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Suspending the slot manager.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopping Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopping Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopped Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Shutting down BLOB cache'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Shutting down BLOB cache'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.blob.BlobServer close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopped BLOB server at 0.0.0.0:33575'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Sep 08,
2021 12:43:40 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Stopped Akka RPC service.'
INFO apache_beam.runners.portability.portable_runner:portable_runner.py:574
Job state changed to DONE
PASSED [100%]
=============================== warnings summary ===============================
apache_beam/io/gcp/bigquery_read_it_test.py::ReadTests::test_iobase_source
apache_beam/io/gcp/bigquery_read_it_test.py::ReadNewTypesTests::test_iobase_source
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:1935:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
temp_location = pcoll.pipeline.options.view_as(
apache_beam/io/gcp/bigquery_read_it_test.py::ReadTests::test_iobase_source
apache_beam/io/gcp/bigquery_read_it_test.py::ReadNewTypesTests::test_iobase_source
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:1937:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
job_name = pcoll.pipeline.options.view_as(GoogleCloudOptions).job_name
apache_beam/io/gcp/bigquery_read_it_test.py::ReadTests::test_iobase_source
apache_beam/io/gcp/bigquery_read_it_test.py::ReadNewTypesTests::test_iobase_source
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:1961:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
pipeline_options=pcoll.pipeline.options,
-- Docs: https://docs.pytest.org/en/latest/warnings.html
- generated xml file:
<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/pytest_postCommitIT-flink-py38.xml>
-
============= 14 passed, 4 skipped, 6 warnings in 1559.89 seconds ==============
> Task :sdks:python:test-suites:portable:py38:postCommitPy38
> Task :sdks:python:test-suites:dataflow:py38:postCommitIT FAILED
FAILURE: Build failed with an exception.
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python38/ws/src/sdks/python/test-suites/dataflow/common.gradle'>
line: 120
* What went wrong:
Execution failed for task ':sdks:python:test-suites:dataflow:py38:postCommitIT'.
> 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 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/6.8.3/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 51m 22s
212 actionable tasks: 176 executed, 32 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/vaypkmpm7v7vo
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]
