beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: beam_PostCommit_Python_PVR_Flink_Gradle #96
Date Fri, 21 Sep 2018 21:13:27 GMT
See <https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/96/display/redirect?page=changes>

Changes:

[scott] Upgrade gradle wrapper to latest (4.10)

------------------------------------------
[...truncated 60.14 MB...]
[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) (5b1db8c497856f658fbd17c29b97877e)
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) (5b1db8c497856f658fbd17c29b97877e).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (c5c32629fc9d8b37cf43e9c8a5929ffa)
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) (e163ac11aaad9c58928b4053ba0e9ce6)
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) (e163ac11aaad9c58928b4053ba0e9ce6).
[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) (7bb845c239229e560f5b902fef356e6c)
switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (9e18a428a742b3008608f7311a8881a6)
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) (d77c8c990dc924eb4875d946af34571e).
[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) (4a7c1fc8144828b21f65eb53a4a4591e)
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) (4a7c1fc8144828b21f65eb53a4a4591e).
[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) (d77c8c990dc924eb4875d946af34571e) [FINISHED]
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task ToKeyedWorkItem (7/16) (5683639c38b59f853b30e78abde90dea) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams
are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(11/16) (4a7c1fc8144828b21f65eb53a4a4591e) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (b6f28a7afa8bd22247f0800e4451a048)
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) (b6f28a7afa8bd22247f0800e4451a048).
[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) (56a57fef653687b32b3a7f37f3823542) [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) (b6f28a7afa8bd22247f0800e4451a048) [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) (9e18a428a742b3008608f7311a8881a6).
[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) (7bb845c239229e560f5b902fef356e6c).
[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 d77c8c990dc924eb4875d946af34571e.
[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) (9e18a428a742b3008608f7311a8881a6) [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) (e163ac11aaad9c58928b4053ba0e9ce6) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (488dc6b230efe1d9d6fc064cc52b83a2)
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) (488dc6b230efe1d9d6fc064cc52b83a2).
[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) (488dc6b230efe1d9d6fc064cc52b83a2) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (49b317af783fcabc6f2c21e2c4e3078d)
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) (49b317af783fcabc6f2c21e2c4e3078d).
[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) (5b1db8c497856f658fbd17c29b97877e) [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) (49b317af783fcabc6f2c21e2c4e3078d) [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 4a7c1fc8144828b21f65eb53a4a4591e.
[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) (79f90c4bb29100e4b7f9c82ce73a118f)
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) (79f90c4bb29100e4b7f9c82ce73a118f).
[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) (134e2517413e2ce4e96726fad9f107c4)
switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (9/16) (134e2517413e2ce4e96726fad9f107c4).
[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) (134e2517413e2ce4e96726fad9f107c4) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
5683639c38b59f853b30e78abde90dea.
[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) (9e3e7d563a26516b143c383996f4396c).
[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
(3/16) (d77c8c990dc924eb4875d946af34571e) 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 - 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) (79f90c4bb29100e4b7f9c82ce73a118f) [FINISHED]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey ->
42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (4a5e0b400b6a06832620171b2777e6f0)
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 b6f28a7afa8bd22247f0800e4451a048.
[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) (4a5e0b400b6a06832620171b2777e6f0).
[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
(11/16) (4a7c1fc8144828b21f65eb53a4a4591e) 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 56a57fef653687b32b3a7f37f3823542.
[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) (17da3b479277c2a5185a6ae99c4a7dc2)
switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- ToKeyedWorkItem (7/16) (5683639c38b59f853b30e78abde90dea) 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) (17da3b479277c2a5185a6ae99c4a7dc2).
[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 e163ac11aaad9c58928b4053ba0e9ce6.
[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
(7/16) (b6f28a7afa8bd22247f0800e4451a048) 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 5b1db8c497856f658fbd17c29b97877e.
[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 49b317af783fcabc6f2c21e2c4e3078d.
[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
(1/16) (56a57fef653687b32b3a7f37f3823542) 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 134e2517413e2ce4e96726fad9f107c4.
[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
(13/16) (e163ac11aaad9c58928b4053ba0e9ce6) 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 79f90c4bb29100e4b7f9c82ce73a118f.
[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) (9e3e7d563a26516b143c383996f4396c) [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) (17da3b479277c2a5185a6ae99c4a7dc2) [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) (4a5e0b400b6a06832620171b2777e6f0) [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) (7bb845c239229e560f5b902fef356e6c) [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 488dc6b230efe1d9d6fc064cc52b83a2.
[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
(5/16) (5b1db8c497856f658fbd17c29b97877e) 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 9e18a428a742b3008608f7311a8881a6.
[grpc-default-executor-5] INFO sdk_worker.run - Got work 103
[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
(16/16) (49b317af783fcabc6f2c21e2c4e3078d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 9e3e7d563a26516b143c383996f4396c.
[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
(9/16) (134e2517413e2ce4e96726fad9f107c4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 17da3b479277c2a5185a6ae99c4a7dc2.
[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 4a5e0b400b6a06832620171b2777e6f0.
[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
(15/16) (79f90c4bb29100e4b7f9c82ce73a118f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 7bb845c239229e560f5b902fef356e6c.
[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
(10/16) (488dc6b230efe1d9d6fc064cc52b83a2) switched from RUNNING to FINISHED.
[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
(12/16) (9e18a428a742b3008608f7311a8881a6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(4/16) (9e3e7d563a26516b143c383996f4396c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(6/16) (17da3b479277c2a5185a6ae99c4a7dc2) switched from RUNNING to FINISHED.
[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
(8/16) (4a5e0b400b6a06832620171b2777e6f0) switched from RUNNING to FINISHED.
[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
(14/16) (7bb845c239229e560f5b902fef356e6c) switched from RUNNING to FINISHED.
[grpc-default-executor-5] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Match
output_tags=['out']>
[grpc-default-executor-5] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Unkey
output_tags=['out']>
[grpc-default-executor-5] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Group/Map(_merge_tagged_vals_under_key)
output_tags=['out']>
[grpc-default-executor-5] INFO bundle_processor.process_bundle - start <DataInputOperation
 receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder],
IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-5] INFO bundle_processor.process_bundle - finish <DataInputOperation
 receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder],
IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-5] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Group/Map(_merge_tagged_vals_under_key)
output_tags=['out'], receivers=[ConsumerSet[assert_that/Group/Map(_merge_tagged_vals_under_key).out0,
coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-5] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Unkey
output_tags=['out'], receivers=[ConsumerSet[assert_that/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder],
len(consumers)=1]]>
[grpc-default-executor-5] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Match
output_tags=['out'], receivers=[ConsumerSet[assert_that/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder],
len(consumers)=0]]>
[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] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-5] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged
up for unknown endpoint.
[grpc-default-executor-5] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-5] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-5] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-5] 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)] WARN org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase - Error cleaning
up environment url: "jenkins-docker-apache.bintray.io/beam/python:latest"
urn: "beam:env:docker:v1"
payload: "\n3jenkins-docker-apache.bintray.io/beam/python:latest"

java.lang.IllegalStateException: call already closed
	at org.apache.beam.vendor.guava.v20.com.google.common.base.Preconditions.checkState(Preconditions.java:444)
	at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:172)
	at org.apache.beam.vendor.grpc.v1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:358)
	at org.apache.beam.runners.fnexecution.state.GrpcStateService.close(GrpcStateService.java:54)
	at org.apache.beam.runners.fnexecution.GrpcFnServer.close(GrpcFnServer.java:83)
	at org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase$WrappedSdkHarnessClient.$closeResource(JobBundleFactoryBase.java:327)
	at org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase$WrappedSdkHarnessClient.close(JobBundleFactoryBase.java:327)
	at org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase.lambda$createEnvironmentCache$0(JobBundleFactoryBase.java:147)
	at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.processPendingNotifications(LocalCache.java:1963)
	at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.runUnlockedCleanup(LocalCache.java:3562)
	at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.postWriteCleanup(LocalCache.java:3538)
	at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.clear(LocalCache.java:3309)
	at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.clear(LocalCache.java:4322)
	at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalManualCache.invalidateAll(LocalCache.java:4937)
	at org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase.close(JobBundleFactoryBase.java:185)
	at org.apache.beam.runners.flink.translation.functions.FlinkDefaultExecutableStageContext.close(FlinkDefaultExecutableStageContext.java:46)
	at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.closeActual(ReferenceCountingFlinkExecutableStageContextFactory.java:185)
	at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.access$200(ReferenceCountingFlinkExecutableStageContextFactory.java:161)
	at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory.release(ReferenceCountingFlinkExecutableStageContextFactory.java:149)
	at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory.scheduleRelease(ReferenceCountingFlinkExecutableStageContextFactory.java:109)
	at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory.access$300(ReferenceCountingFlinkExecutableStageContextFactory.java:40)
	at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.close(ReferenceCountingFlinkExecutableStageContextFactory.java:181)
	at org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator.$closeResource(ExecutableStageDoFnOperator.java:187)
	at org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator.close(ExecutableStageDoFnOperator.java:202)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:438)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:323)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)
	at java.lang.Thread.run(Thread.java:748)
[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) (141c968824e06b0274268842678079e9)
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) (141c968824e06b0274268842678079e9).
[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) (141c968824e06b0274268842678079e9) [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 141c968824e06b0274268842678079e9.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0
(2/16) (141c968824e06b0274268842678079e9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Job test_windowing_1537564402.35 (82435228a13539bbe2abd3541fdfbb51) switched from state
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator
- Stopping checkpoint coordinator for job 82435228a13539bbe2abd3541fdfbb51.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore
- Shutting down
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher
- Job 82435228a13539bbe2abd3541fdfbb51 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_1537564402.35(82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Close JobManager connection for job 82435228a13539bbe2abd3541fdfbb51.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster
- Close ResourceManager connection ed8fdc901058eac23b2ed7ca95d351de: JobManager is shutting
down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool
- Suspending SlotPool.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting
down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager
- Disconnect job manager a5d5cc05bf2bbca23ab32f682ad54918@akka://flink/user/jobmanager_41
for job 82435228a13539bbe2abd3541fdfbb51 from the resource manager.
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint
- Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-3] 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/dispatcher5f5dafc9-754a-41af-b073-3452b148135c.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher
- Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher5f5dafc9-754a-41af-b073-3452b148135c.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- JobManager for job 82435228a13539bbe2abd3541fdfbb51 with leader id a5d5cc05bf2bbca23ab32f682ad54918
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 7f686430c7475ac81a21bdc4481746ca from the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{79a30c9ca3bbe7b6e63463cd03520ebe}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] 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{ef3da052aa2564a20cbefa434a1d28c8}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{c687631fceafa6cc900f5271bb880213}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] 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{fe18885700be48ecfebfca23e168ac76}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[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{3101c447fb7b90ef2654d2b51a1f6be8}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{f88e40c67d8601de5617dce787a602f6}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8770fcb243bfccbde1f13004cfb493b2}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[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-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{66be6ce1d4b025c4830c5e6cfe29c801}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher
- Stopped dispatcher akka://flink/user/dispatcher5f5dafc9-754a-41af-b073-3452b148135c.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{9c1876c61ab8f75a4dc34ae7cf0bb660}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{f35a618d57bc3f7f547f6c8116e468ac}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{f6f1383582b64c4e5d6651848be35ba9}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{cb9b88bc11e30e9113d6ac6c0b5fe92c}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{afbea72087e2dc4aaf17f2f5ee424d76}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{9ad1be4993453d55af5121d35b53538f}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[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{3b0299768baedef7da8221de58844e6c}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-3] 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{c2d7a44a1001f8cff152b3fab0c900b3}, jobId: 82435228a13539bbe2abd3541fdfbb51).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService
- Remove job 82435228a13539bbe2abd3541fdfbb51 from job leader monitoring.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Close JobManager connection for job 82435228a13539bbe2abd3541fdfbb51.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Stopping TaskExecutor akka://flink/user/taskmanager_40.
[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-7b2482e4-f36b-4c02-ad71-abfe10eb8b83
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.network.NetworkEnvironment
- Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint
- Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService
- Stop job leader service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Stopped TaskExecutor akka://flink/user/taskmanager_40.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
- Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache
- Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache
- Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped
BLOB server at 0.0.0.0:36391
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
- Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished
in 1955 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@70536ef3
.
======================================================================
ERROR: test_pardo_state_only (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/fn_api_runner_test.py", line 253, in test_pardo_state_only
    equal_to(expected))
  File "apache_beam/pipeline.py", line 414, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 209, in wait_until_finish
    'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline test_pardo_state_only_1537564388.3_7142126b-dd3a-4e08-8efd-6b9ef47a1bed
failed in state FAILED.

----------------------------------------------------------------------
Ran 24 tests in 79.645s

FAILED (errors=1, skipped=5)
Segmentation fault (core dumped)

> Task :beam-sdks-python:flinkCompatibilityMatrixStreaming FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Task worker for ':' Thread 3,5,main])
completed. Took 1 mins 21.853 secs.

FAILURE: Build completed with 2 failures.

1: Task failed with an exception.
-----------
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/ws/src/sdks/python/build.gradle'>
line: 340

* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatch'.
> Process 'command 'sh'' finished with non-zero exit value 139

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log
output. Run with --scan to get full insights.
==============================================================================

2: Task failed with an exception.
-----------
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/ws/src/sdks/python/build.gradle'>
line: 340

* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreaming'.
> Process 'command 'sh'' finished with non-zero exit value 139

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log
output. Run with --scan to get full insights.
==============================================================================

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 21m 33s
59 actionable tasks: 58 executed, 1 up-to-date

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

Stopped 1 worker daemon(s).
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

Mime
View raw message