You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/10/09 19:01:20 UTC
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #291
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/291/display/redirect?page=changes>
Changes:
[thw] Add Wiki access request procedure to contributor guildelines.
------------------------------------------
[...truncated 51.06 MB...]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16) (3e9ebf99f06b9bf7a02f7d12ee86262c) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 5e861f169d4af55628252b10e2e7795d.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem a36dfe9f4993eeb3426b6414e444f171.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (0b22df5bb648562fa17c3f0a3c5b95a9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 2b726a028c816638fbafc2b7eb8c90db.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 5c9d202eb91a1f2f580994967d57ac83.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 5a6fc08db76297575ca4ceafc5f16cb2.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 d54a7125ed661bd7217dfdb331eec856.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (25e832179e44c9f7c6574c76fc2ee55e) switched from RUNNING to FINISHED.
[assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (f5d7c4506243b4c52ec1af8ed154881a) switched from RUNNING to FINISHED.
[assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (f5d7c4506243b4c52ec1af8ed154881a).
[assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (f5d7c4506243b4c52ec1af8ed154881a) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem eed753a66d81902b31e668c306f4ca0f.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 29a42edf5e2a50ee1dd4b9d00f79358e.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 4885b5162807637dd19c7c5618b84803.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem c77ba89f74ff9387c93f7bc525e8e0a9.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 66a2b4d03e402378c1428d030cf21300.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem caf43bbc99ad7e8c091f8750142bec4c.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem fe547ef8e2f4d9c8cb97ac381714a975.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (d0af15cdb77cee96f82047cae0b7393f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 3e9ebf99f06b9bf7a02f7d12ee86262c.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 f5d7c4506243b4c52ec1af8ed154881a.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (63d5de0031663985f74ce1302861c851) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (23ab877a1cf6a11ab492c86eb8935c6f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (5e861f169d4af55628252b10e2e7795d) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (15/16) (e50cfd81a9d084eaf96d0bc484cf8c8d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (a36dfe9f4993eeb3426b6414e444f171) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (15/16) (e50cfd81a9d084eaf96d0bc484cf8c8d).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) (e50cfd81a9d084eaf96d0bc484cf8c8d) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem e50cfd81a9d084eaf96d0bc484cf8c8d.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (2b726a028c816638fbafc2b7eb8c90db) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (5c9d202eb91a1f2f580994967d57ac83) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (5a6fc08db76297575ca4ceafc5f16cb2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (d54a7125ed661bd7217dfdb331eec856) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (eed753a66d81902b31e668c306f4ca0f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (29a42edf5e2a50ee1dd4b9d00f79358e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (4885b5162807637dd19c7c5618b84803) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (c77ba89f74ff9387c93f7bc525e8e0a9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (66a2b4d03e402378c1428d030cf21300) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (caf43bbc99ad7e8c091f8750142bec4c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (fe547ef8e2f4d9c8cb97ac381714a975) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (3e9ebf99f06b9bf7a02f7d12ee86262c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (f5d7c4506243b4c52ec1af8ed154881a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (e50cfd81a9d084eaf96d0bc484cf8c8d) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (a13ca80b6e409e5feed90f9aa6f7e531) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (a13ca80b6e409e5feed90f9aa6f7e531).
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (a13ca80b6e409e5feed90f9aa6f7e531) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 a13ca80b6e409e5feed90f9aa6f7e531.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (ca5c602715be54a766ed7dfe893f02ee) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (ca5c602715be54a766ed7dfe893f02ee).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (d5654860b8f258fa6acef5f3e607dc43) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (d5654860b8f258fa6acef5f3e607dc43).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (9e41979665337ccfaeaac555af68fa03) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (da7b134b458521a903e20fa7afb58ef4) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (af500420b6a2b048ab9827c52d385fb0) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (af500420b6a2b048ab9827c52d385fb0).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (a13ca80b6e409e5feed90f9aa6f7e531) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (11f5023fb9bbd1f25fcac5521bf12b71) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (9e41979665337ccfaeaac555af68fa03).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (56703940e028e2d6abaaaebad53b4a65) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (ca5c602715be54a766ed7dfe893f02ee) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (9b8c3e05004d7e9490f7765dfbe26756) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (9b8c3e05004d7e9490f7765dfbe26756).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (5821f19f940e11d08aafd0205b9f6b39) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (99b9b37c7d93ba16077c9f91330e485f) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (99b9b37c7d93ba16077c9f91330e485f).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (da7b134b458521a903e20fa7afb58ef4).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (5821f19f940e11d08aafd0205b9f6b39).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (25eab183afd08d8e0cfb8ac5c45ec997) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem ca5c602715be54a766ed7dfe893f02ee.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (56703940e028e2d6abaaaebad53b4a65).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (e6ee7ee4d372a4855a42b32c77d79a5e) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (e6ee7ee4d372a4855a42b32c77d79a5e).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (11f5023fb9bbd1f25fcac5521bf12b71).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (adc53f0c0a267cde72f9ffd185a857a9) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (adc53f0c0a267cde72f9ffd185a857a9).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (4c0256ce4cd9e5f783f39da4c9078eb6) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (4c0256ce4cd9e5f783f39da4c9078eb6).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (25eab183afd08d8e0cfb8ac5c45ec997).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (ca5c602715be54a766ed7dfe893f02ee) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (1f02c67ccde949f78768c4ade5a4dfd7) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (b3ffda769d6969472b2dfbd68b42f351) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (b3ffda769d6969472b2dfbd68b42f351).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (1f02c67ccde949f78768c4ade5a4dfd7).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (d5654860b8f258fa6acef5f3e607dc43) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 d5654860b8f258fa6acef5f3e607dc43.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (1f02c67ccde949f78768c4ade5a4dfd7) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (b3ffda769d6969472b2dfbd68b42f351) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 1f02c67ccde949f78768c4ade5a4dfd7.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (25eab183afd08d8e0cfb8ac5c45ec997) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (4c0256ce4cd9e5f783f39da4c9078eb6) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 b3ffda769d6969472b2dfbd68b42f351.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (adc53f0c0a267cde72f9ffd185a857a9) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (d5654860b8f258fa6acef5f3e607dc43) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 25eab183afd08d8e0cfb8ac5c45ec997.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (11f5023fb9bbd1f25fcac5521bf12b71) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (e6ee7ee4d372a4855a42b32c77d79a5e) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (56703940e028e2d6abaaaebad53b4a65) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 4c0256ce4cd9e5f783f39da4c9078eb6.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (1f02c67ccde949f78768c4ade5a4dfd7) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (5821f19f940e11d08aafd0205b9f6b39) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 adc53f0c0a267cde72f9ffd185a857a9.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 11f5023fb9bbd1f25fcac5521bf12b71.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (b3ffda769d6969472b2dfbd68b42f351) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (da7b134b458521a903e20fa7afb58ef4) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 e6ee7ee4d372a4855a42b32c77d79a5e.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (99b9b37c7d93ba16077c9f91330e485f) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (9b8c3e05004d7e9490f7765dfbe26756) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (25eab183afd08d8e0cfb8ac5c45ec997) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 56703940e028e2d6abaaaebad53b4a65.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (9e41979665337ccfaeaac555af68fa03) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (af500420b6a2b048ab9827c52d385fb0) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 5821f19f940e11d08aafd0205b9f6b39.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (4c0256ce4cd9e5f783f39da4c9078eb6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 da7b134b458521a903e20fa7afb58ef4.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (adc53f0c0a267cde72f9ffd185a857a9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 99b9b37c7d93ba16077c9f91330e485f.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (11f5023fb9bbd1f25fcac5521bf12b71) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 9b8c3e05004d7e9490f7765dfbe26756.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 9e41979665337ccfaeaac555af68fa03.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (e6ee7ee4d372a4855a42b32c77d79a5e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 af500420b6a2b048ab9827c52d385fb0.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (56703940e028e2d6abaaaebad53b4a65) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (5821f19f940e11d08aafd0205b9f6b39) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (da7b134b458521a903e20fa7afb58ef4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (99b9b37c7d93ba16077c9f91330e485f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (9b8c3e05004d7e9490f7765dfbe26756) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (9e41979665337ccfaeaac555af68fa03) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (af500420b6a2b048ab9827c52d385fb0) switched from RUNNING to FINISHED.
[grpc-default-executor-3] INFO sdk_worker.run - No more requests from control plane
[grpc-default-executor-3] INFO sdk_worker.run - SDK Harness waiting for in-flight requests to complete
[grpc-default-executor-3] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-3] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-3] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-3] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-3] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-3] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client hanged up.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (fb1e764aa0fb0452d7f28b0c829fa219) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (fb1e764aa0fb0452d7f28b0c829fa219).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (fb1e764aa0fb0452d7f28b0c829fa219) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 fb1e764aa0fb0452d7f28b0c829fa219.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (fb1e764aa0fb0452d7f28b0c829fa219) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1539111674.8 (53ee529f703004b4c5d51cc9693acd87) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 53ee529f703004b4c5d51cc9693acd87.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 53ee529f703004b4c5d51cc9693acd87 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job test_windowing_1539111674.8(53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 53ee529f703004b4c5d51cc9693acd87.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection c6f9197cabfd0573860312930c62307c: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager bddfcbae79622047886458fe7c394393@akka://flink/user/jobmanager_39 for job 53ee529f703004b4c5d51cc9693acd87 from the resource manager.
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{0b268b857d340350317d8f2d54be0487}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcheref96a82c-20b3-4a22-a636-ce952cf4153a.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcheref96a82c-20b3-4a22-a636-ce952cf4153a.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager bcbe5401cba5bd70d30f1513463d9c79 from the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 53ee529f703004b4c5d51cc9693acd87 with leader id bddfcbae79622047886458fe7c394393 lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{e52aab165d3b40d6232e3d88d2debd44}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{37fb10ccc1a4c46d5cb2f55240ff8137}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{bc1edabb2138e6a000673df0fb8c5996}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Could not resolve JobManager address akka://flink/user/jobmanager_39, retrying in 10000 ms: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_39..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d7ba0d0847252968ac379b321357b735}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{86d4073a60ac2263966a311a30db7079}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c6f2d18c425f1e0604540fa9eec44c2e}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{380f45e93f590b8d5234e8a407eca104}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a31e6f5db285a029b4b9512cefcbb11d}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d5e8de32368ca1be622e6ba29388f285}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{669cff32ddb07e06ac58b91f0f372e13}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{add79c87787b86ff2c9a2ce031cbfb63}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{28acf290012ec07945b9d1acab942e0a}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{7a41bae899cc8d1b97a170b0fa3484fc}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{aa9582af17be49ffa82b44756f566af0}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4940e6557d6948fa3145bd281977e504}, jobId: 53ee529f703004b4c5d51cc9693acd87).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 53ee529f703004b4c5d51cc9693acd87 from job leader monitoring.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 53ee529f703004b4c5d51cc9693acd87.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-feb6c527-db9a-4ac2-afd7-691de8e7a5e2
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcheref96a82c-20b3-4a22-a636-ce952cf4153a.
[ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:39229
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 1934 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@ce639d89
.
----------------------------------------------------------------------
Ran 25 tests in 76.045s
OK (skipped=7)
Segmentation fault (core dumped)
> Task :beam-sdks-python:flinkCompatibilityMatrixStreaming FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Daemon worker,5,main]) completed. Took 1 mins 18.148 secs.
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 351
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatch'.
> Process 'command 'sh'' finished with non-zero exit value 139
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 351
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreaming'.
> Process 'command 'sh'' finished with non-zero exit value 139
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 10m 45s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/mngxuezkgdnbc
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #298
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/298/display/redirect>
------------------------------------------
Started by timer
[EnvInject] - Loading node environment variables.
Building remotely on beam15 (beam) in workspace <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/>
> git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
> git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
> git --version # timeout=10
> git fetch --tags --progress https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/* +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/*
> git rev-parse origin/master^{commit} # timeout=10
Checking out Revision 399c09fca45904ce8c55c022f9483db1b979c6a6 (origin/master)
> git config core.sparsecheckout # timeout=10
> git checkout -f 399c09fca45904ce8c55c022f9483db1b979c6a6
Commit message: "Merge pull request #6623 from apache/revert-6610-fixAssert"
> git rev-list --no-walk 399c09fca45904ce8c55c022f9483db1b979c6a6 # timeout=10
Cleaning workspace
> git rev-parse --verify HEAD # timeout=10
Resetting working tree
> git reset --hard # timeout=10
> git clean -fdx # timeout=10
[EnvInject] - Executing scripts and injecting environment variables after the SCM step.
[EnvInject] - Injecting as environment variables the properties content
SPARK_LOCAL_IP=127.0.0.1
[EnvInject] - Variables injected successfully.
[Gradle] - Launching build.
[src] $ <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/gradlew> --info --continue --max-workers=12 -Dorg.gradle.jvmargs=-Xms2g -Dorg.gradle.jvmargs=-Xmx4g :beam-sdks-python:flinkValidatesRunner
Initialized native services in: /home/jenkins/.gradle/native
To honour the JVM settings for this build a new JVM will be forked. Please consider using the daemon: https://docs.gradle.org/4.10.2/userguide/gradle_daemon.html.
Starting process 'Gradle build daemon'. Working directory: /home/jenkins/.gradle/daemon/4.10.2 Command: /usr/local/asfpackages/java/jdk1.8.0_172/bin/java -Xmx4g -Dfile.encoding=UTF-8 -Duser.country=US -Duser.language=en -Duser.variant -cp /home/jenkins/.gradle/wrapper/dists/gradle-4.10.2-bin/cghg6c4gf4vkiutgsab8yrnwv/gradle-4.10.2/lib/gradle-launcher-4.10.2.jar org.gradle.launcher.daemon.bootstrap.GradleDaemon 4.10.2
Successfully started process 'Gradle build daemon'
An attempt to start the daemon took 0.855 secs.
The client will now receive all logging from the daemon (pid: 20579). The daemon log file: /home/jenkins/.gradle/daemon/4.10.2/daemon-20579.out.log
Closing daemon's stdin at end of input.
The daemon will no longer process any standard input.
Daemon will be stopped at the end of the build stopping after processing
Using 12 worker leases.
Starting Build
Parallel execution is an incubating feature.
> Configure project :buildSrc
Evaluating project ':buildSrc' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/build.gradle'.>
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Selected primary task 'build' from project :
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:compileJava (Thread[Task worker for ':buildSrc',5,main]) started.
Using local directory build cache for build ':buildSrc' (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
> Task :buildSrc:compileJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/java',> not found
Skipping task ':buildSrc:compileJava' as it has no source files and no previous output files.
:buildSrc:compileJava (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.079 secs.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:compileGroovy FROM-CACHE
Build cache key for task ':buildSrc:compileGroovy' is ffa895a1cf2b1718eb804dc82ad66ea4
Task ':buildSrc:compileGroovy' is not up-to-date because:
No history is available.
Origin for task ':buildSrc:compileGroovy': {executionTime=2266, hostName=apache-beam-jenkins-slave-group-lbw6, operatingSystem=Linux, buildInvocationId=67p7cwv2jbh23lrdpokdubwxee, creationTime=1538771065235, type=org.gradle.api.tasks.compile.GroovyCompile_Decorated, userName=jenkins, gradleVersion=4.10.2, rootPath=<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc,> path=:compileGroovy}
Unpacked output for task ':buildSrc:compileGroovy' from cache.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.101 secs.
:buildSrc:processResources (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:processResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/resources',> not found
Skipping task ':buildSrc:processResources' as it has no source files and no previous output files.
:buildSrc:processResources (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.001 secs.
:buildSrc:classes (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:classes UP-TO-DATE
Skipping task ':buildSrc:classes' as it has no actions.
:buildSrc:classes (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:jar (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:jar
Build cache key for task ':buildSrc:jar' is 7445e5c45b21f8a690f2f547fcb49594
Caching disabled for task ':buildSrc:jar': Caching has not been enabled for the task
Task ':buildSrc:jar' is not up-to-date because:
No history is available.
:buildSrc:jar (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.125 secs.
:buildSrc:assemble (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:assemble
Skipping task ':buildSrc:assemble' as it has no actions.
:buildSrc:assemble (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessGroovy
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Caching disabled for task ':buildSrc:spotlessGroovy': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovy' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovy'.
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc',5,main]) completed. Took 1.358 secs.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessGroovyCheck
Skipping task ':buildSrc:spotlessGroovyCheck' as it has no actions.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.001 secs.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessGroovyGradle
Caching disabled for task ':buildSrc:spotlessGroovyGradle': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovyGradle' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovyGradle'.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.031 secs.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessGroovyGradleCheck
Skipping task ':buildSrc:spotlessGroovyGradleCheck' as it has no actions.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessCheck
Skipping task ':buildSrc:spotlessCheck' as it has no actions.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:compileTestJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/java',> not found
Skipping task ':buildSrc:compileTestJava' as it has no source files and no previous output files.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.002 secs.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:compileTestGroovy NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Skipping task ':buildSrc:compileTestGroovy' as it has no source files and no previous output files.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.001 secs.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/resources',> not found
Skipping task ':buildSrc:processTestResources' as it has no source files and no previous output files.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.002 secs.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:testClasses UP-TO-DATE
Skipping task ':buildSrc:testClasses' as it has no actions.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:test (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:test NO-SOURCE
Skipping task ':buildSrc:test' as it has no source files and no previous output files.
:buildSrc:test (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.002 secs.
:buildSrc:check (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:check
Skipping task ':buildSrc:check' as it has no actions.
:buildSrc:check (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:build (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:build
Skipping task ':buildSrc:build' as it has no actions.
:buildSrc:build (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
Settings evaluated using settings file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/settings.gradle'.>
Using local directory build cache for the root build (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
Projects loaded. Root project using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
Included projects: [root project 'beam', project ':beam-examples-java', project ':beam-model-fn-execution', project ':beam-model-job-management', project ':beam-model-pipeline', project ':beam-runners-apex', project ':beam-runners-core-construction-java', project ':beam-runners-core-java', project ':beam-runners-direct-java', project ':beam-runners-extensions-java-metrics', project ':beam-runners-flink_2.11', project ':beam-runners-flink_2.11-job-server', project ':beam-runners-flink_2.11-job-server-container', project ':beam-runners-gearpump', project ':beam-runners-google-cloud-dataflow-java', project ':beam-runners-google-cloud-dataflow-java-examples', project ':beam-runners-google-cloud-dataflow-java-examples-streaming', project ':beam-runners-google-cloud-dataflow-java-fn-api-worker', project ':beam-runners-google-cloud-dataflow-java-legacy-worker', project ':beam-runners-google-cloud-dataflow-java-windmill', project ':beam-runners-java-fn-execution', project ':beam-runners-local-java-core', project ':beam-runners-reference-java', project ':beam-runners-reference-job-server', project ':beam-runners-samza', project ':beam-runners-spark', project ':beam-sdks-go', project ':beam-sdks-go-container', project ':beam-sdks-go-examples', project ':beam-sdks-go-test', project ':beam-sdks-java-build-tools', project ':beam-sdks-java-container', project ':beam-sdks-java-core', project ':beam-sdks-java-extensions-google-cloud-platform-core', project ':beam-sdks-java-extensions-join-library', project ':beam-sdks-java-extensions-json-jackson', project ':beam-sdks-java-extensions-protobuf', project ':beam-sdks-java-extensions-sketching', project ':beam-sdks-java-extensions-sorter', project ':beam-sdks-java-extensions-sql', project ':beam-sdks-java-extensions-sql-jdbc', project ':beam-sdks-java-extensions-sql-shell', project ':beam-sdks-java-fn-execution', project ':beam-sdks-java-harness', project ':beam-sdks-java-io-amazon-web-services', project ':beam-sdks-java-io-amqp', project ':beam-sdks-java-io-cassandra', project ':beam-sdks-java-io-common', project ':beam-sdks-java-io-elasticsearch', project ':beam-sdks-java-io-elasticsearch-tests-2', project ':beam-sdks-java-io-elasticsearch-tests-5', project ':beam-sdks-java-io-elasticsearch-tests-6', project ':beam-sdks-java-io-elasticsearch-tests-common', project ':beam-sdks-java-io-file-based-io-tests', project ':beam-sdks-java-io-google-cloud-platform', project ':beam-sdks-java-io-hadoop-common', project ':beam-sdks-java-io-hadoop-file-system', project ':beam-sdks-java-io-hadoop-input-format', project ':beam-sdks-java-io-hbase', project ':beam-sdks-java-io-hcatalog', project ':beam-sdks-java-io-jdbc', project ':beam-sdks-java-io-jms', project ':beam-sdks-java-io-kafka', project ':beam-sdks-java-io-kinesis', project ':beam-sdks-java-io-kudu', project ':beam-sdks-java-io-mongodb', project ':beam-sdks-java-io-mqtt', project ':beam-sdks-java-io-parquet', project ':beam-sdks-java-io-redis', project ':beam-sdks-java-io-solr', project ':beam-sdks-java-io-synthetic', project ':beam-sdks-java-io-tika', project ':beam-sdks-java-io-xml', project ':beam-sdks-java-javadoc', project ':beam-sdks-java-load-tests', project ':beam-sdks-java-maven-archetypes-examples', project ':beam-sdks-java-maven-archetypes-starter', project ':beam-sdks-java-nexmark', project ':beam-sdks-python', project ':beam-sdks-python-container', project ':beam-sdks-python-container-py3', project ':beam-vendor-sdks-java-extensions-protobuf', project ':beam-website', project ':release']
Parallel execution with configuration on demand is an incubating feature.
> Configure project :
Evaluating root project 'beam' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
> Configure project :beam-sdks-python
Evaluating project ':beam-sdks-python' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'.>
FAILURE: Build failed with an exception.
* What went wrong:
Task 'flinkValidatesRunner' not found in project ':beam-sdks-python'.
* Try:
Run gradlew tasks to get a list of available tasks. Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8s
Publishing build scan...
https://gradle.com/s/zctnw3k7u7jyu
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #297
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/297/display/redirect?page=changes>
Changes:
[github] Revert "[BEAM-5627] Fix the issue of using str while byte is required in
------------------------------------------
Started by GitHub push by aaltay
[EnvInject] - Loading node environment variables.
Building remotely on beam13 (beam) in workspace <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/>
> git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
> git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
> git --version # timeout=10
> git fetch --tags --progress https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/* +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/*
> git rev-parse origin/master^{commit} # timeout=10
Checking out Revision 399c09fca45904ce8c55c022f9483db1b979c6a6 (origin/master)
> git config core.sparsecheckout # timeout=10
> git checkout -f 399c09fca45904ce8c55c022f9483db1b979c6a6
Commit message: "Merge pull request #6623 from apache/revert-6610-fixAssert"
> git rev-list --no-walk 1fce8654ed6546dac66b2ee10e2c4adbcc59da3f # timeout=10
Cleaning workspace
> git rev-parse --verify HEAD # timeout=10
Resetting working tree
> git reset --hard # timeout=10
> git clean -fdx # timeout=10
[EnvInject] - Executing scripts and injecting environment variables after the SCM step.
[EnvInject] - Injecting as environment variables the properties content
SPARK_LOCAL_IP=127.0.0.1
[EnvInject] - Variables injected successfully.
[Gradle] - Launching build.
[src] $ <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/gradlew> --info --continue --max-workers=12 -Dorg.gradle.jvmargs=-Xms2g -Dorg.gradle.jvmargs=-Xmx4g :beam-sdks-python:flinkValidatesRunner
Initialized native services in: /home/jenkins/.gradle/native
To honour the JVM settings for this build a new JVM will be forked. Please consider using the daemon: https://docs.gradle.org/4.10.2/userguide/gradle_daemon.html.
Starting process 'Gradle build daemon'. Working directory: /home/jenkins/.gradle/daemon/4.10.2 Command: /usr/local/asfpackages/java/jdk1.8.0_172/bin/java -Xmx4g -Dfile.encoding=UTF-8 -Duser.country=US -Duser.language=en -Duser.variant -cp /home/jenkins/.gradle/wrapper/dists/gradle-4.10.2-bin/cghg6c4gf4vkiutgsab8yrnwv/gradle-4.10.2/lib/gradle-launcher-4.10.2.jar org.gradle.launcher.daemon.bootstrap.GradleDaemon 4.10.2
Successfully started process 'Gradle build daemon'
An attempt to start the daemon took 0.778 secs.
The client will now receive all logging from the daemon (pid: 28946). The daemon log file: /home/jenkins/.gradle/daemon/4.10.2/daemon-28946.out.log
Closing daemon's stdin at end of input.
The daemon will no longer process any standard input.
Daemon will be stopped at the end of the build stopping after processing
Using 12 worker leases.
Starting Build
Parallel execution is an incubating feature.
> Configure project :buildSrc
Evaluating project ':buildSrc' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/build.gradle'.>
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Selected primary task 'build' from project :
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:compileJava (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
Using local directory build cache for build ':buildSrc' (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
> Task :buildSrc:compileJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/java',> not found
Skipping task ':buildSrc:compileJava' as it has no source files and no previous output files.
:buildSrc:compileJava (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 0.072 secs.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
> Task :buildSrc:compileGroovy FROM-CACHE
Build cache key for task ':buildSrc:compileGroovy' is ffa895a1cf2b1718eb804dc82ad66ea4
Task ':buildSrc:compileGroovy' is not up-to-date because:
No history is available.
Origin for task ':buildSrc:compileGroovy': {executionTime=2079, hostName=apache-beam-jenkins-slave-group-jh79, operatingSystem=Linux, buildInvocationId=s7oaf3dm5vd7vatnkjp4oywhpa, creationTime=1538771517222, type=org.gradle.api.tasks.compile.GroovyCompile_Decorated, userName=jenkins, gradleVersion=4.10.2, rootPath=/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/src/buildSrc, path=:compileGroovy}
Unpacked output for task ':buildSrc:compileGroovy' from cache.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 0.091 secs.
:buildSrc:processResources (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
> Task :buildSrc:processResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/resources',> not found
Skipping task ':buildSrc:processResources' as it has no source files and no previous output files.
:buildSrc:processResources (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 0.001 secs.
:buildSrc:classes (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
> Task :buildSrc:classes UP-TO-DATE
Skipping task ':buildSrc:classes' as it has no actions.
:buildSrc:classes (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 0.0 secs.
:buildSrc:jar (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
> Task :buildSrc:jar
Build cache key for task ':buildSrc:jar' is 7445e5c45b21f8a690f2f547fcb49594
Caching disabled for task ':buildSrc:jar': Caching has not been enabled for the task
Task ':buildSrc:jar' is not up-to-date because:
No history is available.
:buildSrc:jar (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 0.111 secs.
:buildSrc:assemble (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
> Task :buildSrc:assemble
Skipping task ':buildSrc:assemble' as it has no actions.
:buildSrc:assemble (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
> Task :buildSrc:spotlessGroovy
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Caching disabled for task ':buildSrc:spotlessGroovy': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovy' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovy'.
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 1.371 secs.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
> Task :buildSrc:spotlessGroovyCheck
Skipping task ':buildSrc:spotlessGroovyCheck' as it has no actions.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 0.001 secs.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc' Thread 6,5,main]) started.
> Task :buildSrc:spotlessGroovyGradle
Caching disabled for task ':buildSrc:spotlessGroovyGradle': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovyGradle' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovyGradle'.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc' Thread 6,5,main]) completed. Took 0.026 secs.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc' Thread 3,5,main]) started.
> Task :buildSrc:spotlessGroovyGradleCheck
Skipping task ':buildSrc:spotlessGroovyGradleCheck' as it has no actions.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc' Thread 3,5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc' Thread 3,5,main]) started.
> Task :buildSrc:spotlessCheck
Skipping task ':buildSrc:spotlessCheck' as it has no actions.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc' Thread 3,5,main]) completed. Took 0.0 secs.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc' Thread 3,5,main]) started.
> Task :buildSrc:compileTestJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/java',> not found
Skipping task ':buildSrc:compileTestJava' as it has no source files and no previous output files.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc' Thread 3,5,main]) completed. Took 0.002 secs.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc' Thread 3,5,main]) started.
> Task :buildSrc:compileTestGroovy NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Skipping task ':buildSrc:compileTestGroovy' as it has no source files and no previous output files.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc' Thread 3,5,main]) completed. Took 0.002 secs.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc' Thread 4,5,main]) started.
> Task :buildSrc:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/resources',> not found
Skipping task ':buildSrc:processTestResources' as it has no source files and no previous output files.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc' Thread 4,5,main]) completed. Took 0.001 secs.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc' Thread 4,5,main]) started.
> Task :buildSrc:testClasses UP-TO-DATE
Skipping task ':buildSrc:testClasses' as it has no actions.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc' Thread 4,5,main]) completed. Took 0.0 secs.
:buildSrc:test (Thread[Task worker for ':buildSrc' Thread 4,5,main]) started.
> Task :buildSrc:test NO-SOURCE
Skipping task ':buildSrc:test' as it has no source files and no previous output files.
:buildSrc:test (Thread[Task worker for ':buildSrc' Thread 4,5,main]) completed. Took 0.003 secs.
:buildSrc:check (Thread[Task worker for ':buildSrc' Thread 4,5,main]) started.
> Task :buildSrc:check
Skipping task ':buildSrc:check' as it has no actions.
:buildSrc:check (Thread[Task worker for ':buildSrc' Thread 4,5,main]) completed. Took 0.0 secs.
:buildSrc:build (Thread[Task worker for ':buildSrc' Thread 4,5,main]) started.
> Task :buildSrc:build
Skipping task ':buildSrc:build' as it has no actions.
:buildSrc:build (Thread[Task worker for ':buildSrc' Thread 4,5,main]) completed. Took 0.0 secs.
Settings evaluated using settings file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/settings.gradle'.>
Using local directory build cache for the root build (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
Projects loaded. Root project using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
Included projects: [root project 'beam', project ':beam-examples-java', project ':beam-model-fn-execution', project ':beam-model-job-management', project ':beam-model-pipeline', project ':beam-runners-apex', project ':beam-runners-core-construction-java', project ':beam-runners-core-java', project ':beam-runners-direct-java', project ':beam-runners-extensions-java-metrics', project ':beam-runners-flink_2.11', project ':beam-runners-flink_2.11-job-server', project ':beam-runners-flink_2.11-job-server-container', project ':beam-runners-gearpump', project ':beam-runners-google-cloud-dataflow-java', project ':beam-runners-google-cloud-dataflow-java-examples', project ':beam-runners-google-cloud-dataflow-java-examples-streaming', project ':beam-runners-google-cloud-dataflow-java-fn-api-worker', project ':beam-runners-google-cloud-dataflow-java-legacy-worker', project ':beam-runners-google-cloud-dataflow-java-windmill', project ':beam-runners-java-fn-execution', project ':beam-runners-local-java-core', project ':beam-runners-reference-java', project ':beam-runners-reference-job-server', project ':beam-runners-samza', project ':beam-runners-spark', project ':beam-sdks-go', project ':beam-sdks-go-container', project ':beam-sdks-go-examples', project ':beam-sdks-go-test', project ':beam-sdks-java-build-tools', project ':beam-sdks-java-container', project ':beam-sdks-java-core', project ':beam-sdks-java-extensions-google-cloud-platform-core', project ':beam-sdks-java-extensions-join-library', project ':beam-sdks-java-extensions-json-jackson', project ':beam-sdks-java-extensions-protobuf', project ':beam-sdks-java-extensions-sketching', project ':beam-sdks-java-extensions-sorter', project ':beam-sdks-java-extensions-sql', project ':beam-sdks-java-extensions-sql-jdbc', project ':beam-sdks-java-extensions-sql-shell', project ':beam-sdks-java-fn-execution', project ':beam-sdks-java-harness', project ':beam-sdks-java-io-amazon-web-services', project ':beam-sdks-java-io-amqp', project ':beam-sdks-java-io-cassandra', project ':beam-sdks-java-io-common', project ':beam-sdks-java-io-elasticsearch', project ':beam-sdks-java-io-elasticsearch-tests-2', project ':beam-sdks-java-io-elasticsearch-tests-5', project ':beam-sdks-java-io-elasticsearch-tests-6', project ':beam-sdks-java-io-elasticsearch-tests-common', project ':beam-sdks-java-io-file-based-io-tests', project ':beam-sdks-java-io-google-cloud-platform', project ':beam-sdks-java-io-hadoop-common', project ':beam-sdks-java-io-hadoop-file-system', project ':beam-sdks-java-io-hadoop-input-format', project ':beam-sdks-java-io-hbase', project ':beam-sdks-java-io-hcatalog', project ':beam-sdks-java-io-jdbc', project ':beam-sdks-java-io-jms', project ':beam-sdks-java-io-kafka', project ':beam-sdks-java-io-kinesis', project ':beam-sdks-java-io-kudu', project ':beam-sdks-java-io-mongodb', project ':beam-sdks-java-io-mqtt', project ':beam-sdks-java-io-parquet', project ':beam-sdks-java-io-redis', project ':beam-sdks-java-io-solr', project ':beam-sdks-java-io-synthetic', project ':beam-sdks-java-io-tika', project ':beam-sdks-java-io-xml', project ':beam-sdks-java-javadoc', project ':beam-sdks-java-load-tests', project ':beam-sdks-java-maven-archetypes-examples', project ':beam-sdks-java-maven-archetypes-starter', project ':beam-sdks-java-nexmark', project ':beam-sdks-python', project ':beam-sdks-python-container', project ':beam-sdks-python-container-py3', project ':beam-vendor-sdks-java-extensions-protobuf', project ':beam-website', project ':release']
Parallel execution with configuration on demand is an incubating feature.
> Configure project :
Evaluating root project 'beam' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/fileHashes.bin
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/resourceHashesCache.bin
> Configure project :beam-sdks-python
Evaluating project ':beam-sdks-python' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'.>
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/fileHashes.bin
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/resourceHashesCache.bin
FAILURE: Build failed with an exception.
* What went wrong:
Task 'flinkValidatesRunner' not found in project ':beam-sdks-python'.
* Try:
Run gradlew tasks to get a list of available tasks. Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8s
Publishing build scan...
https://gradle.com/s/t6ac2yka2zwho
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #296
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/296/display/redirect?page=changes>
Changes:
[pablo] Adding fixes to work properly with files on windows
------------------------------------------
Started by GitHub push by pabloem
[EnvInject] - Loading node environment variables.
Building remotely on beam15 (beam) in workspace <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/>
> git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
> git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
> git --version # timeout=10
> git fetch --tags --progress https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/* +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/*
> git rev-parse origin/master^{commit} # timeout=10
Checking out Revision 1fce8654ed6546dac66b2ee10e2c4adbcc59da3f (origin/master)
> git config core.sparsecheckout # timeout=10
> git checkout -f 1fce8654ed6546dac66b2ee10e2c4adbcc59da3f
Commit message: "Merge pull request #6620 from pabloem/windows-files"
> git rev-list --no-walk c356c574312e2ee84de8e0abeaf66e77d29d521a # timeout=10
Cleaning workspace
> git rev-parse --verify HEAD # timeout=10
Resetting working tree
> git reset --hard # timeout=10
> git clean -fdx # timeout=10
[EnvInject] - Executing scripts and injecting environment variables after the SCM step.
[EnvInject] - Injecting as environment variables the properties content
SPARK_LOCAL_IP=127.0.0.1
[EnvInject] - Variables injected successfully.
[Gradle] - Launching build.
[src] $ <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/gradlew> --info --continue --max-workers=12 -Dorg.gradle.jvmargs=-Xms2g -Dorg.gradle.jvmargs=-Xmx4g :beam-sdks-python:flinkValidatesRunner
Initialized native services in: /home/jenkins/.gradle/native
To honour the JVM settings for this build a new JVM will be forked. Please consider using the daemon: https://docs.gradle.org/4.10.2/userguide/gradle_daemon.html.
Starting process 'Gradle build daemon'. Working directory: /home/jenkins/.gradle/daemon/4.10.2 Command: /usr/local/asfpackages/java/jdk1.8.0_172/bin/java -Xmx4g -Dfile.encoding=UTF-8 -Duser.country=US -Duser.language=en -Duser.variant -cp /home/jenkins/.gradle/wrapper/dists/gradle-4.10.2-bin/cghg6c4gf4vkiutgsab8yrnwv/gradle-4.10.2/lib/gradle-launcher-4.10.2.jar org.gradle.launcher.daemon.bootstrap.GradleDaemon 4.10.2
Successfully started process 'Gradle build daemon'
An attempt to start the daemon took 0.848 secs.
The client will now receive all logging from the daemon (pid: 22403). The daemon log file: /home/jenkins/.gradle/daemon/4.10.2/daemon-22403.out.log
Closing daemon's stdin at end of input.
The daemon will no longer process any standard input.
Daemon will be stopped at the end of the build stopping after processing
Using 12 worker leases.
Starting Build
Parallel execution is an incubating feature.
> Configure project :buildSrc
Evaluating project ':buildSrc' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/build.gradle'.>
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Selected primary task 'build' from project :
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:compileJava (Thread[Task worker for ':buildSrc',5,main]) started.
Using local directory build cache for build ':buildSrc' (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
> Task :buildSrc:compileJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/java',> not found
Skipping task ':buildSrc:compileJava' as it has no source files and no previous output files.
:buildSrc:compileJava (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.077 secs.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:compileGroovy FROM-CACHE
Build cache key for task ':buildSrc:compileGroovy' is ffa895a1cf2b1718eb804dc82ad66ea4
Task ':buildSrc:compileGroovy' is not up-to-date because:
No history is available.
Origin for task ':buildSrc:compileGroovy': {executionTime=2266, hostName=apache-beam-jenkins-slave-group-lbw6, operatingSystem=Linux, buildInvocationId=67p7cwv2jbh23lrdpokdubwxee, creationTime=1538771065235, type=org.gradle.api.tasks.compile.GroovyCompile_Decorated, userName=jenkins, gradleVersion=4.10.2, rootPath=<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc,> path=:compileGroovy}
Unpacked output for task ':buildSrc:compileGroovy' from cache.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.092 secs.
:buildSrc:processResources (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:processResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/resources',> not found
Skipping task ':buildSrc:processResources' as it has no source files and no previous output files.
:buildSrc:processResources (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.002 secs.
:buildSrc:classes (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:classes UP-TO-DATE
Skipping task ':buildSrc:classes' as it has no actions.
:buildSrc:classes (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:jar (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:jar
Build cache key for task ':buildSrc:jar' is 7445e5c45b21f8a690f2f547fcb49594
Caching disabled for task ':buildSrc:jar': Caching has not been enabled for the task
Task ':buildSrc:jar' is not up-to-date because:
No history is available.
:buildSrc:jar (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.115 secs.
:buildSrc:assemble (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:assemble
Skipping task ':buildSrc:assemble' as it has no actions.
:buildSrc:assemble (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessGroovy
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Caching disabled for task ':buildSrc:spotlessGroovy': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovy' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovy'.
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc',5,main]) completed. Took 1.354 secs.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessGroovyCheck
Skipping task ':buildSrc:spotlessGroovyCheck' as it has no actions.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.001 secs.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessGroovyGradle
Caching disabled for task ':buildSrc:spotlessGroovyGradle': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovyGradle' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovyGradle'.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.034 secs.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessGroovyGradleCheck
Skipping task ':buildSrc:spotlessGroovyGradleCheck' as it has no actions.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:spotlessCheck
Skipping task ':buildSrc:spotlessCheck' as it has no actions.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:compileTestJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/java',> not found
Skipping task ':buildSrc:compileTestJava' as it has no source files and no previous output files.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.002 secs.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:compileTestGroovy NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Skipping task ':buildSrc:compileTestGroovy' as it has no source files and no previous output files.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.002 secs.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/resources',> not found
Skipping task ':buildSrc:processTestResources' as it has no source files and no previous output files.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.001 secs.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:testClasses UP-TO-DATE
Skipping task ':buildSrc:testClasses' as it has no actions.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:test (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:test NO-SOURCE
Skipping task ':buildSrc:test' as it has no source files and no previous output files.
:buildSrc:test (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.004 secs.
:buildSrc:check (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:check
Skipping task ':buildSrc:check' as it has no actions.
:buildSrc:check (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
:buildSrc:build (Thread[Task worker for ':buildSrc',5,main]) started.
> Task :buildSrc:build
Skipping task ':buildSrc:build' as it has no actions.
:buildSrc:build (Thread[Task worker for ':buildSrc',5,main]) completed. Took 0.0 secs.
Settings evaluated using settings file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/settings.gradle'.>
Using local directory build cache for the root build (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
Projects loaded. Root project using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
Included projects: [root project 'beam', project ':beam-examples-java', project ':beam-model-fn-execution', project ':beam-model-job-management', project ':beam-model-pipeline', project ':beam-runners-apex', project ':beam-runners-core-construction-java', project ':beam-runners-core-java', project ':beam-runners-direct-java', project ':beam-runners-extensions-java-metrics', project ':beam-runners-flink_2.11', project ':beam-runners-flink_2.11-job-server', project ':beam-runners-flink_2.11-job-server-container', project ':beam-runners-gearpump', project ':beam-runners-google-cloud-dataflow-java', project ':beam-runners-google-cloud-dataflow-java-examples', project ':beam-runners-google-cloud-dataflow-java-examples-streaming', project ':beam-runners-google-cloud-dataflow-java-fn-api-worker', project ':beam-runners-google-cloud-dataflow-java-legacy-worker', project ':beam-runners-google-cloud-dataflow-java-windmill', project ':beam-runners-java-fn-execution', project ':beam-runners-local-java-core', project ':beam-runners-reference-java', project ':beam-runners-reference-job-server', project ':beam-runners-samza', project ':beam-runners-spark', project ':beam-sdks-go', project ':beam-sdks-go-container', project ':beam-sdks-go-examples', project ':beam-sdks-go-test', project ':beam-sdks-java-build-tools', project ':beam-sdks-java-container', project ':beam-sdks-java-core', project ':beam-sdks-java-extensions-google-cloud-platform-core', project ':beam-sdks-java-extensions-join-library', project ':beam-sdks-java-extensions-json-jackson', project ':beam-sdks-java-extensions-protobuf', project ':beam-sdks-java-extensions-sketching', project ':beam-sdks-java-extensions-sorter', project ':beam-sdks-java-extensions-sql', project ':beam-sdks-java-extensions-sql-jdbc', project ':beam-sdks-java-extensions-sql-shell', project ':beam-sdks-java-fn-execution', project ':beam-sdks-java-harness', project ':beam-sdks-java-io-amazon-web-services', project ':beam-sdks-java-io-amqp', project ':beam-sdks-java-io-cassandra', project ':beam-sdks-java-io-common', project ':beam-sdks-java-io-elasticsearch', project ':beam-sdks-java-io-elasticsearch-tests-2', project ':beam-sdks-java-io-elasticsearch-tests-5', project ':beam-sdks-java-io-elasticsearch-tests-6', project ':beam-sdks-java-io-elasticsearch-tests-common', project ':beam-sdks-java-io-file-based-io-tests', project ':beam-sdks-java-io-google-cloud-platform', project ':beam-sdks-java-io-hadoop-common', project ':beam-sdks-java-io-hadoop-file-system', project ':beam-sdks-java-io-hadoop-input-format', project ':beam-sdks-java-io-hbase', project ':beam-sdks-java-io-hcatalog', project ':beam-sdks-java-io-jdbc', project ':beam-sdks-java-io-jms', project ':beam-sdks-java-io-kafka', project ':beam-sdks-java-io-kinesis', project ':beam-sdks-java-io-kudu', project ':beam-sdks-java-io-mongodb', project ':beam-sdks-java-io-mqtt', project ':beam-sdks-java-io-parquet', project ':beam-sdks-java-io-redis', project ':beam-sdks-java-io-solr', project ':beam-sdks-java-io-synthetic', project ':beam-sdks-java-io-tika', project ':beam-sdks-java-io-xml', project ':beam-sdks-java-javadoc', project ':beam-sdks-java-load-tests', project ':beam-sdks-java-maven-archetypes-examples', project ':beam-sdks-java-maven-archetypes-starter', project ':beam-sdks-java-nexmark', project ':beam-sdks-python', project ':beam-sdks-python-container', project ':beam-sdks-python-container-py3', project ':beam-vendor-sdks-java-extensions-protobuf', project ':beam-website', project ':release']
Parallel execution with configuration on demand is an incubating feature.
> Configure project :
Evaluating root project 'beam' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
> Configure project :beam-sdks-python
Evaluating project ':beam-sdks-python' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'.>
FAILURE: Build failed with an exception.
* What went wrong:
Task 'flinkValidatesRunner' not found in project ':beam-sdks-python'.
* Try:
Run gradlew tasks to get a list of available tasks. Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8s
Publishing build scan...
https://gradle.com/s/ovlsvyikj3eda
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #295
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/295/display/redirect?page=changes>
Changes:
[logan.hauspie.pro] [BEAM-4643] Allow to check early panes of a window
[logan.hauspie.pro] [BEAM-4643] Rebase after autoformating turned on
[github] Change plurality of method name to match existing.
[github] Change plurality of method name to match existing.
------------------------------------------
Started by GitHub push by akedin
[EnvInject] - Loading node environment variables.
Building remotely on beam15 (beam) in workspace <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/>
> git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
> git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
> git --version # timeout=10
> git fetch --tags --progress https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/* +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/*
> git rev-parse origin/master^{commit} # timeout=10
Checking out Revision c356c574312e2ee84de8e0abeaf66e77d29d521a (origin/master)
> git config core.sparsecheckout # timeout=10
> git checkout -f c356c574312e2ee84de8e0abeaf66e77d29d521a
Commit message: "Merge pull request #5811 from lhauspie/master"
> git rev-list --no-walk 4e132f387614ab37036e4eda49bed8dbe6c08c88 # timeout=10
Cleaning workspace
> git rev-parse --verify HEAD # timeout=10
Resetting working tree
> git reset --hard # timeout=10
> git clean -fdx # timeout=10
[EnvInject] - Executing scripts and injecting environment variables after the SCM step.
[EnvInject] - Injecting as environment variables the properties content
SPARK_LOCAL_IP=127.0.0.1
[EnvInject] - Variables injected successfully.
[Gradle] - Launching build.
[src] $ <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/gradlew> --info --continue --max-workers=12 -Dorg.gradle.jvmargs=-Xms2g -Dorg.gradle.jvmargs=-Xmx4g :beam-sdks-python:flinkValidatesRunner
Initialized native services in: /home/jenkins/.gradle/native
To honour the JVM settings for this build a new JVM will be forked. Please consider using the daemon: https://docs.gradle.org/4.10.2/userguide/gradle_daemon.html.
Starting process 'Gradle build daemon'. Working directory: /home/jenkins/.gradle/daemon/4.10.2 Command: /usr/local/asfpackages/java/jdk1.8.0_172/bin/java -Xmx4g -Dfile.encoding=UTF-8 -Duser.country=US -Duser.language=en -Duser.variant -cp /home/jenkins/.gradle/wrapper/dists/gradle-4.10.2-bin/cghg6c4gf4vkiutgsab8yrnwv/gradle-4.10.2/lib/gradle-launcher-4.10.2.jar org.gradle.launcher.daemon.bootstrap.GradleDaemon 4.10.2
Successfully started process 'Gradle build daemon'
An attempt to start the daemon took 0.889 secs.
The client will now receive all logging from the daemon (pid: 17988). The daemon log file: /home/jenkins/.gradle/daemon/4.10.2/daemon-17988.out.log
Closing daemon's stdin at end of input.
The daemon will no longer process any standard input.
Daemon will be stopped at the end of the build stopping after processing
Using 12 worker leases.
Starting Build
Parallel execution is an incubating feature.
> Configure project :buildSrc
Evaluating project ':buildSrc' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/build.gradle'.>
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Selected primary task 'build' from project :
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:compileJava (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
Using local directory build cache for build ':buildSrc' (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
> Task :buildSrc:compileJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/java',> not found
Skipping task ':buildSrc:compileJava' as it has no source files and no previous output files.
:buildSrc:compileJava (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.083 secs.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:compileGroovy FROM-CACHE
Build cache key for task ':buildSrc:compileGroovy' is ffa895a1cf2b1718eb804dc82ad66ea4
Task ':buildSrc:compileGroovy' is not up-to-date because:
No history is available.
Origin for task ':buildSrc:compileGroovy': {executionTime=2266, hostName=apache-beam-jenkins-slave-group-lbw6, operatingSystem=Linux, buildInvocationId=67p7cwv2jbh23lrdpokdubwxee, creationTime=1538771065235, type=org.gradle.api.tasks.compile.GroovyCompile_Decorated, userName=jenkins, gradleVersion=4.10.2, rootPath=<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc,> path=:compileGroovy}
Unpacked output for task ':buildSrc:compileGroovy' from cache.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.099 secs.
:buildSrc:processResources (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:processResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/resources',> not found
Skipping task ':buildSrc:processResources' as it has no source files and no previous output files.
:buildSrc:processResources (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.002 secs.
:buildSrc:classes (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:classes UP-TO-DATE
Skipping task ':buildSrc:classes' as it has no actions.
:buildSrc:classes (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:jar (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:jar
Build cache key for task ':buildSrc:jar' is 7445e5c45b21f8a690f2f547fcb49594
Caching disabled for task ':buildSrc:jar': Caching has not been enabled for the task
Task ':buildSrc:jar' is not up-to-date because:
No history is available.
:buildSrc:jar (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.119 secs.
:buildSrc:assemble (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:assemble
Skipping task ':buildSrc:assemble' as it has no actions.
:buildSrc:assemble (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessGroovy
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Caching disabled for task ':buildSrc:spotlessGroovy': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovy' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovy'.
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 1.336 secs.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessGroovyCheck
Skipping task ':buildSrc:spotlessGroovyCheck' as it has no actions.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.001 secs.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessGroovyGradle
Caching disabled for task ':buildSrc:spotlessGroovyGradle': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovyGradle' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovyGradle'.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.028 secs.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessGroovyGradleCheck
Skipping task ':buildSrc:spotlessGroovyGradleCheck' as it has no actions.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessCheck
Skipping task ':buildSrc:spotlessCheck' as it has no actions.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:compileTestJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/java',> not found
Skipping task ':buildSrc:compileTestJava' as it has no source files and no previous output files.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.002 secs.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:compileTestGroovy NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Skipping task ':buildSrc:compileTestGroovy' as it has no source files and no previous output files.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.002 secs.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/resources',> not found
Skipping task ':buildSrc:processTestResources' as it has no source files and no previous output files.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.002 secs.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:testClasses UP-TO-DATE
Skipping task ':buildSrc:testClasses' as it has no actions.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:test (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:test NO-SOURCE
Skipping task ':buildSrc:test' as it has no source files and no previous output files.
:buildSrc:test (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.004 secs.
:buildSrc:check (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:check
Skipping task ':buildSrc:check' as it has no actions.
:buildSrc:check (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:build (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:build
Skipping task ':buildSrc:build' as it has no actions.
:buildSrc:build (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
Settings evaluated using settings file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/settings.gradle'.>
Using local directory build cache for the root build (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
Projects loaded. Root project using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
Included projects: [root project 'beam', project ':beam-examples-java', project ':beam-model-fn-execution', project ':beam-model-job-management', project ':beam-model-pipeline', project ':beam-runners-apex', project ':beam-runners-core-construction-java', project ':beam-runners-core-java', project ':beam-runners-direct-java', project ':beam-runners-extensions-java-metrics', project ':beam-runners-flink_2.11', project ':beam-runners-flink_2.11-job-server', project ':beam-runners-flink_2.11-job-server-container', project ':beam-runners-gearpump', project ':beam-runners-google-cloud-dataflow-java', project ':beam-runners-google-cloud-dataflow-java-examples', project ':beam-runners-google-cloud-dataflow-java-examples-streaming', project ':beam-runners-google-cloud-dataflow-java-fn-api-worker', project ':beam-runners-google-cloud-dataflow-java-legacy-worker', project ':beam-runners-google-cloud-dataflow-java-windmill', project ':beam-runners-java-fn-execution', project ':beam-runners-local-java-core', project ':beam-runners-reference-java', project ':beam-runners-reference-job-server', project ':beam-runners-samza', project ':beam-runners-spark', project ':beam-sdks-go', project ':beam-sdks-go-container', project ':beam-sdks-go-examples', project ':beam-sdks-go-test', project ':beam-sdks-java-build-tools', project ':beam-sdks-java-container', project ':beam-sdks-java-core', project ':beam-sdks-java-extensions-google-cloud-platform-core', project ':beam-sdks-java-extensions-join-library', project ':beam-sdks-java-extensions-json-jackson', project ':beam-sdks-java-extensions-protobuf', project ':beam-sdks-java-extensions-sketching', project ':beam-sdks-java-extensions-sorter', project ':beam-sdks-java-extensions-sql', project ':beam-sdks-java-extensions-sql-jdbc', project ':beam-sdks-java-extensions-sql-shell', project ':beam-sdks-java-fn-execution', project ':beam-sdks-java-harness', project ':beam-sdks-java-io-amazon-web-services', project ':beam-sdks-java-io-amqp', project ':beam-sdks-java-io-cassandra', project ':beam-sdks-java-io-common', project ':beam-sdks-java-io-elasticsearch', project ':beam-sdks-java-io-elasticsearch-tests-2', project ':beam-sdks-java-io-elasticsearch-tests-5', project ':beam-sdks-java-io-elasticsearch-tests-6', project ':beam-sdks-java-io-elasticsearch-tests-common', project ':beam-sdks-java-io-file-based-io-tests', project ':beam-sdks-java-io-google-cloud-platform', project ':beam-sdks-java-io-hadoop-common', project ':beam-sdks-java-io-hadoop-file-system', project ':beam-sdks-java-io-hadoop-input-format', project ':beam-sdks-java-io-hbase', project ':beam-sdks-java-io-hcatalog', project ':beam-sdks-java-io-jdbc', project ':beam-sdks-java-io-jms', project ':beam-sdks-java-io-kafka', project ':beam-sdks-java-io-kinesis', project ':beam-sdks-java-io-kudu', project ':beam-sdks-java-io-mongodb', project ':beam-sdks-java-io-mqtt', project ':beam-sdks-java-io-parquet', project ':beam-sdks-java-io-redis', project ':beam-sdks-java-io-solr', project ':beam-sdks-java-io-synthetic', project ':beam-sdks-java-io-tika', project ':beam-sdks-java-io-xml', project ':beam-sdks-java-javadoc', project ':beam-sdks-java-load-tests', project ':beam-sdks-java-maven-archetypes-examples', project ':beam-sdks-java-maven-archetypes-starter', project ':beam-sdks-java-nexmark', project ':beam-sdks-python', project ':beam-sdks-python-container', project ':beam-sdks-python-container-py3', project ':beam-vendor-sdks-java-extensions-protobuf', project ':beam-website', project ':release']
Parallel execution with configuration on demand is an incubating feature.
> Configure project :
Evaluating root project 'beam' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
> Configure project :beam-sdks-python
Evaluating project ':beam-sdks-python' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'.>
FAILURE: Build failed with an exception.
* What went wrong:
Task 'flinkValidatesRunner' not found in project ':beam-sdks-python'.
* Try:
Run gradlew tasks to get a list of available tasks. Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8s
Publishing build scan...
https://gradle.com/s/33mqoy2wx4af2
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #294
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/294/display/redirect?page=changes>
Changes:
[github] Update outdated TFRecords format detail reference
------------------------------------------
Started by GitHub push by akedin
[EnvInject] - Loading node environment variables.
Building remotely on beam15 (beam) in workspace <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/>
> git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
> git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
> git --version # timeout=10
> git fetch --tags --progress https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/* +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/*
> git rev-parse origin/master^{commit} # timeout=10
Checking out Revision 4e132f387614ab37036e4eda49bed8dbe6c08c88 (origin/master)
> git config core.sparsecheckout # timeout=10
> git checkout -f 4e132f387614ab37036e4eda49bed8dbe6c08c88
Commit message: "Merge pull request #6604 from terrytangyuan/patch-2"
> git rev-list --no-walk 4afd5ec3706344e40083a81d53e73436a4c0b513 # timeout=10
Cleaning workspace
> git rev-parse --verify HEAD # timeout=10
Resetting working tree
> git reset --hard # timeout=10
> git clean -fdx # timeout=10
[EnvInject] - Executing scripts and injecting environment variables after the SCM step.
[EnvInject] - Injecting as environment variables the properties content
SPARK_LOCAL_IP=127.0.0.1
[EnvInject] - Variables injected successfully.
[Gradle] - Launching build.
[src] $ <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/gradlew> --info --continue --max-workers=12 -Dorg.gradle.jvmargs=-Xms2g -Dorg.gradle.jvmargs=-Xmx4g :beam-sdks-python:flinkValidatesRunner
Initialized native services in: /home/jenkins/.gradle/native
To honour the JVM settings for this build a new JVM will be forked. Please consider using the daemon: https://docs.gradle.org/4.10.2/userguide/gradle_daemon.html.
Starting process 'Gradle build daemon'. Working directory: /home/jenkins/.gradle/daemon/4.10.2 Command: /usr/local/asfpackages/java/jdk1.8.0_172/bin/java -Xmx4g -Dfile.encoding=UTF-8 -Duser.country=US -Duser.language=en -Duser.variant -cp /home/jenkins/.gradle/wrapper/dists/gradle-4.10.2-bin/cghg6c4gf4vkiutgsab8yrnwv/gradle-4.10.2/lib/gradle-launcher-4.10.2.jar org.gradle.launcher.daemon.bootstrap.GradleDaemon 4.10.2
Successfully started process 'Gradle build daemon'
An attempt to start the daemon took 0.972 secs.
The client will now receive all logging from the daemon (pid: 6423). The daemon log file: /home/jenkins/.gradle/daemon/4.10.2/daemon-6423.out.log
Closing daemon's stdin at end of input.
The daemon will no longer process any standard input.
Daemon will be stopped at the end of the build stopping after processing
Using 12 worker leases.
Starting Build
Parallel execution is an incubating feature.
> Configure project :buildSrc
Evaluating project ':buildSrc' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/build.gradle'.>
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Selected primary task 'build' from project :
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:compileJava (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
Using local directory build cache for build ':buildSrc' (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
> Task :buildSrc:compileJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/java',> not found
Skipping task ':buildSrc:compileJava' as it has no source files and no previous output files.
:buildSrc:compileJava (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.092 secs.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:compileGroovy FROM-CACHE
Build cache key for task ':buildSrc:compileGroovy' is ffa895a1cf2b1718eb804dc82ad66ea4
Task ':buildSrc:compileGroovy' is not up-to-date because:
No history is available.
Origin for task ':buildSrc:compileGroovy': {executionTime=2266, hostName=apache-beam-jenkins-slave-group-lbw6, operatingSystem=Linux, buildInvocationId=67p7cwv2jbh23lrdpokdubwxee, creationTime=1538771065235, type=org.gradle.api.tasks.compile.GroovyCompile_Decorated, userName=jenkins, gradleVersion=4.10.2, rootPath=<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc,> path=:compileGroovy}
Unpacked output for task ':buildSrc:compileGroovy' from cache.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.104 secs.
:buildSrc:processResources (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:processResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/main/resources',> not found
Skipping task ':buildSrc:processResources' as it has no source files and no previous output files.
:buildSrc:processResources (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.004 secs.
:buildSrc:classes (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:classes UP-TO-DATE
Skipping task ':buildSrc:classes' as it has no actions.
:buildSrc:classes (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.0 secs.
:buildSrc:jar (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:jar
Build cache key for task ':buildSrc:jar' is 7445e5c45b21f8a690f2f547fcb49594
Caching disabled for task ':buildSrc:jar': Caching has not been enabled for the task
Task ':buildSrc:jar' is not up-to-date because:
No history is available.
:buildSrc:jar (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.123 secs.
:buildSrc:assemble (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:assemble
Skipping task ':buildSrc:assemble' as it has no actions.
:buildSrc:assemble (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.001 secs.
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:spotlessGroovy
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Caching disabled for task ':buildSrc:spotlessGroovy': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovy' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovy'.
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 1.483 secs.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:spotlessGroovyCheck
Skipping task ':buildSrc:spotlessGroovyCheck' as it has no actions.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.001 secs.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:spotlessGroovyGradle
Caching disabled for task ':buildSrc:spotlessGroovyGradle': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovyGradle' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovyGradle'.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.039 secs.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:spotlessGroovyGradleCheck
Skipping task ':buildSrc:spotlessGroovyGradleCheck' as it has no actions.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:spotlessCheck
Skipping task ':buildSrc:spotlessCheck' as it has no actions.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.0 secs.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:compileTestJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/java',> not found
Skipping task ':buildSrc:compileTestJava' as it has no source files and no previous output files.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.003 secs.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:compileTestGroovy NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/groovy',> not found
Skipping task ':buildSrc:compileTestGroovy' as it has no source files and no previous output files.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.004 secs.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/buildSrc/src/test/resources',> not found
Skipping task ':buildSrc:processTestResources' as it has no source files and no previous output files.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.002 secs.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:testClasses UP-TO-DATE
Skipping task ':buildSrc:testClasses' as it has no actions.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.0 secs.
:buildSrc:test (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:test NO-SOURCE
Skipping task ':buildSrc:test' as it has no source files and no previous output files.
:buildSrc:test (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.005 secs.
:buildSrc:check (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:check
Skipping task ':buildSrc:check' as it has no actions.
:buildSrc:check (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.0 secs.
:buildSrc:build (Thread[Task worker for ':buildSrc' Thread 5,5,main]) started.
> Task :buildSrc:build
Skipping task ':buildSrc:build' as it has no actions.
:buildSrc:build (Thread[Task worker for ':buildSrc' Thread 5,5,main]) completed. Took 0.0 secs.
Settings evaluated using settings file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/settings.gradle'.>
Using local directory build cache for the root build (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
Projects loaded. Root project using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
Included projects: [root project 'beam', project ':beam-examples-java', project ':beam-model-fn-execution', project ':beam-model-job-management', project ':beam-model-pipeline', project ':beam-runners-apex', project ':beam-runners-core-construction-java', project ':beam-runners-core-java', project ':beam-runners-direct-java', project ':beam-runners-extensions-java-metrics', project ':beam-runners-flink_2.11', project ':beam-runners-flink_2.11-job-server', project ':beam-runners-flink_2.11-job-server-container', project ':beam-runners-gearpump', project ':beam-runners-google-cloud-dataflow-java', project ':beam-runners-google-cloud-dataflow-java-examples', project ':beam-runners-google-cloud-dataflow-java-examples-streaming', project ':beam-runners-google-cloud-dataflow-java-fn-api-worker', project ':beam-runners-google-cloud-dataflow-java-legacy-worker', project ':beam-runners-google-cloud-dataflow-java-windmill', project ':beam-runners-java-fn-execution', project ':beam-runners-local-java-core', project ':beam-runners-reference-java', project ':beam-runners-reference-job-server', project ':beam-runners-samza', project ':beam-runners-spark', project ':beam-sdks-go', project ':beam-sdks-go-container', project ':beam-sdks-go-examples', project ':beam-sdks-go-test', project ':beam-sdks-java-build-tools', project ':beam-sdks-java-container', project ':beam-sdks-java-core', project ':beam-sdks-java-extensions-google-cloud-platform-core', project ':beam-sdks-java-extensions-join-library', project ':beam-sdks-java-extensions-json-jackson', project ':beam-sdks-java-extensions-protobuf', project ':beam-sdks-java-extensions-sketching', project ':beam-sdks-java-extensions-sorter', project ':beam-sdks-java-extensions-sql', project ':beam-sdks-java-extensions-sql-jdbc', project ':beam-sdks-java-extensions-sql-shell', project ':beam-sdks-java-fn-execution', project ':beam-sdks-java-harness', project ':beam-sdks-java-io-amazon-web-services', project ':beam-sdks-java-io-amqp', project ':beam-sdks-java-io-cassandra', project ':beam-sdks-java-io-common', project ':beam-sdks-java-io-elasticsearch', project ':beam-sdks-java-io-elasticsearch-tests-2', project ':beam-sdks-java-io-elasticsearch-tests-5', project ':beam-sdks-java-io-elasticsearch-tests-6', project ':beam-sdks-java-io-elasticsearch-tests-common', project ':beam-sdks-java-io-file-based-io-tests', project ':beam-sdks-java-io-google-cloud-platform', project ':beam-sdks-java-io-hadoop-common', project ':beam-sdks-java-io-hadoop-file-system', project ':beam-sdks-java-io-hadoop-input-format', project ':beam-sdks-java-io-hbase', project ':beam-sdks-java-io-hcatalog', project ':beam-sdks-java-io-jdbc', project ':beam-sdks-java-io-jms', project ':beam-sdks-java-io-kafka', project ':beam-sdks-java-io-kinesis', project ':beam-sdks-java-io-kudu', project ':beam-sdks-java-io-mongodb', project ':beam-sdks-java-io-mqtt', project ':beam-sdks-java-io-parquet', project ':beam-sdks-java-io-redis', project ':beam-sdks-java-io-solr', project ':beam-sdks-java-io-synthetic', project ':beam-sdks-java-io-tika', project ':beam-sdks-java-io-xml', project ':beam-sdks-java-javadoc', project ':beam-sdks-java-load-tests', project ':beam-sdks-java-maven-archetypes-examples', project ':beam-sdks-java-maven-archetypes-starter', project ':beam-sdks-java-nexmark', project ':beam-sdks-python', project ':beam-sdks-python-container', project ':beam-sdks-python-container-py3', project ':beam-vendor-sdks-java-extensions-protobuf', project ':beam-website', project ':release']
Parallel execution with configuration on demand is an incubating feature.
> Configure project :
Evaluating root project 'beam' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/build.gradle'.>
> Configure project :beam-sdks-python
Evaluating project ':beam-sdks-python' using build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'.>
FAILURE: Build failed with an exception.
* What went wrong:
Task 'flinkValidatesRunner' not found in project ':beam-sdks-python'.
* Try:
Run gradlew tasks to get a list of available tasks. Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 9s
Publishing build scan...
https://gradle.com/s/lnjnjaykvdrga
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #293
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/293/display/redirect?page=changes>
Changes:
[huangry] Fix the issue of using str while byte is required in a few unit tests
[aaltay] [BEAM-5315] Partially port io (#6590)
[aaltay] [BEAM-5633] Adds reconnect logic to python logging client (#6593)
------------------------------------------
[...truncated 51.08 MB...]
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (15601cf01046ed8849a252934794b56f) [FINISHED]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (46734e9ddc762903e32e936e2aa021db) [FINISHED]
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (d961053d01570ef977e0707982dbae2f) [FINISHED]
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (11/16) (7ffb82839f374f4bc0cd51bb92d9b60c) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (3d7ef4564839cd6b5e837471a5a01ea5) [FINISHED]
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (11/16) (7ffb82839f374f4bc0cd51bb92d9b60c).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 90cb2362cd9a1f3fc5c98227d91280c9.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (37e9d2d2402abfcbc80841718e7c7cff) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 33f9dc4cd01b962849a8e5319c866064.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16) (7ffb82839f374f4bc0cd51bb92d9b60c) [FINISHED]
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (15/16) (ab37e0bf1ebce6d308d1d19d672accf6) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (2914c3bb261091f9f3c0d21b19f70623) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (2914c3bb261091f9f3c0d21b19f70623).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 9d49f2da08f2e52728359c7282a22f23.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (15/16) (ab37e0bf1ebce6d308d1d19d672accf6).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (2914c3bb261091f9f3c0d21b19f70623) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (b4d6c75e9cb458a633a6200c1911d649) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) (ab37e0bf1ebce6d308d1d19d672accf6) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (164e7b689afef864bf894974939dd4cc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 41c313b2ec24aef165e81125122be7ca.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (bd9f186caf294025a63eab726508ac7e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (7b0959f713f04654e6f3096208d243e7) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (13/16) (5124aa12391f875de31d1eafb156fa64) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (13/16) (5124aa12391f875de31d1eafb156fa64).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 76610a0af4ee1a3bce65a473d67e90b4.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (5124aa12391f875de31d1eafb156fa64) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (a34093327420e53da675884cd816baea) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (fb83e9d9a5bf49f6da53dc64004af7a8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 21aa8ae75cd05009125391fe26b6c72e.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 405e85fb9424411d2852c1f5bce4c016.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (3445f476c8748662389d02b67e4305cd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 15601cf01046ed8849a252934794b56f.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (858102ac777f5699722572f680850fbb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 46734e9ddc762903e32e936e2aa021db.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 d961053d01570ef977e0707982dbae2f.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (90cb2362cd9a1f3fc5c98227d91280c9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 3d7ef4564839cd6b5e837471a5a01ea5.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (33f9dc4cd01b962849a8e5319c866064) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 37e9d2d2402abfcbc80841718e7c7cff.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 7ffb82839f374f4bc0cd51bb92d9b60c.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 2914c3bb261091f9f3c0d21b19f70623.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem ab37e0bf1ebce6d308d1d19d672accf6.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 5124aa12391f875de31d1eafb156fa64.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (9d49f2da08f2e52728359c7282a22f23) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (41c313b2ec24aef165e81125122be7ca) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/16) (4f4f681545ed97d26fa98e697f07756b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/16) (4f4f681545ed97d26fa98e697f07756b).
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) (4f4f681545ed97d26fa98e697f07756b) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 4f4f681545ed97d26fa98e697f07756b.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (76610a0af4ee1a3bce65a473d67e90b4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (21aa8ae75cd05009125391fe26b6c72e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (405e85fb9424411d2852c1f5bce4c016) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (15601cf01046ed8849a252934794b56f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (46734e9ddc762903e32e936e2aa021db) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (d961053d01570ef977e0707982dbae2f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (3d7ef4564839cd6b5e837471a5a01ea5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (37e9d2d2402abfcbc80841718e7c7cff) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (7ffb82839f374f4bc0cd51bb92d9b60c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (2914c3bb261091f9f3c0d21b19f70623) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (ab37e0bf1ebce6d308d1d19d672accf6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (5124aa12391f875de31d1eafb156fa64) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (4f4f681545ed97d26fa98e697f07756b) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (f03620ca21b9fef3fb3ae28ee24068d6) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (f03620ca21b9fef3fb3ae28ee24068d6).
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (f03620ca21b9fef3fb3ae28ee24068d6) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 f03620ca21b9fef3fb3ae28ee24068d6.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (6af9443ee755991d35958f9bbe0b9eb6) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (6af9443ee755991d35958f9bbe0b9eb6).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (f03620ca21b9fef3fb3ae28ee24068d6) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (d5fb11cd3ecd15b49f4d7d2fa57007dc) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (54f8f7af9cd26b3135efdc1b2a78fa91) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (b0de45c0085e9a1ec7cf65a035daecae) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (3b1c1d086f5bea2905095f59549dc7fd) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (7cc4787eb951aa700838aeec4b5053b6) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (2915688c37678b0833016b18f70c17ff) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (54f8f7af9cd26b3135efdc1b2a78fa91).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (d5fb11cd3ecd15b49f4d7d2fa57007dc).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (54f8f7af9cd26b3135efdc1b2a78fa91) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (15dcd82685b48deea3c7eff5caa9923a) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (d5fb11cd3ecd15b49f4d7d2fa57007dc) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (2915688c37678b0833016b18f70c17ff).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 d5fb11cd3ecd15b49f4d7d2fa57007dc.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (1920ed77941b3f9fd530d507566dc99c) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (667b1b37c33d4d96b1f6a5c18087c626) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (667b1b37c33d4d96b1f6a5c18087c626).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (6af9443ee755991d35958f9bbe0b9eb6) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (3b1c1d086f5bea2905095f59549dc7fd).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (5532204a50edba72c3d41e38550e9f26) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (abca06e9a7cc5344e396f4a82dfdc177) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (b0de45c0085e9a1ec7cf65a035daecae).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (abca06e9a7cc5344e396f4a82dfdc177).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (194848641aab2e59977b269e416dd047) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (194848641aab2e59977b269e416dd047).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (5532204a50edba72c3d41e38550e9f26).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (1920ed77941b3f9fd530d507566dc99c).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 54f8f7af9cd26b3135efdc1b2a78fa91.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (08ef400a9a5184a1e6a20f4792bdf809) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (08ef400a9a5184a1e6a20f4792bdf809).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (7cc4787eb951aa700838aeec4b5053b6).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (6911d9c37aed97cf61ba886cff17cab8) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (6911d9c37aed97cf61ba886cff17cab8).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (15dcd82685b48deea3c7eff5caa9923a).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (7994e2ca42fbfc95d7223ba3ae900bb3) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (7994e2ca42fbfc95d7223ba3ae900bb3).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 6af9443ee755991d35958f9bbe0b9eb6.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (d5fb11cd3ecd15b49f4d7d2fa57007dc) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (2915688c37678b0833016b18f70c17ff) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (54f8f7af9cd26b3135efdc1b2a78fa91) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (7994e2ca42fbfc95d7223ba3ae900bb3) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (15dcd82685b48deea3c7eff5caa9923a) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (6911d9c37aed97cf61ba886cff17cab8) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 2915688c37678b0833016b18f70c17ff.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (7cc4787eb951aa700838aeec4b5053b6) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (1920ed77941b3f9fd530d507566dc99c) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (6af9443ee755991d35958f9bbe0b9eb6) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (5532204a50edba72c3d41e38550e9f26) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (08ef400a9a5184a1e6a20f4792bdf809) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (abca06e9a7cc5344e396f4a82dfdc177) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (b0de45c0085e9a1ec7cf65a035daecae) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (3b1c1d086f5bea2905095f59549dc7fd) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (194848641aab2e59977b269e416dd047) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (667b1b37c33d4d96b1f6a5c18087c626) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 7994e2ca42fbfc95d7223ba3ae900bb3.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 b0de45c0085e9a1ec7cf65a035daecae.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (2915688c37678b0833016b18f70c17ff) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 3b1c1d086f5bea2905095f59549dc7fd.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 08ef400a9a5184a1e6a20f4792bdf809.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (7994e2ca42fbfc95d7223ba3ae900bb3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 194848641aab2e59977b269e416dd047.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 667b1b37c33d4d96b1f6a5c18087c626.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (b0de45c0085e9a1ec7cf65a035daecae) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 abca06e9a7cc5344e396f4a82dfdc177.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (3b1c1d086f5bea2905095f59549dc7fd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 5532204a50edba72c3d41e38550e9f26.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 7cc4787eb951aa700838aeec4b5053b6.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (08ef400a9a5184a1e6a20f4792bdf809) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 6911d9c37aed97cf61ba886cff17cab8.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (194848641aab2e59977b269e416dd047) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 1920ed77941b3f9fd530d507566dc99c.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 15dcd82685b48deea3c7eff5caa9923a.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (667b1b37c33d4d96b1f6a5c18087c626) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (abca06e9a7cc5344e396f4a82dfdc177) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (5532204a50edba72c3d41e38550e9f26) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (7cc4787eb951aa700838aeec4b5053b6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (6911d9c37aed97cf61ba886cff17cab8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (1920ed77941b3f9fd530d507566dc99c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (15dcd82685b48deea3c7eff5caa9923a) switched from RUNNING to FINISHED.
[grpc-default-executor-0] INFO sdk_worker.run - No more requests from control plane
[grpc-default-executor-0] INFO sdk_worker.run - SDK Harness waiting for in-flight requests to complete
[grpc-default-executor-0] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-0] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-0] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-0] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-0] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client hanged up.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (3c397b7a98641e4a0b63ab5c4cd7c027) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (3c397b7a98641e4a0b63ab5c4cd7c027).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (3c397b7a98641e4a0b63ab5c4cd7c027) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 3c397b7a98641e4a0b63ab5c4cd7c027.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (3c397b7a98641e4a0b63ab5c4cd7c027) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1539116157.89 (96613c2430ec325c42505cb7b98fa3e8) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 96613c2430ec325c42505cb7b98fa3e8.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 96613c2430ec325c42505cb7b98fa3e8 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job test_windowing_1539116157.89(96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 96613c2430ec325c42505cb7b98fa3e8.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 2fafacf3d8d3b3b5ba2909113239ff68: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher24b341b5-494d-4d35-bdd9-21453930edc9.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher24b341b5-494d-4d35-bdd9-21453930edc9.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcActor - The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is started.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 8da17399ed7cdf000ae6cd8ebc244d6e@akka://flink/user/jobmanager_39 for job 96613c2430ec325c42505cb7b98fa3e8 from the resource manager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d286fc1f91d0f5a9a6e586665cd3f54c}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 8bd85d73d5c3688390d6869a2b60bee6 from the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{bdc747478ce252cda95cd1b7b6a4835e}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6b642868884fa218e27f853a34198e8c}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{93ac001a0ad3342069933aa0f0a3951e}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4eb01031fbf1b43d1d466a8b3b467430}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{5f9b1359e3fec3e79c9f86e1aa7135a2}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{1efe01554ca0a2a538f42889401b7bc4}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{9cf7ff906430497c13c0e6d7c1f077c3}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 96613c2430ec325c42505cb7b98fa3e8 with leader id 8da17399ed7cdf000ae6cd8ebc244d6e lost leadership.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{f2738811489f1772f48a5fe761134dec}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{917b3bc3b014a4cb7d9af75804f62435}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{10c812a071fe1a4597f562424b2faa34}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d305964b576934878c11b1930b8dc44d}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{243531e9f337ab8f4177df1b6f6c802c}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b655ac439575f701ff2cd28a6592d0b4}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{7e7c9e9c400e882b69e7ca9d62882f86}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Could not resolve JobManager address akka://flink/user/jobmanager_39, retrying in 10000 ms: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_39..
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a581cb651e70e0c02c5db2cdbef6e2c4}, jobId: 96613c2430ec325c42505cb7b98fa3e8).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 96613c2430ec325c42505cb7b98fa3e8 from job leader monitoring.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 96613c2430ec325c42505cb7b98fa3e8.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-5de844cd-e307-41c7-88a8-d1249e5e2163
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher24b341b5-494d-4d35-bdd9-21453930edc9.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_38.
[ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:44637
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 2069 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@6be46686
.
----------------------------------------------------------------------
Ran 25 tests in 83.179s
OK (skipped=7)
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Daemon worker,5,main]) completed. Took 1 mins 25.417 secs.
FAILURE: Build failed with an exception.
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 351
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatch'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 11m 19s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/2vvm7s2mpddey
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #292
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/292/display/redirect?page=changes>
Changes:
[juta_staes] [BEAM-5615] fix cmp is an invalid keyword for sort function in python 3
------------------------------------------
[...truncated 51.09 MB...]
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (17926c3672addf7266ccbcbbaa7b879d) [FINISHED]
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (87769a7843f378c00a5c87de631b2872).
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16) (167dbd3e25d5a8b5eeb23f331c147367) [FINISHED]
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (8/16) (4267081be406beba72761f8df1976ec7).
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16) (2e0fc44e169ea7cca35232c9e49615f1) [FINISHED]
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16) (4267081be406beba72761f8df1976ec7) [FINISHED]
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (4/16) (fb3749fc397bd98ad3a0896c0d0568a2).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (04615f974f929973619c1d9e6aa3ea48) [FINISHED]
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16) (fb3749fc397bd98ad3a0896c0d0568a2) [FINISHED]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (f6e349e5602cfd87aae98715b4c75d72) [FINISHED]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16) (b2dc3f1d458048a2feee650db024dee0) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (cbb033e18505a9a64dcbde364af92138) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (87769a7843f378c00a5c87de631b2872) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem f8a858479f37e49aefa2796088191957.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 725e03680e963fa76c4587fd90a8c281.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem e2b99d0225d71bfa3a9ffecf67895131.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 2bbc841cd2bcdcdb5c4660590bdad8c6.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (af47353a48b58ca5dbec2efcabfdd47c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 382fc0bb9c4647b4f7542bcbb5de79f0.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (cdc867ea3d1b11edfb686420ced4174e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (dca89bd916874b112c74d210c28e5b65) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 1a0d91b50b96e5b24cc6f580bc5345f2.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 cedf6494c5e8e19dadfefc9e83abc66e.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (86e58f72c67d01e46ffaf508afef9248) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem fcf953c444ef10db0fb9cde79499a5d7.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (f8a858479f37e49aefa2796088191957) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 b0423b37fbfb8e24df1866c8d53b179b.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (725e03680e963fa76c4587fd90a8c281) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (e2b99d0225d71bfa3a9ffecf67895131) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 608acd0617043b63c7bfa5238f2177e7.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (2bbc841cd2bcdcdb5c4660590bdad8c6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 14813df45f76345b6736dddb186ffd44.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem a4028aca5934cfa7aab7c27961e03b84.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (382fc0bb9c4647b4f7542bcbb5de79f0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 f89aac9b1522c302a5568dbdb33a7728.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (1a0d91b50b96e5b24cc6f580bc5345f2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 17926c3672addf7266ccbcbbaa7b879d.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 167dbd3e25d5a8b5eeb23f331c147367.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (cedf6494c5e8e19dadfefc9e83abc66e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 2e0fc44e169ea7cca35232c9e49615f1.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 4267081be406beba72761f8df1976ec7.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem fb3749fc397bd98ad3a0896c0d0568a2.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (fcf953c444ef10db0fb9cde79499a5d7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem f6e349e5602cfd87aae98715b4c75d72.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem b2dc3f1d458048a2feee650db024dee0.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 04615f974f929973619c1d9e6aa3ea48.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 87769a7843f378c00a5c87de631b2872.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (b0423b37fbfb8e24df1866c8d53b179b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (608acd0617043b63c7bfa5238f2177e7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (14813df45f76345b6736dddb186ffd44) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (a4028aca5934cfa7aab7c27961e03b84) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (f89aac9b1522c302a5568dbdb33a7728) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (17926c3672addf7266ccbcbbaa7b879d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (167dbd3e25d5a8b5eeb23f331c147367) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (2e0fc44e169ea7cca35232c9e49615f1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (4267081be406beba72761f8df1976ec7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (fb3749fc397bd98ad3a0896c0d0568a2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (f6e349e5602cfd87aae98715b4c75d72) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (b2dc3f1d458048a2feee650db024dee0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (04615f974f929973619c1d9e6aa3ea48) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (87769a7843f378c00a5c87de631b2872) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (0387e316fb2cc74f8f57c8ef5272a025) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (0387e316fb2cc74f8f57c8ef5272a025).
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (0387e316fb2cc74f8f57c8ef5272a025) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 0387e316fb2cc74f8f57c8ef5272a025.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (705be06ae3b7fa08aee24b748751b98c) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (705be06ae3b7fa08aee24b748751b98c).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (705be06ae3b7fa08aee24b748751b98c) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (3ac794dd455185cd5dddeae0c5031f66) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (3ac794dd455185cd5dddeae0c5031f66).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (0387e316fb2cc74f8f57c8ef5272a025) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (57f9a3cffe933a348f02acfbafb131cd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 705be06ae3b7fa08aee24b748751b98c.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (57f9a3cffe933a348f02acfbafb131cd).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (a7ce2f91546efc51a3c0585fc11a14ff) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (a7ce2f91546efc51a3c0585fc11a14ff).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (705be06ae3b7fa08aee24b748751b98c) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (12c2168d8a34b302b6fff0d1cb116067) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (12c2168d8a34b302b6fff0d1cb116067).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (6361087c207be07a6fcc14474a28b548) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (6361087c207be07a6fcc14474a28b548).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (3ac794dd455185cd5dddeae0c5031f66) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (cf82c0d023e0ccf096463a3f290963f3) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (6361087c207be07a6fcc14474a28b548) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (a7ce2f91546efc51a3c0585fc11a14ff) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (57f9a3cffe933a348f02acfbafb131cd) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 6361087c207be07a6fcc14474a28b548.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (5dafa6c05eb6e8ea7ecd8b698090890c) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (5dafa6c05eb6e8ea7ecd8b698090890c).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (4ee92465bb728fb422e815a7ccce9a79) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (12c2168d8a34b302b6fff0d1cb116067) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (cf82c0d023e0ccf096463a3f290963f3).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (4ee92465bb728fb422e815a7ccce9a79).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 a7ce2f91546efc51a3c0585fc11a14ff.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 57f9a3cffe933a348f02acfbafb131cd.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (6361087c207be07a6fcc14474a28b548) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 12c2168d8a34b302b6fff0d1cb116067.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 3ac794dd455185cd5dddeae0c5031f66.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (a7ce2f91546efc51a3c0585fc11a14ff) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (12ef666b658cc009f4bbe74a0cefe8a0) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (12ef666b658cc009f4bbe74a0cefe8a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (57f9a3cffe933a348f02acfbafb131cd) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (41c422295028fcc5a4d5f83c5dc901ff) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (41c422295028fcc5a4d5f83c5dc901ff).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (12c2168d8a34b302b6fff0d1cb116067) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (5dafa6c05eb6e8ea7ecd8b698090890c) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 5dafa6c05eb6e8ea7ecd8b698090890c.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (87c89f86d6cea9a320e58cee6fb7617e) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (87c89f86d6cea9a320e58cee6fb7617e).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (3ac794dd455185cd5dddeae0c5031f66) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (41c422295028fcc5a4d5f83c5dc901ff) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (13f6c3266b7bc71df6400ca5a15259ab) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (7719b2087f41a128fa8020041f707ce2) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (7719b2087f41a128fa8020041f707ce2).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (13f6c3266b7bc71df6400ca5a15259ab).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (7719b2087f41a128fa8020041f707ce2) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 41c422295028fcc5a4d5f83c5dc901ff.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16) (5dafa6c05eb6e8ea7ecd8b698090890c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 7719b2087f41a128fa8020041f707ce2.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (576077248c0af9dca8c91e623eb98cd2) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (13f6c3266b7bc71df6400ca5a15259ab) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (576077248c0af9dca8c91e623eb98cd2).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (fe86050c1765bcc411c2dcf7ca8240a8) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (fe86050c1765bcc411c2dcf7ca8240a8).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (41c422295028fcc5a4d5f83c5dc901ff) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (12ef666b658cc009f4bbe74a0cefe8a0) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 13f6c3266b7bc71df6400ca5a15259ab.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (7719b2087f41a128fa8020041f707ce2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 12ef666b658cc009f4bbe74a0cefe8a0.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (4ee92465bb728fb422e815a7ccce9a79) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (cf82c0d023e0ccf096463a3f290963f3) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (13f6c3266b7bc71df6400ca5a15259ab) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 4ee92465bb728fb422e815a7ccce9a79.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 cf82c0d023e0ccf096463a3f290963f3.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (fe86050c1765bcc411c2dcf7ca8240a8) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (12ef666b658cc009f4bbe74a0cefe8a0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 fe86050c1765bcc411c2dcf7ca8240a8.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (4ee92465bb728fb422e815a7ccce9a79) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (576077248c0af9dca8c91e623eb98cd2) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (87c89f86d6cea9a320e58cee6fb7617e) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (cf82c0d023e0ccf096463a3f290963f3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 576077248c0af9dca8c91e623eb98cd2.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (fe86050c1765bcc411c2dcf7ca8240a8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 87c89f86d6cea9a320e58cee6fb7617e.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (576077248c0af9dca8c91e623eb98cd2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (87c89f86d6cea9a320e58cee6fb7617e) switched from RUNNING to FINISHED.
[grpc-default-executor-4] INFO sdk_worker.run - No more requests from control plane
[grpc-default-executor-4] INFO sdk_worker.run - SDK Harness waiting for in-flight requests to complete
[grpc-default-executor-4] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-4] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-4] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-4] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-4] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client hanged up.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (9209f1028a06a4aa2ea1f303e5e9f864) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (9209f1028a06a4aa2ea1f303e5e9f864).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (9209f1028a06a4aa2ea1f303e5e9f864) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 9209f1028a06a4aa2ea1f303e5e9f864.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (9209f1028a06a4aa2ea1f303e5e9f864) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1539115469.82 (f0456a83c44cdc52fa0bf1c880656594) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job f0456a83c44cdc52fa0bf1c880656594.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job f0456a83c44cdc52fa0bf1c880656594 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job test_windowing_1539115469.82(f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f0456a83c44cdc52fa0bf1c880656594.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher6c570653-3e05-4b2a-8ff1-88d7810d7bf6.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher6c570653-3e05-4b2a-8ff1-88d7810d7bf6.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 1dc485cea58b3b3e529d6f6be3d1b920: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b0701a6fb9bb33292c2ae344eb21b653}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcActor - The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is started.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{caf949501e44febc651268b982ba2750}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 07726f46a965ad2b3a8461f80d64908c from the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{01ad77e30e0343e35da0e3b051d37cd7}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{06d2f73405d54ffc03c0027a9d7922f3}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{7c80638406596c4fd516b851dec3d02b}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job f0456a83c44cdc52fa0bf1c880656594 with leader id 976d237b6b719c43a2f524f54fe04295 lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{75a50a2548dc760f5832e8e4bae4fa99}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{5f630e4ddf9cce90fb5690aeaa75bb1b}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{9fb636253f63d307c057e5815ed22f5f}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{8fcc7a3594c98aea1d6a3c853ed32468}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d3be04d9b976725763c26b25229a0c2e}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ee509438f8da948bfaa6ddfdd40b11cd}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{de3bb07e7c9c6590e5d78393679debcc}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ae0ab396ab210ec112c36417efc844e4}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{dd76cf11f8ea3bcec0adf54053518732}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{cf072b461545a025ab56c35b45777b52}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4cc8dbc88dd75902ec38f0aab72829bd}, jobId: f0456a83c44cdc52fa0bf1c880656594).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job f0456a83c44cdc52fa0bf1c880656594 from job leader monitoring.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f0456a83c44cdc52fa0bf1c880656594.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-bc9eb95c-0be6-41e1-ac7d-a598fc7efe08
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher6c570653-3e05-4b2a-8ff1-88d7810d7bf6.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:45903
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 2100 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@43a6ed7b
.
----------------------------------------------------------------------
Ran 25 tests in 80.810s
OK (skipped=7)
Segmentation fault (core dumped)
> Task :beam-sdks-python:flinkCompatibilityMatrixStreaming FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 1 mins 23.18 secs.
FAILURE: Build failed with an exception.
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 351
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreaming'.
> Process 'command 'sh'' finished with non-zero exit value 139
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 11m 17s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/lnu4lr45hzexk
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure