See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/4474/display/redirect?page=changes>
Changes:
[dmitrii_kuzin] [BEAM-12730] Custom delimiter always bytes
[noreply] Minor: Add base_func to Series.aggregate expression names (#15706)
[noreply] [BEAM-13013] Extend cross language expansion. (#15698)
[noreply] Minor: Clarify confusing boolean logic for selecting PerWindowInvoker
[noreply] [BEAM-4424] Execute hooks in enabling order (#15713)
------------------------------------------
[...truncated 49.55 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (15/16) (f4f9d910f336bdb0e2afd576237744cd)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (9/16)#0 (82dc0aedb42b9c75c455137474caa3c1) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (029f2b30a146a37f03db1c0e68473496) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (9/16) (82dc0aedb42b9c75c455137474caa3c1) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (7187d270d64c552543f87d9d2770e334) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (7187d270d64c552543f87d9d2770e334) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (2/16)#0 (4c1358c15d1dbbeb34704184fb34a955) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (2/16) (4c1358c15d1dbbeb34704184fb34a955) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (c296a7755fc9ac32b0d39d2203080f8c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (6375b73a23ba63348c812a9f2d3c0424)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(c296a7755fc9ac32b0d39d2203080f8c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (e2ed9160d37cb8ec55d56d38ed6d6279)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (4d01317ab1fe43b9abb742ceb3f36b97)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(e2ed9160d37cb8ec55d56d38ed6d6279).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (338d05ed4ff2912e3dc58bc71240900d)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(4d01317ab1fe43b9abb742ceb3f36b97).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(338d05ed4ff2912e3dc58bc71240900d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
e2ed9160d37cb8ec55d56d38ed6d6279.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(6375b73a23ba63348c812a9f2d3c0424).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (99d35f452e4feb6a5a487a0faf1f1852)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(99d35f452e4feb6a5a487a0faf1f1852).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (d2b57fd5f585681e3d1eb9a7b13983fb)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(d2b57fd5f585681e3d1eb9a7b13983fb).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (c1e2b6eb087c52d14f277e9acd17f97f)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(c1e2b6eb087c52d14f277e9acd17f97f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (71269ced55568310cb9eaf4aca17092c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (3683b395e46680aa7ff295b88b94ecf2)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(71269ced55568310cb9eaf4aca17092c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(3683b395e46680aa7ff295b88b94ecf2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (0366733fa3eda2ed153b9e83e859ca0b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(0366733fa3eda2ed153b9e83e859ca0b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (22026acaa551b839e46550fb24baed61) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (37fb8326efb0892111b1435053d9656c) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (22026acaa551b839e46550fb24baed61) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (bfa1bf84dfa67cab85bfab167117c986)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(bfa1bf84dfa67cab85bfab167117c986).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (37fb8326efb0892111b1435053d9656c) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (10/16)#0 (7ea0b3bf384a3409a5985dcd53dbc2d6) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (10/16) (7ea0b3bf384a3409a5985dcd53dbc2d6) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (11/16)#0 (6ea1559807f7d1bb973d8ef308cca98a) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:883 Creating
insecure state channel for localhost:40557.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:890 State channel
established.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
assert_that/Group/CoGroupByKeyImpl/GroupByKey -> [4]assert_that/{Group, Unkey,
Match} (11/16) (6ea1559807f7d1bb973d8ef308cca98a) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (15/16)#0 (41a7453ecee156b94e996ff0a5b01306) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (ec6cddef18555065e99a2bb6161d1cd4) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (274763dc22d94f59e6449ba636074d8f)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (15/16) (41a7453ecee156b94e996ff0a5b01306) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (ec6cddef18555065e99a2bb6161d1cd4) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.runners.worker.data_plane:data_plane.py:750 Creating
client data channel for localhost:43857
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(274763dc22d94f59e6449ba636074d8f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (465bdaaf9bbc188a54950aed6a18afad)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(465bdaaf9bbc188a54950aed6a18afad).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (10913a98b24bd4064a4f59acdf9cd873) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (10913a98b24bd4064a4f59acdf9cd873) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (eee26afa247a71b74a1416ea6802cf7f) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (522bbf26b12c4e83348e6431683c4e32) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (3/16)#0 (2ce9b60e7bf8c5d12a7021656ca2336d) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (1/16)#0 (6b1b3e55a0d5dc5ea8a91ac3f5580fc1) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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-22'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (e2ed9160d37cb8ec55d56d38ed6d6279)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (eee26afa247a71b74a1416ea6802cf7f) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
338d05ed4ff2912e3dc58bc71240900d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (522bbf26b12c4e83348e6431683c4e32) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (3/16) (2ce9b60e7bf8c5d12a7021656ca2336d) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (8/16)#0 (1b5743ab1938d4794cabd4775de5385e) switched from INITIALIZING
to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (1/16) (6b1b3e55a0d5dc5ea8a91ac3f5580fc1) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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} (8/16) (1b5743ab1938d4794cabd4775de5385e) switched from INITIALIZING to
RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
465bdaaf9bbc188a54950aed6a18afad.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
274763dc22d94f59e6449ba636074d8f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (338d05ed4ff2912e3dc58bc71240900d)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (465bdaaf9bbc188a54950aed6a18afad)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
d2b57fd5f585681e3d1eb9a7b13983fb.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
99d35f452e4feb6a5a487a0faf1f1852.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (274763dc22d94f59e6449ba636074d8f)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
6375b73a23ba63348c812a9f2d3c0424.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 (f4f9d910f336bdb0e2afd576237744cd)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(f4f9d910f336bdb0e2afd576237744cd).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
c296a7755fc9ac32b0d39d2203080f8c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (d2b57fd5f585681e3d1eb9a7b13983fb)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (99d35f452e4feb6a5a487a0faf1f1852)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (6375b73a23ba63348c812a9f2d3c0424)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
c1e2b6eb087c52d14f277e9acd17f97f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (c296a7755fc9ac32b0d39d2203080f8c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
71269ced55568310cb9eaf4aca17092c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (c1e2b6eb087c52d14f277e9acd17f97f)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
3683b395e46680aa7ff295b88b94ecf2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (71269ced55568310cb9eaf4aca17092c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
0366733fa3eda2ed153b9e83e859ca0b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (3683b395e46680aa7ff295b88b94ecf2)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
bfa1bf84dfa67cab85bfab167117c986.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (0366733fa3eda2ed153b9e83e859ca0b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
4d01317ab1fe43b9abb742ceb3f36b97.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (bfa1bf84dfa67cab85bfab167117c986)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
f4f9d910f336bdb0e2afd576237744cd.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (4d01317ab1fe43b9abb742ceb3f36b97)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (f4f9d910f336bdb0e2afd576237744cd)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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 13,
2021 6:28:29 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 (562de2158242b30cf5791c5540c217e1)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
(562de2158242b30cf5791c5540c217e1).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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
562de2158242b30cf5791c5540c217e1.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:29 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) (562de2158242b30cf5791c5540c217e1)
switched from RUNNING to FINISHED.'
> Task :sdks:python:test-suites:dataflow:py36:postCommitIT
[gw2] [32mPASSED[0m
apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_it
apache_beam/io/fileio_test.py::MatchIntegrationTest::test_transform_on_gcs
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
control'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Beam Fn Control client connected with id 1-1'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM org.apache.beam.runners.fnexecution.logging.GrpcLoggingService
logging'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Beam Fn Logging client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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 (203e124f5622d5d82fa661429fc2d8b8)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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) (203e124f5622d5d82fa661429fc2d8b8)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Fn Harness started'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Entering instruction processing loop'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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} (12/16)#0
(5988df80c1ef2fcc64ac61e43c00bba3) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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 (bad153736835533a77120a55924d07a0)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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} (12/16)
(5988df80c1ef2fcc64ac61e43c00bba3) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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) (bad153736835533a77120a55924d07a0) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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} (7/16)#0
(f8a0c141f2a9b2d834f7205cb98c22c9) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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} (7/16)
(f8a0c141f2a9b2d834f7205cb98c22c9) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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} (10/16)#0
(02b27c7538bfe82368bd9f01ba71a33f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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} (10/16)
(02b27c7538bfe82368bd9f01ba71a33f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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
(e8d51a1e620466b2c5d4ccaf4cacd18d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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)
(e8d51a1e620466b2c5d4ccaf4cacd18d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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} (4/16)#0
(f28aa56d935df88b2516747d55ca5582) switched from INITIALIZING to RUNNING.'
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
control'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Beam Fn Control client connected with id 1-1'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM org.apache.beam.runners.fnexecution.logging.GrpcLoggingService
logging'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Beam Fn Logging client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM 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 (203e124f5622d5d82fa661429fc2d8b8)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 13,
2021 6:28:34 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
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]
