You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2021/10/13 01:46:00 UTC
Build failed in Jenkins: beam_PostCommit_Python36 #4471
See <https://ci-beam.apache.org/job/beam_PostCommit_Python36/4471/display/redirect?page=changes>
Changes:
[cgray] [BEAM-7169] Fix singleton assertion in PAssert javadoc.
[noreply] Revert "[BEAM-10913] - Forcing update of YAML file by running kubectl
[kawaigin] [BEAM-12997] Upgraded labextension to V3
------------------------------------------
[...truncated 58.87 MB...]
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
apache_beam/io/gcp/bigquery.py:2109
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2109: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
experiments = p.options.view_as(DebugOptions).experiments or []
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
apache_beam/io/gcp/bigquery.py:2395
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2395: 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.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
apache_beam/io/gcp/bigquery.py:2397
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2397: 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.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
apache_beam/io/gcp/bigquery.py:2428
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2428: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
| _PassThroughThenCleanup(files_to_remove_pcoll))
apache_beam/dataframe/io.py:572
apache_beam/dataframe/io.py:572
apache_beam/dataframe/io.py:572
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/dataframe/io.py>:572: FutureWarning: WriteToFiles is experimental.
sink=lambda _: _WriteToPandasFileSink(
apache_beam/io/fileio.py:550
apache_beam/io/fileio.py:550
apache_beam/io/fileio.py:550
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/fileio.py>:550: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
p.options.view_as(GoogleCloudOptions).temp_location or
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
apache_beam/io/gcp/bigquery.py:2099
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2099: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
self.table_reference.projectId = pcoll.pipeline.options.view_as(
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
apache_beam/io/gcp/bigquery_file_loads.py:1112
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1112: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
temp_location = p.options.view_as(GoogleCloudOptions).temp_location
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
apache_beam/io/gcp/bigquery_file_loads.py:1114
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1114: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
p.options.view_as(GoogleCloudOptions).job_name or 'AUTOMATIC_JOB_NAME')
apache_beam/io/gcp/tests/utils.py:100
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:100: PendingDeprecationWarning: Client.dataset is deprecated and will be removed in a future version. Use a string like 'my_project.my_dataset' or a cloud.google.bigquery.DatasetReference object, instead.
table_ref = client.dataset(dataset_id).table(table_id)
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/build/gradleenv/-1734967053/lib/python3.6/site-packages/avro/schema.py>:1251
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/build/gradleenv/-1734967053/lib/python3.6/site-packages/avro/schema.py>:1251: DeprecationWarning: `Parse` is deprecated in avro 1.9.2. Please use `parse` (lowercase) instead.
DeprecationWarning)
apache_beam/io/gcp/bigquery_test.py:1124
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery_test.py>:1124: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
streaming = self.test_pipeline.options.view_as(StandardOptions).streaming
apache_beam/ml/gcp/cloud_dlp_it_test.py:77
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/ml/gcp/cloud_dlp_it_test.py>:77: FutureWarning: MaskDetectedDetails is experimental.
inspection_config=INSPECT_CONFIG))
apache_beam/io/gcp/bigquery_read_it_test.py:167
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py>:167: BeamDeprecationWarning: BigQuerySource is deprecated since 2.25.0. Use ReadFromBigQuery instead.
beam.io.BigQuerySource(query=self.query, use_standard_sql=True)))
apache_beam/ml/gcp/cloud_dlp_it_test.py:87
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/ml/gcp/cloud_dlp_it_test.py>:87: FutureWarning: InspectForDetails is experimental.
| beam.ParDo(extract_inspection_results).with_outputs(
apache_beam/io/gcp/big_query_query_to_table_pipeline.py:84
apache_beam/io/gcp/big_query_query_to_table_pipeline.py:84
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/big_query_query_to_table_pipeline.py>:84: BeamDeprecationWarning: BigQuerySource is deprecated since 2.25.0. Use ReadFromBigQuery instead.
kms_key=kms_key))
apache_beam/runners/dataflow/ptransform_overrides.py:323
apache_beam/runners/dataflow/ptransform_overrides.py:323
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/runners/dataflow/ptransform_overrides.py>:323: BeamDeprecationWarning: BigQuerySink is deprecated since 2.11.0. Use WriteToBigQuery instead.
kms_key=self.kms_key))
apache_beam/io/gcp/bigquery_read_it_test.py:556
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py>:556: BeamDeprecationWarning: BigQuerySource is deprecated since 2.25.0. Use ReadFromBigQuery instead.
beam.io.BigQuerySource(query=self.query, use_standard_sql=True)))
apache_beam/io/gcp/experimental/spannerio_write_it_test.py:181
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/experimental/spannerio_write_it_test.py>:181: FutureWarning: WriteToSpanner is experimental. No backwards-compatibility guarantees.
database_id=self.TEST_DATABASE))
apache_beam/io/gcp/bigquery_read_it_test.py:670
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery_read_it_test.py>:670: FutureWarning: ReadAllFromBigQuery is experimental.
| beam.io.ReadAllFromBigQuery())
apache_beam/io/gcp/bigquery.py:2569
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2569: 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.py:2570
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2570: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
project = pcoll.pipeline.options.view_as(GoogleCloudOptions).project
apache_beam/io/gcp/bigquery.py:2583
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2583: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported
options=pcoll.pipeline.options,
apache_beam/io/gcp/experimental/spannerio_write_it_test.py:162
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/experimental/spannerio_write_it_test.py>:162: FutureWarning: WriteToSpanner is experimental. No backwards-compatibility guarantees.
database_id=self.TEST_DATABASE))
apache_beam/io/gcp/experimental/spannerio_write_it_test.py:126
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/experimental/spannerio_write_it_test.py>:126: FutureWarning: WriteToSpanner is experimental. No backwards-compatibility guarantees.
max_batch_size_bytes=250))
apache_beam/io/gcp/experimental/spannerio_read_it_test.py:124
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/experimental/spannerio_read_it_test.py>:124: FutureWarning: ReadFromSpanner is experimental. No backwards-compatibility guarantees.
sql="select * from Users")
apache_beam/io/gcp/experimental/spannerio_read_it_test.py:113
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/apache_beam/io/gcp/experimental/spannerio_read_it_test.py>:113: FutureWarning: ReadFromSpanner is experimental. No backwards-compatibility guarantees.
columns=["UserId", "Key"])
-- Docs: https://docs.pytest.org/en/latest/warnings.html
- generated xml file: <https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/pytest_postCommitIT-df-py36.xml> -
[33m[1m============ 63 passed, 11 skipped, 176 warnings in 5841.49 seconds ============[0m
FAILURE: Build failed with an exception.
* Where:
Script '<https://ci-beam.apache.org/job/beam_PostCommit_Python36/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 225
* What went wrong:
Execution failed for task ':sdks:python:test-suites:portable:py36:postCommitPy36IT'.
> 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.9.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 1h 45m 23s
211 actionable tasks: 148 executed, 59 from cache, 4 up-to-date
Publishing build scan...
https://gradle.com/s/v23rstlkqh4ug
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Python36 #4473
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python36/4473/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python36 #4472
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python36/4472/display/redirect?page=changes>
Changes:
[noreply] [BEAM-12513] Add JIRAs for missing Go SDK features (#15658)
------------------------------------------
[...truncated 49.97 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (11/16)#0 (4666925a07c6d2cb73e66f6625cebc11) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (1/16)#0 (85b3f50ab37710babd37987ebb2d5af6) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (10/16)#0 (1571f476db0a3c673650ddbee7112c9e) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (7/16)#0 (147611443e701a11e6ff08f3a196ce1f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (6/16)#0 (047189b4ea653cd3a83892c1616f323b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (3/16)#0 (54747b22422b6b00ed1aa23e9c174c2e) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (7/16)#0 (37b7a050318450420f0cf7fefd9b1c14) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (2/16)#0 (a68b82a589fe0475650faafdac8d98c5) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [1]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0 -> [5]{Read from debezium, assert_that} (15/16)#0 (106bf8bed3b7c4bca719208094f94258) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (11/16)#0 (77c860a0bc47f2f3f7fd08a75c105343) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (16/16)#0 (27d24936e58436dcd0d2e11e2a82ee6b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [1]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0 -> [5]{Read from debezium, assert_that} (4/16) (c511a33a22571f3d93264e313ebe747d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (6/16)#0 (c90c9529f6f76d5042aa1fc65df3a807) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (6/16)#0 (c90c9529f6f76d5042aa1fc65df3a807).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (12/16) (d92bded42c829b89e70f366c0a0f6635) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (13/16) (15ff237036c78e0edfce8600fb191394) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (6/16)#0 c90c9529f6f76d5042aa1fc65df3a807.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (9/16) (27db10c513343ff88938a2290d6db213) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (11/16) (4666925a07c6d2cb73e66f6625cebc11) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (1/16) (85b3f50ab37710babd37987ebb2d5af6) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (10/16) (1571f476db0a3c673650ddbee7112c9e) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (7/16) (147611443e701a11e6ff08f3a196ce1f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (6/16) (047189b4ea653cd3a83892c1616f323b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (8/16)#0 (f599df7f94217d8103d93ae11f4f04eb) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (3/16) (54747b22422b6b00ed1aa23e9c174c2e) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (7/16) (37b7a050318450420f0cf7fefd9b1c14) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (2/16) (a68b82a589fe0475650faafdac8d98c5) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [1]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0 -> [5]{Read from debezium, assert_that} (15/16) (106bf8bed3b7c4bca719208094f94258) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (11/16) (77c860a0bc47f2f3f7fd08a75c105343) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (16/16) (27d24936e58436dcd0d2e11e2a82ee6b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (8/16) (f599df7f94217d8103d93ae11f4f04eb) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (14/16)#0 (519225d90595101d3c4b612e0f41ed7f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (15/16)#0 (4e6450fd0899a416369f4ef8f85fb0c6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (1/16)#0 (d2e8400b5644ab6640d92116eed1a3ef) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (15/16)#0 (4e6450fd0899a416369f4ef8f85fb0c6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (15/16)#0 4e6450fd0899a416369f4ef8f85fb0c6.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (5/16)#0 (dadd62ad3a891edd3f6f3ad1a9281eb2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (6/16) (c90c9529f6f76d5042aa1fc65df3a807) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (14/16) (519225d90595101d3c4b612e0f41ed7f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (1/16) (d2e8400b5644ab6640d92116eed1a3ef) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (5/16) (dadd62ad3a891edd3f6f3ad1a9281eb2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (15/16) (4e6450fd0899a416369f4ef8f85fb0c6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (3/16)#0 (1df745377986c5daf512887c1859e915) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (3/16) (1df745377986c5daf512887c1859e915) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (5/16)#0 (dadd62ad3a891edd3f6f3ad1a9281eb2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (5/16)#0 (dadd62ad3a891edd3f6f3ad1a9281eb2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (13/16)#0 (15ff237036c78e0edfce8600fb191394) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (13/16)#0 (15ff237036c78e0edfce8600fb191394).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (5/16)#0 dadd62ad3a891edd3f6f3ad1a9281eb2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (1/16)#0 (d2e8400b5644ab6640d92116eed1a3ef) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (10/16)#0 (99b31e2d0bb492fd71756494c0b4319c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (10/16)#0 (99b31e2d0bb492fd71756494c0b4319c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (8/16)#0 (e31460cbe48d73bfb72d86a8ee6c1b59) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (13/16)#0 15ff237036c78e0edfce8600fb191394.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (8/16)#0 (e31460cbe48d73bfb72d86a8ee6c1b59).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (5/16) (dadd62ad3a891edd3f6f3ad1a9281eb2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (1/16)#0 (d2e8400b5644ab6640d92116eed1a3ef).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (10/16)#0 99b31e2d0bb492fd71756494c0b4319c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (13/16) (15ff237036c78e0edfce8600fb191394) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: getProcessBundleDescriptor request with id 1-85'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (9/16)#0 (3e1ca4c4316adb7613a182421ced45a1) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (9/16) (3e1ca4c4316adb7613a182421ced45a1) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (16/16)#0 (27d24936e58436dcd0d2e11e2a82ee6b) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (16/16)#0 (27d24936e58436dcd0d2e11e2a82ee6b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (3/16)#0 (54747b22422b6b00ed1aa23e9c174c2e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (2/16)#0 (138478a5602715b7ed4dd1de6181e79c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (3/16)#0 (54747b22422b6b00ed1aa23e9c174c2e).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (2/16)#0 (138478a5602715b7ed4dd1de6181e79c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (12/16)#0 (d92bded42c829b89e70f366c0a0f6635) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (12/16)#0 (d92bded42c829b89e70f366c0a0f6635).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (4/16)#0 (8d15b091f3eb0f7562a9c7ffb22f8027) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (4/16)#0 (8d15b091f3eb0f7562a9c7ffb22f8027).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (14/16)#0 (8301419cad8602a7af9eb880972c70eb) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (14/16)#0 (8301419cad8602a7af9eb880972c70eb).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (8/16)#0 e31460cbe48d73bfb72d86a8ee6c1b59.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (7/16)#0 (37b7a050318450420f0cf7fefd9b1c14) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (7/16)#0 (37b7a050318450420f0cf7fefd9b1c14).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (10/16) (99b31e2d0bb492fd71756494c0b4319c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (1/16)#0 d2e8400b5644ab6640d92116eed1a3ef.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (16/16)#0 27d24936e58436dcd0d2e11e2a82ee6b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (9/16)#0 (27db10c513343ff88938a2290d6db213) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (8/16) (e31460cbe48d73bfb72d86a8ee6c1b59) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (9/16)#0 (27db10c513343ff88938a2290d6db213).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (3/16)#0 54747b22422b6b00ed1aa23e9c174c2e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (2/16)#0 138478a5602715b7ed4dd1de6181e79c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (1/16) (d2e8400b5644ab6640d92116eed1a3ef) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (12/16)#0 d92bded42c829b89e70f366c0a0f6635.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (4/16)#0 8d15b091f3eb0f7562a9c7ffb22f8027.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (16/16) (27d24936e58436dcd0d2e11e2a82ee6b) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (14/16)#0 8301419cad8602a7af9eb880972c70eb.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (3/16) (54747b22422b6b00ed1aa23e9c174c2e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (7/16)#0 37b7a050318450420f0cf7fefd9b1c14.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (9/16)#0 27db10c513343ff88938a2290d6db213.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (2/16) (138478a5602715b7ed4dd1de6181e79c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (12/16) (d92bded42c829b89e70f366c0a0f6635) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (4/16) (8d15b091f3eb0f7562a9c7ffb22f8027) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (14/16) (8301419cad8602a7af9eb880972c70eb) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (7/16) (37b7a050318450420f0cf7fefd9b1c14) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:21 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (9/16) (27db10c513343ff88938a2290d6db213) switched from RUNNING to FINISHED.'
> Task :sdks:python:test-suites:dataflow:py36:postCommitIT
[gw0] [32mPASSED[0m apache_beam/examples/fastavro_it_test.py::FastavroIT::test_avro_it
apache_beam/examples/complete/game/user_score_it_test.py::UserScoreIT::test_user_score_it
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.beam.runners.fnexecution.data.GrpcDataService data'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Beam Fn Data client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: getProcessBundleDescriptor request with id 1-79'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (4/16)#0 (49267bc12f2c0a015096afd336e30fed) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (4/16)#0 (49267bc12f2c0a015096afd336e30fed).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (8/16)#0 (f599df7f94217d8103d93ae11f4f04eb) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (8/16)#0 (f599df7f94217d8103d93ae11f4f04eb).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (4/16)#0 49267bc12f2c0a015096afd336e30fed.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (6/16)#0 (047189b4ea653cd3a83892c1616f323b) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (6/16)#0 (047189b4ea653cd3a83892c1616f323b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (8/16)#0 f599df7f94217d8103d93ae11f4f04eb.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (6/16)#0 047189b4ea653cd3a83892c1616f323b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (4/16) (49267bc12f2c0a015096afd336e30fed) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (9/16)#0 (3e1ca4c4316adb7613a182421ced45a1) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (8/16) (f599df7f94217d8103d93ae11f4f04eb) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (11/16)#0 (4666925a07c6d2cb73e66f6625cebc11) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource), ParDo(BoundedSourceAsSDFWrapper)} (11/16)#0 (4666925a07c6d2cb73e66f6625cebc11).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (10/16)#0 (1571f476db0a3c673650ddbee7112c9e) switched from RUNNING to FINISHED.'
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.beam.runners.fnexecution.data.GrpcDataService data'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Beam Fn Data client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: getProcessBundleDescriptor request with id 1-79'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: [3]Read from debezium/ExternalTransform(beam:external:java:debezium:read:v1)/{Create.Values, ParDo(KafkaSourceConsumer)} (4/16)#0 (49267bc12f2c0a015096afd336e30fed) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13, 2021 6:27:22 AM org.apache.flink.runtime.taskmanager.Task doRun'
java.lang.OutOfMemoryError: GC overhead limit exceeded
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org