See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/2/display/redirect?page=changes>
Changes:
[yifanzou] [BEAM-5700] remove the extra licenses from python bigquery IT
------------------------------------------
[...truncated 254.20 MB...]
[flink-akka.actor.default-dispatcher-2] 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) 801c9322ead463e7faeba7538eb265b6.
[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) (8/16) (76b61d1fbe2f361af034d009ac88f847) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 839cf66aae0c0b060f87f0041455bfad.
[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) (6/16) (3b6764f07dbabeb65a428e9d6e3cf3a9) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 5fc58178cd48f069a93bb42fbf0126fd.
[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) (5/16) (801c9322ead463e7faeba7538eb265b6) 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) (11/16) (839cf66aae0c0b060f87f0041455bfad) switched
from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 6087f6bcb44ce26b31f4b59f9d9c2ac2.
[flink-akka.actor.default-dispatcher-3] 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) (6/16) (5fc58178cd48f069a93bb42fbf0126fd) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) dc7e6e0d1309e50e396143621b621bb0.
[flink-akka.actor.default-dispatcher-2] 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) e783620e7503dab514b5c577e55d893d.
[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) (14/16) (6087f6bcb44ce26b31f4b59f9d9c2ac2) switched
from CANCELING to CANCELED.
[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) (9/16) (dc7e6e0d1309e50e396143621b621bb0) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 05965680ebc7dc2c3f427def620265f7.
[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) (7/16) (e783620e7503dab514b5c577e55d893d) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) eec3764677d1643c160d0591bc3647af.
[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) (05965680ebc7dc2c3f427def620265f7) switched
from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) b93f9643b095d7cfd32ea845b1b61fbd.
[flink-akka.actor.default-dispatcher-3] 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) (eec3764677d1643c160d0591bc3647af) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) c79fd5711ef23d47b3a8fac070e51c70.
[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) (3/16) (b93f9643b095d7cfd32ea845b1b61fbd) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) c221ccbffe75ddb278b5ee0ffe19ebbd.
[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) (c79fd5711ef23d47b3a8fac070e51c70) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 11cefea3e854066a78ae3872a5b4fcf3.
[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) (15/16) (c221ccbffe75ddb278b5ee0ffe19ebbd) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 4f0d44a954201cd7301405db8f166737.
[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) (15/16) (11cefea3e854066a78ae3872a5b4fcf3) switched
from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) b23877c024e65960b6764024847a4ef1.
[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) (4f0d44a954201cd7301405db8f166737) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 01d9f128c6e543c3d1997a4fe914a017.
[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) (2/16) (b23877c024e65960b6764024847a4ef1) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 05f80920cfdbae396cb0ba816d436b75.
[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) (16/16) (01d9f128c6e543c3d1997a4fe914a017) switched
from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) a2a3e3b84c94cd72167cc8c0391aa455.
[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) (2/16) (05f80920cfdbae396cb0ba816d436b75) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 28f18193e4b51a99a0dff11841ea12fa.
[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) (14/16) (a2a3e3b84c94cd72167cc8c0391aa455) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 3f0053082b8871bacfd2795752707958.
[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) (10/16) (28f18193e4b51a99a0dff11841ea12fa) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) a3af515bb9e0640a1056034f4dfc7a06.
[flink-akka.actor.default-dispatcher-3] 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) (3f0053082b8871bacfd2795752707958) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) 0c4aad827cb9a12e63aded1bfed27d16.
[flink-akka.actor.default-dispatcher-3] 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) (a3af515bb9e0640a1056034f4dfc7a06) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-2] 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) bf43e31783da605e88b6f23355857fe5.
[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) (8/16) (0c4aad827cb9a12e63aded1bfed27d16) switched from
CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] 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) (bf43e31783da605e88b6f23355857fe5) 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) (0b2dcabefb723db64ad8fb583dec1b98) 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) (0b2dcabefb723db64ad8fb583dec1b98).
[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)] 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) (1/16) (99339d26daabdbd6e74b4b28ebac7a59) 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) (1/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) (1/16) (99339d26daabdbd6e74b4b28ebac7a59).
[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) (13/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) (13/16) (50d09eaf4d2603f33d09388f539ff90e) switched
from CANCELING to 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) (13/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) (13/16) (50d09eaf4d2603f33d09388f539ff90e).
[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)] 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) (3/16) (47ba87bf1481f882b13688d66ff956d0) 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) (3/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) (3/16) (47ba87bf1481f882b13688d66ff956d0).
[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) (13/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) (13/16) (50d09eaf4d2603f33d09388f539ff90e) [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) (3/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) (3/16) (47ba87bf1481f882b13688d66ff956d0) [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) (1/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) (1/16) (99339d26daabdbd6e74b4b28ebac7a59) [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) (0b2dcabefb723db64ad8fb583dec1b98) [CANCELED]
[flink-akka.actor.default-dispatcher-4] 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) 50d09eaf4d2603f33d09388f539ff90e.
[flink-akka.actor.default-dispatcher-4] 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) 47ba87bf1481f882b13688d66ff956d0.
[flink-akka.actor.default-dispatcher-4] 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) 0b2dcabefb723db64ad8fb583dec1b98.
[flink-akka.actor.default-dispatcher-4] 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) 99339d26daabdbd6e74b4b28ebac7a59.
[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) (13/16) (50d09eaf4d2603f33d09388f539ff90e) switched
from CANCELING to CANCELED.
[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) (3/16) (47ba87bf1481f882b13688d66ff956d0) switched from
CANCELING to CANCELED.
[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) (13/16) (0b2dcabefb723db64ad8fb583dec1b98) switched from
CANCELING to CANCELED.
[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) (1/16) (99339d26daabdbd6e74b4b28ebac7a59) 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-1010234953-79a61ffa
(489d228f40beacb0edcb5cb7405b90b8) if no longer possible.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1010234953-79a61ffa
(489d228f40beacb0edcb5cb7405b90b8) 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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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-1010234953-79a61ffa
(489d228f40beacb0edcb5cb7405b90b8) 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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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
489d228f40beacb0edcb5cb7405b90b8 reached globally terminal state FAILED.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1010234953-79a61ffa(489d228f40beacb0edcb5cb7405b90b8).
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatchercb1fc754-5165-4543-9310-6df62290d001.
[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-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatchercb1fc754-5165-4543-9310-6df62290d001.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
984a18a1b2993847efaf5448b792e616: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[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 ccaac2b46301cc2ed5f118bfe691e6f1 from the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
489d228f40beacb0edcb5cb7405b90b8 with leader id
87d682573c78093153fb0a4b3f814086 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-b1f05586-45a3-402f-936d-eda0c841d645
[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-4] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[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_212.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatchercb1fc754-5165-4543-9310-6df62290d001.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:44185
[flink-akka.actor.default-dispatcher-4] 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-1010234953-79a61ffa_4f84cb17-9b75-490e-93bc-4d424d5da3a6.
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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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=3
--logging_endpoint=localhost:35751 --artifact_endpoint=localhost:35931
--provision_endpoint=localhost:43659 --control_endpoint=localhost:35133'.
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-1010234953-79a61ffa_94f27ece-6b25-4c80-859f-05cd5f2a09d5/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-1010234953-79a61ffa_94f27ece-6b25-4c80-859f-05cd5f2a09d5/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:36207
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:43861
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 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
170 tests completed, 160 failed, 1 skipped
Finished generating test XML results (0.944 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 (2.013 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 41.501 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 41s
61 actionable tasks: 57 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/qdce66uguc2ua
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
