See 
<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/224/display/redirect?page=changes>

Changes:

[ankurgoenka] Store and server termination state after portable job termination

------------------------------------------
[...truncated 51.05 MB...]
[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 
0dd37671ea747107f43b3648d12b7ee1.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (12/16) (6eea885af93cdfd587f65183fcf6866f) switched from 
RUNNING to FINISHED.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (12/16) 
(6eea885af93cdfd587f65183fcf6866f).
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16) 
(6eea885af93cdfd587f65183fcf6866f) [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 
5048ca12b5d49627a19a9de49072854c.
[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 
1261c2a39ca5a170ca306c799382bb6d.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/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 (16/16) 
(e3b928758fa942813f77ec44c3cb650f) [FINISHED]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (10/16) (81b682f4dc46d328b42e6c510b9c106a) switched from 
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) 
(1bdd1f67d8fd5bdba15635f7ef16296f) [FINISHED]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16) 
(9806cb7a27becf4b4eada4ef856cebc9) [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 
074675aea64f361c561376c730ab722e.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (15/16) (bff86b514d3a20ec2e456a58af03690a) switched from 
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (15/16) 
(bff86b514d3a20ec2e456a58af03690a).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (14/16) (2ad02bb71d3392ac511d2494c92e41fc) switched from 
RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (14/16) 
(2ad02bb71d3392ac511d2494c92e41fc).
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16) 
(90b3ddcf0bcb9a3b8e0b076699c54e90) [FINISHED]
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) 
(bff86b514d3a20ec2e456a58af03690a) [FINISHED]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (10/16) 
(81b682f4dc46d328b42e6c510b9c106a).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) 
(2ad02bb71d3392ac511d2494c92e41fc) [FINISHED]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16) 
(81b682f4dc46d328b42e6c510b9c106a) [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 
a629c80a1613852d4ca13f5e5488185c.
[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 
f249466a45a05f76a7183d41d8c32a06.
[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 
200c908c9c138a9f8dbfbadbf108f9e0.
[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 
6a77d41e5d685f3ff30a094a6bc37b22.
[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 
c5d1c73374f6b435c050c67f8d380f77.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) 
(827b2f7595cb10e69c7f4b550412048c) 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 
76a6414d84240e6d7f0321611f7b1d68.
[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 
6eea885af93cdfd587f65183fcf6866f.
[assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 
74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
 (16/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
 (16/16) (943f42231a25f3444eb0969756ab614a) 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
 (16/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
 (16/16) (943f42231a25f3444eb0969756ab614a).
[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 
1bdd1f67d8fd5bdba15635f7ef16296f.
[assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 
74assert_that/Create/Read/Reshuffle/ReshufflePerKey/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/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 
74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
 (16/16) (943f42231a25f3444eb0969756ab614a) [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 
9806cb7a27becf4b4eada4ef856cebc9.
[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 
bff86b514d3a20ec2e456a58af03690a.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) 
(c8e50d8755c5ca6297ef97a5821bfdc3) 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 
90b3ddcf0bcb9a3b8e0b076699c54e90.
[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 GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
e3b928758fa942813f77ec44c3cb650f.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) 
(0ac6d166d031222ff75bca582f4dc902) 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 
2ad02bb71d3392ac511d2494c92e41fc.
[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 
81b682f4dc46d328b42e6c510b9c106a.
[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/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 
74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
 943f42231a25f3444eb0969756ab614a.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) 
(5908eaca701cd33beff40a1f93700747) 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) 
(a86fba418cacd7dbc3efc684a02dacea) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (16/16) (6a5ba842c7e958f11b7f69e5c382c660) switched from 
RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (16/16) 
(6a5ba842c7e958f11b7f69e5c382c660).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16) 
(6a5ba842c7e958f11b7f69e5c382c660) [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 
6a5ba842c7e958f11b7f69e5c382c660.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) 
(0dd37671ea747107f43b3648d12b7ee1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) 
(5048ca12b5d49627a19a9de49072854c) 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 (13/16) 
(1261c2a39ca5a170ca306c799382bb6d) 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 (5/16) 
(074675aea64f361c561376c730ab722e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(11/16) (a629c80a1613852d4ca13f5e5488185c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) 
(f249466a45a05f76a7183d41d8c32a06) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) 
(200c908c9c138a9f8dbfbadbf108f9e0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) 
(6a77d41e5d685f3ff30a094a6bc37b22) 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 (10/16) 
(c5d1c73374f6b435c050c67f8d380f77) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) 
(76a6414d84240e6d7f0321611f7b1d68) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(12/16) (6eea885af93cdfd587f65183fcf6866f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(13/16) (1bdd1f67d8fd5bdba15635f7ef16296f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) 
(9806cb7a27becf4b4eada4ef856cebc9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(15/16) (bff86b514d3a20ec2e456a58af03690a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) 
(90b3ddcf0bcb9a3b8e0b076699c54e90) 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) 
(e3b928758fa942813f77ec44c3cb650f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(14/16) (2ad02bb71d3392ac511d2494c92e41fc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(10/16) (81b682f4dc46d328b42e6c510b9c106a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] 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
 (16/16) (943f42231a25f3444eb0969756ab614a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(16/16) (6a5ba842c7e958f11b7f69e5c382c660) 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) 
(6e245e4681fa46e1dda9c0612348bf74) 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) 
(6e245e4681fa46e1dda9c0612348bf74).
[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) 
(6e245e4681fa46e1dda9c0612348bf74) [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 GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
6e245e4681fa46e1dda9c0612348bf74.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (7/16) (49b09acc40970faa0c4cd8bb1302cc55) switched from RUNNING 
to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (7/16) 
(49b09acc40970faa0c4cd8bb1302cc55).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) 
(49b09acc40970faa0c4cd8bb1302cc55) [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) (1f9e42e51bcfcec275a4a83c917ba98e) 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) 
(1f9e42e51bcfcec275a4a83c917ba98e).
[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 
49b09acc40970faa0c4cd8bb1302cc55.
[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) (dd43e29c1abf7d0b76a2aac06c6b9dc1) 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) (1a051fc3567878e1fb0401bb9f11e3cc) 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) 
(1a051fc3567878e1fb0401bb9f11e3cc).
[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) 
(dd43e29c1abf7d0b76a2aac06c6b9dc1).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) 
(6e245e4681fa46e1dda9c0612348bf74) 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) 
(1f9e42e51bcfcec275a4a83c917ba98e) [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 
1f9e42e51bcfcec275a4a83c917ba98e.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) 
(49b09acc40970faa0c4cd8bb1302cc55) 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) (af502af9bcf4cf622ebf1430fdd52997) 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 - assert_that/Group/GroupByKey 
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
(16/16) (f5444f85a0e4477b996e73f6fb30f208) 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) 
(f5444f85a0e4477b996e73f6fb30f208).
[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) 
(af502af9bcf4cf622ebf1430fdd52997).
[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) 
(1f9e42e51bcfcec275a4a83c917ba98e) 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) (f024bf1b408367bdb2b07d7631ff9600) 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) (e2cda8ffe2dd1dca404e3cdecfea704d) 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 - assert_that/Group/GroupByKey 
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
(10/16) (7e642109c930cfaa11d7106eecf2b887) 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) 
(7e642109c930cfaa11d7106eecf2b887).
[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) 
(f024bf1b408367bdb2b07d7631ff9600).
[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) 
(e2cda8ffe2dd1dca404e3cdecfea704d).
[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) (4678629813e6ab3db0f426e5567b3cb5) 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) (2bd15a0877c5cd67f5872ba05632aae3) 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) 
(2bd15a0877c5cd67f5872ba05632aae3).
[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) 
(4678629813e6ab3db0f426e5567b3cb5).
[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) 
(1a051fc3567878e1fb0401bb9f11e3cc) [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) (26695641ba5a0cfb2eb835fd18184da7) 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 - assert_that/Group/GroupByKey 
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
(6/16) (bc140e697d9a3d0fd122acb3d4c648c9) 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) 
(26695641ba5a0cfb2eb835fd18184da7).
[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) 
(bc140e697d9a3d0fd122acb3d4c648c9).
[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) (b6c3eb0f7a5a6d1b4828b00a7f2f291b) 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) 
(b6c3eb0f7a5a6d1b4828b00a7f2f291b).
[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 
1a051fc3567878e1fb0401bb9f11e3cc.
[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) (3dda797848d67b2aff178016ecff0425) 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) 
(3dda797848d67b2aff178016ecff0425).
[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) 
(1a051fc3567878e1fb0401bb9f11e3cc) 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) (cee48449e90c2be228e99c87a869da4f) 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) 
(cee48449e90c2be228e99c87a869da4f).
[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) 
(4678629813e6ab3db0f426e5567b3cb5) [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 
4678629813e6ab3db0f426e5567b3cb5.
[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) 
(2bd15a0877c5cd67f5872ba05632aae3) [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) 
(e2cda8ffe2dd1dca404e3cdecfea704d) [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 
2bd15a0877c5cd67f5872ba05632aae3.
[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) 
(f024bf1b408367bdb2b07d7631ff9600) [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 
e2cda8ffe2dd1dca404e3cdecfea704d.
[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 (15/16) 
(4678629813e6ab3db0f426e5567b3cb5) 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 
f024bf1b408367bdb2b07d7631ff9600.
[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) 
(7e642109c930cfaa11d7106eecf2b887) [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 
7e642109c930cfaa11d7106eecf2b887.
[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 (13/16) 
(2bd15a0877c5cd67f5872ba05632aae3) 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) 
(af502af9bcf4cf622ebf1430fdd52997) [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 
af502af9bcf4cf622ebf1430fdd52997.
[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 (12/16) 
(e2cda8ffe2dd1dca404e3cdecfea704d) 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 - 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) 
(f5444f85a0e4477b996e73f6fb30f208) [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 
f5444f85a0e4477b996e73f6fb30f208.
[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 (14/16) 
(f024bf1b408367bdb2b07d7631ff9600) 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) 
(dd43e29c1abf7d0b76a2aac06c6b9dc1) [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 
dd43e29c1abf7d0b76a2aac06c6b9dc1.
[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) 
(cee48449e90c2be228e99c87a869da4f) [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) 
(3dda797848d67b2aff178016ecff0425) [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) 
(7e642109c930cfaa11d7106eecf2b887) 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) 
(b6c3eb0f7a5a6d1b4828b00a7f2f291b) [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) 
(bc140e697d9a3d0fd122acb3d4c648c9) [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 
cee48449e90c2be228e99c87a869da4f.
[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 (1/16) 
(af502af9bcf4cf622ebf1430fdd52997) 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 
3dda797848d67b2aff178016ecff0425.
[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 (16/16) 
(f5444f85a0e4477b996e73f6fb30f208) 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 
b6c3eb0f7a5a6d1b4828b00a7f2f291b.
[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) 
(26695641ba5a0cfb2eb835fd18184da7) [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 
bc140e697d9a3d0fd122acb3d4c648c9.
[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 (7/16) 
(dd43e29c1abf7d0b76a2aac06c6b9dc1) 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 
26695641ba5a0cfb2eb835fd18184da7.
[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 (11/16) 
(cee48449e90c2be228e99c87a869da4f) 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 (4/16) 
(3dda797848d67b2aff178016ecff0425) 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 (8/16) 
(b6c3eb0f7a5a6d1b4828b00a7f2f291b) 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 (6/16) 
(bc140e697d9a3d0fd122acb3d4c648c9) 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 (5/16) 
(26695641ba5a0cfb2eb835fd18184da7) switched from RUNNING to FINISHED.
[grpc-default-executor-1] INFO sdk_worker.run - No more requests from control 
plane
[grpc-default-executor-1] INFO sdk_worker.run - SDK Harness waiting for 
in-flight requests to complete
[grpc-default-executor-1] WARN 
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown 
endpoint.
[grpc-default-executor-1] INFO data_plane.close - Closing all cached grpc data 
channels.
[grpc-default-executor-1] INFO sdk_worker.close - Closing all cached gRPC state 
handlers.
[grpc-default-executor-1] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-1] INFO sdk_worker_main.main - Python sdk harness 
exiting.
[grpc-default-executor-1] 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) (8cfcb51ed62cc546d2192c018f2d9719) 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) 
(8cfcb51ed62cc546d2192c018f2d9719).
[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) 
(8cfcb51ed62cc546d2192c018f2d9719) [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 
8cfcb51ed62cc546d2192c018f2d9719.
[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 (2/16) 
(8cfcb51ed62cc546d2192c018f2d9719) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
test_windowing_1538650329.25 (35dd8dbed11f489c5215674411aa237b) switched from 
state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint 
coordinator for job 35dd8dbed11f489c5215674411aa237b.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - 
Shutting down
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 
35dd8dbed11f489c5215674411aa237b reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job 
test_windowing_1538650329.25(35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager 
connection for job 35dd8dbed11f489c5215674411aa237b.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 
55c10d37ffcd1deb58a2c07c3521c357: JobManager is shutting down..
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster 
- Shutting down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect 
job manager a51fc7ae278d3d335e3eb994e4c44e36@akka://flink/user/jobmanager_39 
for job 35dd8dbed11f489c5215674411aa237b from the resource manager.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[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.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 
35dd8dbed11f489c5215674411aa237b with leader id 
a51fc7ae278d3d335e3eb994e4c44e36 lost leadership.
[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 5fa084a127a2639803c6aa95ec16b2be from the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher 
akka://flink/user/dispatcherd7ae72e3-c9db-4e25-8290-d76b4ea53e43.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all 
currently running jobs of dispatcher 
akka://flink/user/dispatcherd7ae72e3-c9db-4e25-8290-d76b4ea53e43.
[flink-akka.actor.default-dispatcher-2] 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{b133f22e6848c96ac3703c56314d167a}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{f72d8ca586b34942e5b62ef4262bc3a8}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[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{5875e8117897ac1f46072a8aec742791}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[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{09d45bd51b8da5d019ec2eb5e07800c2}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{e68ceef0d264e236446c067081874a29}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{c61f23f27dbd44e62e81c64fb5be6407}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{f597e124eaa6fc473696eaab59bd61c3}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{5f0e0cfbd5e46c33918f303b74ddc3cd}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{dbf21307b19939d33ebe3de8c6315c99}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{f2be53dbbbe1655edcad22cbc26b83a8}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{ca24279790f9fe7cc1b79043807910b9}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{b140086d5ec5566b3312291e75c38122}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-2] 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{85d14ac53760f19ffb02ac9f85396fb7}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[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{1c91ee5f1731e534a5ceff20a08d489d}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-3] 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{40c054483220f71775cf37f080a349f7}, jobId: 
35dd8dbed11f489c5215674411aa237b).
[flink-akka.actor.default-dispatcher-4] 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.taskexecutor.TaskExecutor - Stopping TaskExecutor 
akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher 
akka://flink/user/dispatcherd7ae72e3-c9db-4e25-8290-d76b4ea53e43.
[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-3c5e1076-2b74-42a2-b07a-24d0defa625c
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the 
network environment and its components.
[ForkJoinPool.commonPool-worker-11] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache 
directory /tmp/flink-web-ui
[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.
[flink-akka.actor.default-dispatcher-3] 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:46269
[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 2557 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@7674de50
.
----------------------------------------------------------------------
Ran 24 tests in 88.652s

OK (skipped=6)
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Daemon 
worker,5,main]) completed. Took 1 mins 30.876 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: 338

* 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.

* 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 12m 3s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/qnbei5nor2pu4

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

Reply via email to