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

Changes:

[scott] Infer whether we need to publish Docker website port

------------------------------------------
[...truncated 51.11 MB...]
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (1/16) 
(e8123635073f47217b210d736a83a118).
[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) 
(83e7a831b9fa5cb7e94db09d8c0d35a3).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) 
(47135c9245b1f7d9df6b845d9aaccf9d) [FINISHED]
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) 
(e8123635073f47217b210d736a83a118) [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) 
(83e7a831b9fa5cb7e94db09d8c0d35a3) [FINISHED]
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (14/16) (bf1995d8eb7f02ceb8a04183f358fab7) switched from 
RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (14/16) 
(bf1995d8eb7f02ceb8a04183f358fab7).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (15/16) (ca92e556c1b1cdd32a2e09b3fb2e46bd) switched from 
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (15/16) 
(ca92e556c1b1cdd32a2e09b3fb2e46bd).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) 
(bf1995d8eb7f02ceb8a04183f358fab7) [FINISHED]
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) 
(ca92e556c1b1cdd32a2e09b3fb2e46bd) [FINISHED]
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] 
INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) 
(ca0677fd76b65a1afd16847e7d5a195e) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] 
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) 
(ca0677fd76b65a1afd16847e7d5a195e).
[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) 
(ca0677fd76b65a1afd16847e7d5a195e) [FINISHED]
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (8/16) (1c2943efb69bde85f78e7b6aaf942dd3) switched from RUNNING 
to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (8/16) 
(1c2943efb69bde85f78e7b6aaf942dd3).
[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 
2f4fc67293e94c5343f0e5a0e25e8821.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16) 
(1c2943efb69bde85f78e7b6aaf942dd3) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) 
(8fa6102af72e01d819dbb670f41ae46d) 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 GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
e8577a7850127382e56015daec2e3b20.
[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 
9c7b982eafdf66cd3a8e9d4b6e849df1.
[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 
7fc58f15e5fcb760b1b47a2000fc92d3.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) 
(2f4fc67293e94c5343f0e5a0e25e8821) 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 GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
9186ef79ebf987a2061adaa1e93a316a.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) 
(e8577a7850127382e56015daec2e3b20) 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 GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
668351418954dcf98a9b938076a00b40.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) 
(9c7b982eafdf66cd3a8e9d4b6e849df1) 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 
2f4e03df6eae4cef6975c1c0f7a62366.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) 
(7fc58f15e5fcb760b1b47a2000fc92d3) 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 GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 
d8df77d00fe9e9a39e74119b26f0c079.
[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 
e4be08bca65e8a86043bf1d466283794.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) 
(9186ef79ebf987a2061adaa1e93a316a) 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 
473189b50f8b9f37f0d581ac94cacb14.
[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 
039691dba5c3fb1c59d10eafceaf3a5e.
[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 
7b3144ae6dcb983cb30f0d5770ab05cd.
[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 
a25fce30497aae4bd54c26be69b03817.
[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 
686def7ca9dfc4861f5459e3734b1d1b.
[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 
691205be2f1e0539d2ae9ee62127e746.
[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 
cc34888ac2eb51019a90e9727b027e0a.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) 
(668351418954dcf98a9b938076a00b40) 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 
47135c9245b1f7d9df6b845d9aaccf9d.
[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 
e8123635073f47217b210d736a83a118.
[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 
83e7a831b9fa5cb7e94db09d8c0d35a3.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(12/16) (2f4e03df6eae4cef6975c1c0f7a62366) 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 
bf1995d8eb7f02ceb8a04183f358fab7.
[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 
ca92e556c1b1cdd32a2e09b3fb2e46bd.
[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 
ca0677fd76b65a1afd16847e7d5a195e.
[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 
1c2943efb69bde85f78e7b6aaf942dd3.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) 
(d8df77d00fe9e9a39e74119b26f0c079) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) 
(e4be08bca65e8a86043bf1d466283794) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(13/16) (473189b50f8b9f37f0d581ac94cacb14) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) 
(039691dba5c3fb1c59d10eafceaf3a5e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(10/16) (7b3144ae6dcb983cb30f0d5770ab05cd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(16/16) (a25fce30497aae4bd54c26be69b03817) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) 
(686def7ca9dfc4861f5459e3734b1d1b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(11/16) (691205be2f1e0539d2ae9ee62127e746) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) 
(cc34888ac2eb51019a90e9727b027e0a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) 
(47135c9245b1f7d9df6b845d9aaccf9d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) 
(e8123635073f47217b210d736a83a118) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) 
(83e7a831b9fa5cb7e94db09d8c0d35a3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(14/16) (bf1995d8eb7f02ceb8a04183f358fab7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem 
(15/16) (ca92e556c1b1cdd32a2e09b3fb2e46bd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) 
(ca0677fd76b65a1afd16847e7d5a195e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) 
(1c2943efb69bde85f78e7b6aaf942dd3) 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) 
(22f672ebd50194fff958a8103196080a) 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) 
(22f672ebd50194fff958a8103196080a).
[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) 
(22f672ebd50194fff958a8103196080a) [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 
22f672ebd50194fff958a8103196080a.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
ToKeyedWorkItem (7/16) (aa3cf43dce1b080ea541b465b2ed5e9a) switched from RUNNING 
to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for ToKeyedWorkItem (7/16) 
(aa3cf43dce1b080ea541b465b2ed5e9a).
[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) (943f7913010658cb81acfc4572592d65) 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) (9b5ef7c3515bb738df0c04782e15035c) 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) 
(aa3cf43dce1b080ea541b465b2ed5e9a) [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) 
(943f7913010658cb81acfc4572592d65).
[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) (b5df05ba0b14f81b2e85de087d4b2675) 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) 
(b5df05ba0b14f81b2e85de087d4b2675).
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) 
(22f672ebd50194fff958a8103196080a) 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) 
(9b5ef7c3515bb738df0c04782e15035c).
[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) (c9ce5c9b6e511ffbfc65384e1b88d1f1) 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) 
(c9ce5c9b6e511ffbfc65384e1b88d1f1).
[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) (6b1638f19a03d8de9cfa9f0c0953d181) 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) (9b0c8fb9da38421753f5cccc2d705021) 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) (db139eaa3d18736df295f67110f110be) 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) 
(db139eaa3d18736df295f67110f110be).
[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) (71b8c4c37be123cfd4d32ca87e89b02b) 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) 
(71b8c4c37be123cfd4d32ca87e89b02b).
[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) (d1d91fb126f63567cfb935b688518fc7) 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) 
(d1d91fb126f63567cfb935b688518fc7).
[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 
aa3cf43dce1b080ea541b465b2ed5e9a.
[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) 
(9b0c8fb9da38421753f5cccc2d705021).
[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) 
(6b1638f19a03d8de9cfa9f0c0953d181).
[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) (664e1c8bdb24bf22270b204a80b80fad) 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) (d549b5733163737b83c3f7d7410bd92c) 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) (6a9d9603f0ede54749e843a9fcb4ea29) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) 
(aa3cf43dce1b080ea541b465b2ed5e9a) 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) 
(6a9d9603f0ede54749e843a9fcb4ea29).
[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) 
(d549b5733163737b83c3f7d7410bd92c).
[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) (a0dc169192527440cff566ecc97c9ada) 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) 
(a0dc169192527440cff566ecc97c9ada).
[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) 
(664e1c8bdb24bf22270b204a80b80fad).
[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) (8dbe03d835eef18e56ecc4fecf54bbff) 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 - Freeing task resources for 
assert_that/Group/GroupByKey -> 
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) 
(8dbe03d835eef18e56ecc4fecf54bbff).
[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) (3aeb65fa8c23449ecf726f169d472bd5) 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) 
(3aeb65fa8c23449ecf726f169d472bd5).
[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) 
(943f7913010658cb81acfc4572592d65) [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) 
(3aeb65fa8c23449ecf726f169d472bd5) [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) 
(8dbe03d835eef18e56ecc4fecf54bbff) [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 
943f7913010658cb81acfc4572592d65.
[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) 
(664e1c8bdb24bf22270b204a80b80fad) [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 
3aeb65fa8c23449ecf726f169d472bd5.
[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) 
(a0dc169192527440cff566ecc97c9ada) [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) 
(d549b5733163737b83c3f7d7410bd92c) [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) 
(6a9d9603f0ede54749e843a9fcb4ea29) [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 
8dbe03d835eef18e56ecc4fecf54bbff.
[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) 
(943f7913010658cb81acfc4572592d65) 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 
664e1c8bdb24bf22270b204a80b80fad.
[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) 
(6b1638f19a03d8de9cfa9f0c0953d181) [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) 
(9b0c8fb9da38421753f5cccc2d705021) [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 
a0dc169192527440cff566ecc97c9ada.
[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) 
(3aeb65fa8c23449ecf726f169d472bd5) 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) 
(d1d91fb126f63567cfb935b688518fc7) [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 
d549b5733163737b83c3f7d7410bd92c.
[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) 
(8dbe03d835eef18e56ecc4fecf54bbff) 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 
6a9d9603f0ede54749e843a9fcb4ea29.
[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) 
(71b8c4c37be123cfd4d32ca87e89b02b) [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 
6b1638f19a03d8de9cfa9f0c0953d181.
[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) 
(db139eaa3d18736df295f67110f110be) [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) 
(664e1c8bdb24bf22270b204a80b80fad) 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) 
(c9ce5c9b6e511ffbfc65384e1b88d1f1) [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 
9b0c8fb9da38421753f5cccc2d705021.
[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 
d1d91fb126f63567cfb935b688518fc7.
[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) 
(9b5ef7c3515bb738df0c04782e15035c) [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) 
(b5df05ba0b14f81b2e85de087d4b2675) [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 
71b8c4c37be123cfd4d32ca87e89b02b.
[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) 
(a0dc169192527440cff566ecc97c9ada) 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 
db139eaa3d18736df295f67110f110be.
[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 
c9ce5c9b6e511ffbfc65384e1b88d1f1.
[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) 
(d549b5733163737b83c3f7d7410bd92c) 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 
9b5ef7c3515bb738df0c04782e15035c.
[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 
b5df05ba0b14f81b2e85de087d4b2675.
[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) 
(6a9d9603f0ede54749e843a9fcb4ea29) 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 (9/16) 
(6b1638f19a03d8de9cfa9f0c0953d181) 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) 
(9b0c8fb9da38421753f5cccc2d705021) 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) 
(d1d91fb126f63567cfb935b688518fc7) 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 (1/16) 
(71b8c4c37be123cfd4d32ca87e89b02b) 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 (11/16) 
(db139eaa3d18736df295f67110f110be) 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 (16/16) 
(c9ce5c9b6e511ffbfc65384e1b88d1f1) 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 (3/16) 
(9b5ef7c3515bb738df0c04782e15035c) 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 (7/16) 
(b5df05ba0b14f81b2e85de087d4b2675) 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-3] INFO data_plane.close - Closing all cached grpc data 
channels.
[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-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) (1c6ee9d8b193429d571217b846bcd8bb) 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) 
(1c6ee9d8b193429d571217b846bcd8bb).
[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) 
(1c6ee9d8b193429d571217b846bcd8bb) [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 
1c6ee9d8b193429d571217b846bcd8bb.
[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) 
(1c6ee9d8b193429d571217b846bcd8bb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
test_windowing_1539279229.93 (3fe1371e9615eb9fdceb6b2dbfb16ec3) switched from 
state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint 
coordinator for job 3fe1371e9615eb9fdceb6b2dbfb16ec3.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - 
Shutting down
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 
3fe1371e9615eb9fdceb6b2dbfb16ec3 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_1539279229.93(3fe1371e9615eb9fdceb6b2dbfb16ec3).
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager 
connection for job 3fe1371e9615eb9fdceb6b2dbfb16ec3.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 
1592e27159b2a75e1d40a0c6871587a6: 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.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-5] INFO 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect 
job manager 8a8a81ad3b1d1510a50e022a89d144ac@akka://flink/user/jobmanager_39 
for job 3fe1371e9615eb9fdceb6b2dbfb16ec3 from the resource manager.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher 
akka://flink/user/dispatcher113980d6-4e3f-4bfb-b988-11ed8f24c5ae.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all 
currently running jobs of dispatcher 
akka://flink/user/dispatcher113980d6-4e3f-4bfb-b988-11ed8f24c5ae.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the 
SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending 
the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister 
TaskManager 8b8a069d35f799117f577ef069992dc9 from the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 
3fe1371e9615eb9fdceb6b2dbfb16ec3 with leader id 
8a8a81ad3b1d1510a50e022a89d144ac lost leadership.
[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{dad65a18273eeada3fa6f2ac310dbffa}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{beb4eca476802d99d499b1ac8d184811}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{6d81adb2862e7af78f69e9a5c8fa0afc}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{cc10d7a28c54707e809ac1b5c008f73d}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{b385c89acbef1188fe869e52a070dbf9}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{fce3074afe03a474bcc9afebff04ce86}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{b4b0ca897a96084d02b57e6d0e330662}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{426decf1153cca21a721275545d464a0}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{f83b4492532d52a7ffd71f7410b36fc0}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{c8753737b2c3b77fe802981889522db0}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{3bc66e3b81701b2772c91773538d965f}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{4d95b647dc33cb6e4b713ddeb2252245}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{b6db1412719139633805313338de2bb4}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{94756f5e8c6603d0569fa7a4f6b2ea0a}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{2cc0d3da5263860b4e00b669aa1f1dba}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[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{892d955f5d50d1c30e73687150b77de0}, jobId: 
3fe1371e9615eb9fdceb6b2dbfb16ec3).
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 
3fe1371e9615eb9fdceb6b2dbfb16ec3 from job leader monitoring.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager 
connection for job 3fe1371e9615eb9fdceb6b2dbfb16ec3.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor 
akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting 
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed 
spill file directory /tmp/flink-io-45df20bb-1e3b-4300-abae-9d0dd3dd030a
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the 
network environment and its components.
[ForkJoinPool.commonPool-worker-9] 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.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/dispatcher113980d6-4e3f-4bfb-b988-11ed8f24c5ae.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader 
service.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor 
akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:33463
[flink-akka.actor.default-dispatcher-5] 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 2211 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@7986a759
.
----------------------------------------------------------------------
Ran 25 tests in 79.240s

OK (skipped=7)
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Task worker for ':' 
Thread 5,5,main]) completed. Took 1 mins 21.428 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/xdbf6zbruexyu

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

Reply via email to