See
<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/197/display/redirect>
------------------------------------------
[...truncated 51.05 MB...]
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16)
(5150a540a2a6363afcc44e42c0c46d44) [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)
(9d6acc8acbcc6a9940088f9c1450b992) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey ->
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)
(6a2fbe689af6d190c46eb701215ed60d) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(4066b7b958ba4f760814b43dbe7526da) [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
2026fbd86b45634bf3b318694906bde7.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)
(6a2fbe689af6d190c46eb701215ed60d).
[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
676ff3ee7718ebad46fe278308a9507d.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/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 (10/16)
(6a2fbe689af6d190c46eb701215ed60d) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey ->
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)
(ba8a1289ff9ca21104c6ab9974c7b0b4) 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
2847d7cb097e181f5c63f43d1673c99a.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (e18734171055928aa0f21f0d3b770b9b) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (1/16) (8196c99d875513b721b7b2e64df6f7eb) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (1/16)
(8196c99d875513b721b7b2e64df6f7eb).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (16/16)
(e18734171055928aa0f21f0d3b770b9b).
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey ->
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)
(added0e6be541b67e4bb9367b71b1dc6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey ->
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)
(e35ba2490efdd9798d2411848760c207) 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
245314661156bf83d53a4ff3b089278c.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)
(added0e6be541b67e4bb9367b71b1dc6).
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/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 (5/16)
(added0e6be541b67e4bb9367b71b1dc6) [FINISHED]
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16)
(8196c99d875513b721b7b2e64df6f7eb) [FINISHED]
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16)
(e18734171055928aa0f21f0d3b770b9b) [FINISHED]
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (50156d2dc28ce24fb56f7af727142bbb) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(50156d2dc28ce24fb56f7af727142bbb).
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (3/16) (843a9736a2b20e73257f717e7937f8dc) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (aeae72eaf1e8907b3a7e29fed33f5c28) 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)
(50156d2dc28ce24fb56f7af727142bbb) [FINISHED]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (6/16) (b53b3e40b4cf13ba9ec90d84d6e4ffc0) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (6/16)
(b53b3e40b4cf13ba9ec90d84d6e4ffc0).
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (3/16)
(843a9736a2b20e73257f717e7937f8dc).
[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
0a962520004784ff19002b54208b809b.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(aeae72eaf1e8907b3a7e29fed33f5c28).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16)
(b53b3e40b4cf13ba9ec90d84d6e4ffc0) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (2026fbd86b45634bf3b318694906bde7) 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
f3734ed377b0f0ae5b0cbef8d544c093.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(aeae72eaf1e8907b3a7e29fed33f5c28) [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
fddadda56bc1f4a33dfaed97b47cc370.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16)
(843a9736a2b20e73257f717e7937f8dc) [FINISHED]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (92ae9fecf4fac48840f611cb12dbd0ad) 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
f039b1e7616ec7d598534d0e18c5d43d.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (5/16)
(92ae9fecf4fac48840f611cb12dbd0ad).
[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
45dfa715f7ce29288584666bf27f5630.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16)
(92ae9fecf4fac48840f611cb12dbd0ad) [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
4066b7b958ba4f760814b43dbe7526da.
[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
5150a540a2a6363afcc44e42c0c46d44.
[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
6a2fbe689af6d190c46eb701215ed60d.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey ->
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)
(676ff3ee7718ebad46fe278308a9507d) 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
added0e6be541b67e4bb9367b71b1dc6.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey ->
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)
(2847d7cb097e181f5c63f43d1673c99a) 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
8196c99d875513b721b7b2e64df6f7eb.
[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
e18734171055928aa0f21f0d3b770b9b.
[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
50156d2dc28ce24fb56f7af727142bbb.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey ->
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)
(245314661156bf83d53a4ff3b089278c) 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
b53b3e40b4cf13ba9ec90d84d6e4ffc0.
[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
aeae72eaf1e8907b3a7e29fed33f5c28.
[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
843a9736a2b20e73257f717e7937f8dc.
[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
92ae9fecf4fac48840f611cb12dbd0ad.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (0a962520004784ff19002b54208b809b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(f3734ed377b0f0ae5b0cbef8d544c093) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16)
(fddadda56bc1f4a33dfaed97b47cc370) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16)
(f039b1e7616ec7d598534d0e18c5d43d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (45dfa715f7ce29288584666bf27f5630) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(4066b7b958ba4f760814b43dbe7526da) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (5150a540a2a6363afcc44e42c0c46d44) 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 (10/16)
(6a2fbe689af6d190c46eb701215ed60d) 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 (5/16)
(added0e6be541b67e4bb9367b71b1dc6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16)
(8196c99d875513b721b7b2e64df6f7eb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (e18734171055928aa0f21f0d3b770b9b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (50156d2dc28ce24fb56f7af727142bbb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(b53b3e40b4cf13ba9ec90d84d6e4ffc0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (aeae72eaf1e8907b3a7e29fed33f5c28) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(843a9736a2b20e73257f717e7937f8dc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(92ae9fecf4fac48840f611cb12dbd0ad) 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)
(2957e0b9073c1f37e8acb84e383c9c57) 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)
(2957e0b9073c1f37e8acb84e383c9c57).
[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)
(2957e0b9073c1f37e8acb84e383c9c57) [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
2957e0b9073c1f37e8acb84e383c9c57.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (7/16) (1a24f52d8ea48f5f5f32fb81cbe2456e) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (7/16)
(1a24f52d8ea48f5f5f32fb81cbe2456e).
[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) (0ba7ba4dc9ad6d91c22be5ae2f25db98) 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)
(0ba7ba4dc9ad6d91c22be5ae2f25db98).
[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) (209ba15bce6e3ada34837c9b26eee8de) 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)
(209ba15bce6e3ada34837c9b26eee8de).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16)
(1a24f52d8ea48f5f5f32fb81cbe2456e) [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)
(0ba7ba4dc9ad6d91c22be5ae2f25db98) [FINISHED]
[assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(15/16) (27e1e64f709e533f699e698643dbf98e) 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) (592bf846e525f4900955272c02b595a0) 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)
(592bf846e525f4900955272c02b595a0).
[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) (de99cf4f02a0c37f4c53c105d83fbf0c) 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)
(de99cf4f02a0c37f4c53c105d83fbf0c).
[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) (c6bbe5393cc4e8ffd7d8cc68f2ffac46) 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)
(c6bbe5393cc4e8ffd7d8cc68f2ffac46).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
1a24f52d8ea48f5f5f32fb81cbe2456e.
[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)
(27e1e64f709e533f699e698643dbf98e).
[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) (0bfb0da3157fff6d0fffadcd3b6c7a54) 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)
(0bfb0da3157fff6d0fffadcd3b6c7a54).
[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) (1f8763c7a4a9267573c7272dfcd0a7c0) 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)
(1f8763c7a4a9267573c7272dfcd0a7c0).
[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) (a1a7c370f7e0057bac3c2cee8519c341) 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)
(a1a7c370f7e0057bac3c2cee8519c341).
[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
0ba7ba4dc9ad6d91c22be5ae2f25db98.
[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) (646ea896bb11df2621c5352e1e4a269b) 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)
(646ea896bb11df2621c5352e1e4a269b).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey ->
24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)
(2957e0b9073c1f37e8acb84e383c9c57) 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) (e7e69233819ca52fea0811835c6203b2) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)
(e7e69233819ca52fea0811835c6203b2).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(1a24f52d8ea48f5f5f32fb81cbe2456e) 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) (aa79fdd40ef81a479921272720bf2047) 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)
(aa79fdd40ef81a479921272720bf2047).
[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) (60a7f5f37c6cd1256033f67bcae323fd) 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) (08f1a1d964e8b92121bb131e857457f2) 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)
(60a7f5f37c6cd1256033f67bcae323fd).
[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)
(08f1a1d964e8b92121bb131e857457f2).
[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) (e373433e05a8921b1a2cb88525133b5d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)
(0ba7ba4dc9ad6d91c22be5ae2f25db98) 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)
(e373433e05a8921b1a2cb88525133b5d).
[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)
(209ba15bce6e3ada34837c9b26eee8de) [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)
(e373433e05a8921b1a2cb88525133b5d) [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
209ba15bce6e3ada34837c9b26eee8de.
[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)
(08f1a1d964e8b92121bb131e857457f2) [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
e373433e05a8921b1a2cb88525133b5d.
[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
08f1a1d964e8b92121bb131e857457f2.
[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)
(60a7f5f37c6cd1256033f67bcae323fd) [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)
(aa79fdd40ef81a479921272720bf2047) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (6/16)
(209ba15bce6e3ada34837c9b26eee8de) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
60a7f5f37c6cd1256033f67bcae323fd.
[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
aa79fdd40ef81a479921272720bf2047.
[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 (8/16)
(e373433e05a8921b1a2cb88525133b5d) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)
(e7e69233819ca52fea0811835c6203b2) [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
e7e69233819ca52fea0811835c6203b2.
[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)
(646ea896bb11df2621c5352e1e4a269b) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16)
(08f1a1d964e8b92121bb131e857457f2) 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)
(a1a7c370f7e0057bac3c2cee8519c341) [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
646ea896bb11df2621c5352e1e4a269b.
[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)
(1f8763c7a4a9267573c7272dfcd0a7c0) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)
(60a7f5f37c6cd1256033f67bcae323fd) 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
a1a7c370f7e0057bac3c2cee8519c341.
[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)
(0bfb0da3157fff6d0fffadcd3b6c7a54) [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)
(27e1e64f709e533f699e698643dbf98e) [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
1f8763c7a4a9267573c7272dfcd0a7c0.
[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)
(c6bbe5393cc4e8ffd7d8cc68f2ffac46) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)
(aa79fdd40ef81a479921272720bf2047) 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
0bfb0da3157fff6d0fffadcd3b6c7a54.
[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)
(592bf846e525f4900955272c02b595a0) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)
(e7e69233819ca52fea0811835c6203b2) 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
27e1e64f709e533f699e698643dbf98e.
[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)
(de99cf4f02a0c37f4c53c105d83fbf0c) [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
c6bbe5393cc4e8ffd7d8cc68f2ffac46.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)
(646ea896bb11df2621c5352e1e4a269b) 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
592bf846e525f4900955272c02b595a0.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)
(a1a7c370f7e0057bac3c2cee8519c341) 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
de99cf4f02a0c37f4c53c105d83fbf0c.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)
(1f8763c7a4a9267573c7272dfcd0a7c0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)
(0bfb0da3157fff6d0fffadcd3b6c7a54) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)
(27e1e64f709e533f699e698643dbf98e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)
(c6bbe5393cc4e8ffd7d8cc68f2ffac46) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)
(592bf846e525f4900955272c02b595a0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)
(de99cf4f02a0c37f4c53c105d83fbf0c) switched from RUNNING to FINISHED.
[grpc-default-executor-5] INFO sdk_worker.run - No more requests from control
plane
[grpc-default-executor-5] INFO sdk_worker.run - SDK Harness waiting for
in-flight requests to complete
[grpc-default-executor-5] WARN
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown
endpoint.
[grpc-default-executor-5] INFO data_plane.close - Closing all cached grpc data
channels.
[grpc-default-executor-5] INFO sdk_worker.close - Closing all cached gRPC state
handlers.
[grpc-default-executor-4] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-4] INFO sdk_worker_main.main - Python sdk harness
exiting.
[grpc-default-executor-4] INFO
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client
hanged up.
[assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)]
WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for
unknown endpoint.
[assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(2/16) (2be58cee66e28fd6203c628e1818c917) 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)
(2be58cee66e28fd6203c628e1818c917).
[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)
(2be58cee66e28fd6203c628e1818c917) [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
2be58cee66e28fd6203c628e1818c917.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)
(2be58cee66e28fd6203c628e1818c917) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
test_windowing_1538460725.16 (7d14475f3ad609fb9efb84db8b9902b6) switched from
state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job 7d14475f3ad609fb9efb84db8b9902b6.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
7d14475f3ad609fb9efb84db8b9902b6 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
test_windowing_1538460725.16(7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 7d14475f3ad609fb9efb84db8b9902b6.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
c9178ebdafee1a54960e41fe84d038a3: 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-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager b07d80a18911af12e8443ea3d4b24ba2@akka://flink/user/jobmanager_39
for job 7d14475f3ad609fb9efb84db8b9902b6 from the resource manager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher4fc73592-f681-43cd-8460-79451758b12f.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher4fc73592-f681-43cd-8460-79451758b12f.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
7d14475f3ad609fb9efb84db8b9902b6 with leader id
b07d80a18911af12e8443ea3d4b24ba2 lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager d4a56b643d797579fbada70743ae151f from the SlotManager.
[flink-akka.actor.default-dispatcher-3] 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{d655c220e364d00a84bd3e5c39a29848}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{2c1504b809f0baf5fc5710b9ace65962}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[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{d3229832e1e0250beda31ef1b0143b2e}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] 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{bd5c650fd37ed1df97e836b18028e349}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] 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{8894804123a966723b4c01f8db5bf7f5}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] 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{41bea1ca481d3cd6604479e9970e45dc}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] 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{7f929b417da77af0f804fd787bc24a1e}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] 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{ce0ecd333eae836de94b16c9621afd89}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] 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{31d06195da50a2f9873ee84225b03947}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] 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{2a6c8802cc60d7b4e192684ca5fcc5f0}, jobId:
7d14475f3ad609fb9efb84db8b9902b6).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-2bc881d8-19cd-4909-9509-873f020ee86b
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher4fc73592-f681-43cd-8460-79451758b12f.
[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.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:42615
[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 2008 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@e1f54b2f
.
----------------------------------------------------------------------
Ran 24 tests in 82.637s
OK (skipped=6)
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Task worker for ':'
Thread 5,5,main]) completed. Took 1 mins 25.08 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 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 12m 1s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/bljapj7xfj2fg
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
