See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/1/display/redirect>
------------------------------------------
[...truncated 254.19 MB...]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (5/16) (5ed7a4e5597c8308acf0cc08df787922).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (5/16) is already in state FAILED
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 8bea6a8200a7e979619f92e9f8b72d59.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (7/16) (cfaf23da3496d79c57b227c3f7ac6977).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (7/16) is already in state FAILED
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (8/16) (6a03d104b8391860cf38bff2bc41b7e6).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (8/16) is already in state FAILED
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) c2247abd22a535943f1a7f203395e317.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (10/16) (8bea6a8200a7e979619f92e9f8b72d59) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) e39a92220f133d2bfadc58da7dccdc98.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (8/16) (c2247abd22a535943f1a7f203395e317) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (11/16) (f9f92ecbf526ab26077c003039130e7a).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (11/16) is already in state FAILED
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (12/16) (a46eeff21a9e89d098ad22e5ef249927).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (12/16) is already in state FAILED
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 18b2c3d8181b5c9625d08c5592f1b0de.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (9/16) (e39a92220f133d2bfadc58da7dccdc98) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16) (750cf079fe95f2e60e7c76e439510201).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16) (750cf079fe95f2e60e7c76e439510201) switched from
RUNNING to CANCELING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (15/16) (18b2c3d8181b5c9625d08c5592f1b0de) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task
code CHAIN MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16) (750cf079fe95f2e60e7c76e439510201).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) f9f92ecbf526ab26077c003039130e7a.
[CHAIN MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16)] WARN
org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull
docker image jenkins-docker-apache.bintray.io/beam/java, cause: null
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (14/16) (e22b126ce3b5d70b8fb60d289dc555fc).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskmanager.Task - Task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (14/16) is already in state FAILED
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 5ed7a4e5597c8308acf0cc08df787922.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (11/16) (f9f92ecbf526ab26077c003039130e7a) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 9d9424e6f39a16e388790a2ab75028a8.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (5/16) (5ed7a4e5597c8308acf0cc08df787922) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (16/16) (ecdafb4d203d621081e4c132fec4c3c5).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (16/16) is already in state FAILED
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 2d02ac3becee1ecf15b0fb08d189266f.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (2/16) (9d9424e6f39a16e388790a2ab75028a8) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) ecdafb4d203d621081e4c132fec4c3c5.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (3/16) (2d02ac3becee1ecf15b0fb08d189266f) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) e22b126ce3b5d70b8fb60d289dc555fc.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (16/16) (ecdafb4d203d621081e4c132fec4c3c5) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 6a03d104b8391860cf38bff2bc41b7e6.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (14/16) (e22b126ce3b5d70b8fb60d289dc555fc) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 86c5dcff0bf1c8dfa707926989a7d1a5.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (8/16) (6a03d104b8391860cf38bff2bc41b7e6) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) cfaf23da3496d79c57b227c3f7ac6977.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (2/16) (86c5dcff0bf1c8dfa707926989a7d1a5) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 12f714cfd8c63421b4ef67b4ca5290d4.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (7/16) (cfaf23da3496d79c57b227c3f7ac6977) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) f5f8da6b1722e168c3cd13780ee06b0e.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (10/16) (12f714cfd8c63421b4ef67b4ca5290d4) switched
from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) a46eeff21a9e89d098ad22e5ef249927.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (6/16) (f5f8da6b1722e168c3cd13780ee06b0e) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 8d356b7df667c9760efc3236c8dc5bb4.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (12/16) (a46eeff21a9e89d098ad22e5ef249927) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 11743fa49986eaac9bb2d9643a28e310.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (12/16) (8d356b7df667c9760efc3236c8dc5bb4) switched
from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 66b47466917ce04743329dd7a21edd6e.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (1/16) (11743fa49986eaac9bb2d9643a28e310) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (7/16) (66b47466917ce04743329dd7a21edd6e) switched from
CANCELING to CANCELED.
[CHAIN MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task
- CHAIN MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16) (750cf079fe95f2e60e7c76e439510201) switched from
CANCELING to CANCELED.
[CHAIN MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task
- Freeing task resources for CHAIN MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16) (750cf079fe95f2e60e7c76e439510201).
[CHAIN MapPartition (MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task
- CHAIN MapPartition (MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (1/16) (0b51881d27a04134cc232e2866ece4c5) switched from
CANCELING to CANCELED.
[CHAIN MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task
- Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16) (750cf079fe95f2e60e7c76e439510201) [CANCELED]
[CHAIN MapPartition (MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task
- Freeing task resources for CHAIN MapPartition (MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (1/16) (0b51881d27a04134cc232e2866ece4c5).
[CHAIN MapPartition (MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task
- Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (1/16) (0b51881d27a04134cc232e2866ece4c5) [CANCELED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state CANCELED to JobManager for task CHAIN
MapPartition (MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 750cf079fe95f2e60e7c76e439510201.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state CANCELED to JobManager for task CHAIN
MapPartition (MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) 0b51881d27a04134cc232e2866ece4c5.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap
(FlatMap at
Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (13/16) (750cf079fe95f2e60e7c76e439510201) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
-> FlatMap (FlatMap at
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
-> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
PAssert$125/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
-> Map (Key Extractor) (1/16) (0b51881d27a04134cc232e2866ece4c5) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Try to restart or fail
the job reifytimestampstest0invaluessucceeds-jenkins-1010231658-9e3ed693
(6a074ace872c1fde8a8f367e54b35b06) if no longer possible.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1010231658-9e3ed693
(6a074ace872c1fde8a8f367e54b35b06) switched from state FAILING to FAILED.
java.lang.Exception: The user defined 'open()' method caused an exception:
java.io.IOException: Received exit code 125 for command 'docker run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:498)
at
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:368)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)
at java.lang.Thread.run(Thread.java:748)
Caused by:
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.util.concurrent.UncheckedExecutionException:
java.io.IOException: Received exit code 125 for command 'docker run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4994)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:157)
at
org.apache.beam.runners.flink.translation.functions.FlinkDefaultExecutableStageContext.getStageBundleFactory(FlinkDefaultExecutableStageContext.java:59)
at
org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.getStageBundleFactory(ReferenceCountingFlinkExecutableStageContextFactory.java:175)
at
org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.open(FlinkExecutableStageFunction.java:103)
at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:494)
... 3 more
Caused by: java.io.IOException: Received exit code 125 for command 'docker
run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:154)
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.runImage(DockerCommand.java:87)
at
org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory.createEnvironment(DockerEnvironmentFactory.java:151)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.lambda$new$0(DefaultJobBundleFactory.java:104)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:149)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:145)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3628)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2336)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2295)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2208)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.get(LocalCache.java:4053)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4992)
... 9 more
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Could not restart the
job reifytimestampstest0invaluessucceeds-jenkins-1010231658-9e3ed693
(6a074ace872c1fde8a8f367e54b35b06) because the restart strategy prevented it.
java.lang.Exception: The user defined 'open()' method caused an exception:
java.io.IOException: Received exit code 125 for command 'docker run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:498)
at
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:368)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)
at java.lang.Thread.run(Thread.java:748)
Caused by:
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.util.concurrent.UncheckedExecutionException:
java.io.IOException: Received exit code 125 for command 'docker run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4994)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:157)
at
org.apache.beam.runners.flink.translation.functions.FlinkDefaultExecutableStageContext.getStageBundleFactory(FlinkDefaultExecutableStageContext.java:59)
at
org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.getStageBundleFactory(ReferenceCountingFlinkExecutableStageContextFactory.java:175)
at
org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.open(FlinkExecutableStageFunction.java:103)
at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:494)
... 3 more
Caused by: java.io.IOException: Received exit code 125 for command 'docker
run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:154)
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.runImage(DockerCommand.java:87)
at
org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory.createEnvironment(DockerEnvironmentFactory.java:151)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.lambda$new$0(DefaultJobBundleFactory.java:104)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:149)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:145)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3628)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2336)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2295)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2208)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.get(LocalCache.java:4053)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4992)
... 9 more
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
6a074ace872c1fde8a8f367e54b35b06 reached globally terminal state FAILED.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1010231658-9e3ed693(6a074ace872c1fde8a8f367e54b35b06).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherf6bd615e-174e-4c10-8c94-b44c557e8158.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherf6bd615e-174e-4c10-8c94-b44c557e8158.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
10049072176d6b75320c2e4ba89659fc: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager 3bfab88d048112c27ea5620d54308d86 from the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
6a074ace872c1fde8a8f367e54b35b06 with leader id
b312d2e5e74ba0bef3ed8d3e668a40ff lost leadership.
[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-91378983-f480-49e5-9888-67a36a8114c6
[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-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_212.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherf6bd615e-174e-4c10-8c94-b44c557e8158.
[ForkJoinPool.commonPool-worker-2] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-2] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40209
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] ERROR
org.apache.beam.runners.flink.FlinkJobInvocation - Error during job invocation
reifytimestampstest0invaluessucceeds-jenkins-1010231658-9e3ed693_f1ecee83-ef55-48c2-b6db-9c36fe7c76cf.
org.apache.flink.runtime.client.JobExecutionException: java.lang.Exception:
The user defined 'open()' method caused an exception: java.io.IOException:
Received exit code 125 for command 'docker run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at
org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:625)
at
org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:234)
at
org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:91)
at
org.apache.beam.runners.flink.FlinkJobInvocation.runPipeline(FlinkJobInvocation.java:114)
at
org.apache.beam.repackaged.beam_runners_flink_2.11.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:111)
at
org.apache.beam.repackaged.beam_runners_flink_2.11.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:58)
at
org.apache.beam.repackaged.beam_runners_flink_2.11.com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:75)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.Exception: The user defined 'open()' method caused an
exception: java.io.IOException: Received exit code 125 for command 'docker run
-d --mount type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:498)
at
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:368)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)
... 1 more
Caused by:
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.util.concurrent.UncheckedExecutionException:
java.io.IOException: Received exit code 125 for command 'docker run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4994)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:157)
at
org.apache.beam.runners.flink.translation.functions.FlinkDefaultExecutableStageContext.getStageBundleFactory(FlinkDefaultExecutableStageContext.java:59)
at
org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.getStageBundleFactory(ReferenceCountingFlinkExecutableStageContextFactory.java:175)
at
org.apache.beam.runners.flink.translation.functions.FlinkExecutableStageFunction.open(FlinkExecutableStageFunction.java:103)
at
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:494)
... 3 more
Caused by: java.io.IOException: Received exit code 125 for command 'docker
run -d --mount
type=bind,src=/home/jenkins/.config/gcloud,dst=/root/.config/gcloud
--network=host --env=DOCKER_MAC_CONTAINER=null --rm
jenkins-docker-apache.bintray.io/beam/java --id=2
--logging_endpoint=localhost:33971 --artifact_endpoint=localhost:40675
--provision_endpoint=localhost:37525 --control_endpoint=localhost:40479'.
stderr: Unable to find image
'jenkins-docker-apache.bintray.io/beam/java:latest' locallydocker: Error
response from daemon: unknown: Repo 'apache' was not found.See 'docker run
--help'.
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:154)
at
org.apache.beam.runners.fnexecution.environment.DockerCommand.runImage(DockerCommand.java:87)
at
org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory.createEnvironment(DockerEnvironmentFactory.java:151)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.lambda$new$0(DefaultJobBundleFactory.java:104)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:149)
at
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:145)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3628)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2336)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2295)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2208)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.get(LocalCache.java:4053)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
at
org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4992)
... 9 more
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1010231658-9e3ed693_75afa8d6-7ea3-4c6c-be2b-e44bc34b2db8/MANIFEST
has 178 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1010231658-9e3ed693_75afa8d6-7ea3-4c6c-be2b-e44bc34b2db8/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:36973
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:46343
org.apache.beam.sdk.transforms.ReifyTimestampsTest > inValuesSucceeds FAILED
java.lang.AssertionError: Pipeline did not succeed.
Expected: is <DONE>
but: was <FAILED>
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
at
org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:87)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:313)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:350)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:331)
at
org.apache.beam.sdk.transforms.ReifyTimestampsTest.inValuesSucceeds(ReifyTimestampsTest.java:61)
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
170 tests completed, 160 failed, 1 skipped
Finished generating test XML results (1.477 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunner>
Generating HTML test report...
Finished generating test html results (1.716 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker
for ':' Thread 11,5,main]) completed. Took 19 mins 36.16 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner/index.html>
* 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 22m 23s
61 actionable tasks: 57 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/kkxyrhqz5w2y4
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
