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 18:29:13 UTC
Build failed in Jenkins: beam_PostCommit_Python36 #4474
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: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Python36 #4475
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python36/4475/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org