See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/4486/display/redirect>
Changes:
------------------------------------------
[...truncated 52.02 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Finished to build heap keyed state-backend.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend
<init>'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Initializing heap keyed state backend with stream factory.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder restoreState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Finished to build heap keyed state-backend.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend
<init>'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Initializing heap keyed state backend with stream factory.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder restoreState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Finished to build heap keyed state-backend.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend
<init>'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Initializing heap keyed state backend with stream factory.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (10/16)#0 (e0502605ee102309d75cfebd7e75950d)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (9/16)#0 (c09c4ec7f58f96ca4c3dab1a986cda76)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder restoreState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Finished to build heap keyed state-backend.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (10/16) (e0502605ee102309d75cfebd7e75950d)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend
<init>'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Initializing heap keyed state backend with stream factory.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (9/16) (c09c4ec7f58f96ca4c3dab1a986cda76)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder restoreState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Finished to build heap keyed state-backend.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder restoreState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Finished to build heap keyed state-backend.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder restoreState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Finished to build heap keyed state-backend.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend
<init>'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Initializing heap keyed state backend with stream factory.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend
<init>'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Initializing heap keyed state backend with stream factory.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.state.heap.HeapKeyedStateBackend
<init>'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Initializing heap keyed state backend with stream factory.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (12/16)#0 (1180f4d028a218d185c83dedccf46b39)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (12/16) (1180f4d028a218d185c83dedccf46b39)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (12/16)#0 (175376edd63d9da418a0786b00e812e4) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (12/16) (175376edd63d9da418a0786b00e812e4) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (15/16)#0 (7443b9d7ccb94c13fdf3e0fbf59a6cba)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (4/16)#0 (5817940449f6d37336aba7d65513cd9c)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (15/16) (7443b9d7ccb94c13fdf3e0fbf59a6cba)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (5/16)#0 (c9fda16c549373e543730c39aadcadb7) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (4/16) (5817940449f6d37336aba7d65513cd9c)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (5/16) (c9fda16c549373e543730c39aadcadb7) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (16/16)#0 (0a95a4728e04ed772c24d754e71b1b00)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (14/16)#0 (96ad79d6c95cc5221767b0f6d2a63aec) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (14/16) (96ad79d6c95cc5221767b0f6d2a63aec) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (16/16) (0a95a4728e04ed772c24d754e71b1b00)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (13/16)#0 (476bec47cf617a4bed230a1da57c856a) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (13/16) (476bec47cf617a4bed230a1da57c856a) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (8/16)#0 (ac08167e6f12a3a7489b264d8a16379b)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (8/16) (ac08167e6f12a3a7489b264d8a16379b)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (7/16)#0 (a7d464c7beab54cd7a63e1f686037871) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (7/16) (a7d464c7beab54cd7a63e1f686037871) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (6/16)#0 (fb9ee0108478b41df1a37591f35a104d) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (16/16)#0 (4a56f41b560d8eda0842c4b8e74915d4) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (6/16) (fb9ee0108478b41df1a37591f35a104d) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (16/16) (4a56f41b560d8eda0842c4b8e74915d4) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (11/16)#0 (5caa04da40d5c1c8c909e79f6964a885)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (11/16) (5caa04da40d5c1c8c909e79f6964a885)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (3/16)#0 (e6c9e59c09e3f542bc6f79b25cceca9b)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (4/16)#0 (6474d766153e809f0061cc9cf67f792d) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (3/16) (e6c9e59c09e3f542bc6f79b25cceca9b)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (4/16) (6474d766153e809f0061cc9cf67f792d) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (7/16)#0 (24dc1368c46668e9f5d8200bdae8e3ba)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (7/16)#0
(24dc1368c46668e9f5d8200bdae8e3ba).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (5/16)#0 (f3259a01a84af1baa62f3271bb98a384)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (5/16)#0
(f3259a01a84af1baa62f3271bb98a384).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (2/16)#0 (9bb56603fe121010ffa9ba743e1a16fa)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (5/16)#0
f3259a01a84af1baa62f3271bb98a384.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (2/16)#0
(9bb56603fe121010ffa9ba743e1a16fa).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (9/16)#0 (c09c4ec7f58f96ca4c3dab1a986cda76)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (9/16)#0
(c09c4ec7f58f96ca4c3dab1a986cda76).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (15/16)#0 (7443b9d7ccb94c13fdf3e0fbf59a6cba)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (8/16)#0 (ac08167e6f12a3a7489b264d8a16379b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (15/16)#0
(7443b9d7ccb94c13fdf3e0fbf59a6cba).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (8/16)#0
(ac08167e6f12a3a7489b264d8a16379b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (10/16)#0 (e0502605ee102309d75cfebd7e75950d)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (10/16)#0
(e0502605ee102309d75cfebd7e75950d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (11/16)#0 (5caa04da40d5c1c8c909e79f6964a885)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (11/16)#0
(5caa04da40d5c1c8c909e79f6964a885).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM
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-30'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (1/16)#0 (2094908315a1b77e8a76401299030cd9)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (1/16)#0
(2094908315a1b77e8a76401299030cd9).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (3/16)#0 (e6c9e59c09e3f542bc6f79b25cceca9b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (3/16)#0
(e6c9e59c09e3f542bc6f79b25cceca9b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (13/16)#0 (5367de9e6f0195441b7a1d7bb38c5eca)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:807 Creating
insecure state channel for localhost:43583.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (16/16)#0 (0a95a4728e04ed772c24d754e71b1b00)
switched from RUNNING to FINISHED.'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:814 State channel
established.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (13/16)#0
(5367de9e6f0195441b7a1d7bb38c5eca).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (12/16)#0 (1180f4d028a218d185c83dedccf46b39)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (16/16)#0
(0a95a4728e04ed772c24d754e71b1b00).'
INFO apache_beam.runners.worker.data_plane:data_plane.py:750 Creating
client data channel for localhost:42205
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (12/16)#0
(1180f4d028a218d185c83dedccf46b39).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (14/16)#0 (e097e8ad2ab041cc7ab1d1e7a97b137a)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (14/16)#0
(e097e8ad2ab041cc7ab1d1e7a97b137a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (6/16)#0 (3c9290eb31781e16c2e5d4c141b056dc)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (6/16)#0
(3c9290eb31781e16c2e5d4c141b056dc).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (2/16)#0
9bb56603fe121010ffa9ba743e1a16fa.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (7/16)#0
24dc1368c46668e9f5d8200bdae8e3ba.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (9/16)#0
c09c4ec7f58f96ca4c3dab1a986cda76.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (10/16)#0
e0502605ee102309d75cfebd7e75950d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (5/16) (f3259a01a84af1baa62f3271bb98a384)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (2/16) (9bb56603fe121010ffa9ba743e1a16fa)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (7/16) (24dc1368c46668e9f5d8200bdae8e3ba)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (15/16)#0
7443b9d7ccb94c13fdf3e0fbf59a6cba.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (11/16)#0
5caa04da40d5c1c8c909e79f6964a885.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (9/16) (c09c4ec7f58f96ca4c3dab1a986cda76)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (8/16)#0
ac08167e6f12a3a7489b264d8a16379b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (10/16) (e0502605ee102309d75cfebd7e75950d)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (1/16)#0
2094908315a1b77e8a76401299030cd9.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (15/16) (7443b9d7ccb94c13fdf3e0fbf59a6cba)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (3/16)#0
e6c9e59c09e3f542bc6f79b25cceca9b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (11/16) (5caa04da40d5c1c8c909e79f6964a885)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (12/16)#0
1180f4d028a218d185c83dedccf46b39.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (8/16) (ac08167e6f12a3a7489b264d8a16379b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (1/16) (2094908315a1b77e8a76401299030cd9)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (14/16)#0
e097e8ad2ab041cc7ab1d1e7a97b137a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (3/16) (e6c9e59c09e3f542bc6f79b25cceca9b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (6/16)#0
3c9290eb31781e16c2e5d4c141b056dc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (12/16) (1180f4d028a218d185c83dedccf46b39)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (16/16)#0
0a95a4728e04ed772c24d754e71b1b00.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (14/16) (e097e8ad2ab041cc7ab1d1e7a97b137a)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (13/16)#0
5367de9e6f0195441b7a1d7bb38c5eca.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (6/16) (3c9290eb31781e16c2e5d4c141b056dc)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (16/16) (0a95a4728e04ed772c24d754e71b1b00)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (13/16) (5367de9e6f0195441b7a1d7bb38c5eca)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (4/16)#0 (5817940449f6d37336aba7d65513cd9c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (4/16)#0
(5817940449f6d37336aba7d65513cd9c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM 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 [4]assert_that/{Create, Group} (4/16)#0
5817940449f6d37336aba7d65513cd9c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 16,
2021 6:29:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (4/16) (5817940449f6d37336aba7d65513cd9c)
switched from RUNNING to FINISHED.'
> Task :sdks:python:test-suites:dataflow:py36:postCommitIT
[gw4] [32mPASSED[0m
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
apache_beam/io/gcp/bigquery_file_loads_test.py::BigQueryFileLoadsIT::test_bqfl_streaming
[gw4] [33mSKIPPED[0m
apache_beam/io/gcp/bigquery_file_loads_test.py::BigQueryFileLoadsIT::test_bqfl_streaming
apache_beam/io/gcp/bigquery_file_loads_test.py::BigQueryFileLoadsIT::test_multiple_destinations_transform
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: [email protected]
For additional commands, e-mail: [email protected]
