You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/10/10 23:50:17 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #2
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
Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink
#10
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/10/display/redirect?page=changes>
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #9
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/9/display/redirect>
------------------------------------------
[...truncated 292.05 KB...]
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.ParDoSchemaTest.testReadAndWriteMultiOutput(ParDoSchemaTest.java:234)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests > testWindowingInStartAndFinishBundle FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoTest$LifecycleTests.testWindowingInStartAndFinishBundle(ParDoTest.java:1217)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testMergingWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testMergingWindowing(WindowingTest.java:168)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testWindowPreservation FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testWindowPreservation(WindowingTest.java:197)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testNonPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testNonPartitioningWindowing(WindowingTest.java:150)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testPartitioningWindowing(WindowingTest.java:126)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerEndOfWindow FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerEndOfWindow(WindowTest.java:497)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerDefault FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerDefault(WindowTest.java:467)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testNoWindowFnDoesNotReassignWindows FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testNoWindowFnDoesNotReassignWindows(WindowTest.java:433)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsShouldApplyTimestamps(WithTimestampsTest.java:78)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed(WithTimestampsTest.java:142)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsLambdaShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsLambdaShouldApplyTimestamps(WithTimestampsTest.java:205)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesWhenValueTimestampedLaterSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesWhenValueTimestampedLaterSucceeds(ReifyTimestampsTest.java:129)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesSucceeds(ReifyTimestampsTest.java:93)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > inValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
170 tests completed, 160 failed, 1 skipped
Finished generating test XML results (0.074 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 (0.058 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 21.644 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 3m 5s
61 actionable tasks: 57 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/3akcadl3ae7y2
Build cache (/home/jenkins/.gradle/caches/build-cache-1) removing files not accessed on or after Tue Oct 09 00:00:12 UTC 2018.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4378} MaxSize{4500}, CacheStats{hitCount=16, missCount=4121, loadSuccessCount=4122, loadExceptionCount=0, totalLoadTime=207553848, evictionCount=1}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=17, missCount=4693, loadSuccessCount=4694, loadExceptionCount=0, totalLoadTime=231191768, evictionCount=451}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=17, missCount=5143, loadSuccessCount=5144, loadExceptionCount=0, totalLoadTime=251382632, evictionCount=901}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=17, missCount=5593, loadSuccessCount=5594, loadExceptionCount=0, totalLoadTime=269966492, evictionCount=1351}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=17, missCount=6043, loadSuccessCount=6044, loadExceptionCount=0, totalLoadTime=292353302, evictionCount=1801}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Cache entries evicted. In-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin: Size{4500} MaxSize{4500}, CacheStats{hitCount=17, missCount=6493, loadSuccessCount=6494, loadExceptionCount=0, totalLoadTime=317947129, evictionCount=2251}
Performance may suffer from in-memory cache misses. Increase max heap size of Gradle build process to reduce cache misses.
Build cache (/home/jenkins/.gradle/caches/build-cache-1) cleaned up in 0.48 secs.
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #8
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/8/display/redirect?page=changes>
Changes:
[ccy] [BEAM-5754] Fix parentheses grouping warning for
------------------------------------------
[...truncated 293.84 KB...]
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.ParDoSchemaTest.testReadAndWriteWithSchemaRegistry(ParDoSchemaTest.java:279)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoSchemaTest > testReadAndWriteMultiOutput FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoSchemaTest.testReadAndWriteMultiOutput(ParDoSchemaTest.java:234)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests > testWindowingInStartAndFinishBundle FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoTest$LifecycleTests.testWindowingInStartAndFinishBundle(ParDoTest.java:1217)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testMergingWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testMergingWindowing(WindowingTest.java:168)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testWindowPreservation FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testWindowPreservation(WindowingTest.java:197)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testNonPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testNonPartitioningWindowing(WindowingTest.java:150)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testPartitioningWindowing(WindowingTest.java:126)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerEndOfWindow FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerEndOfWindow(WindowTest.java:497)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerDefault FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerDefault(WindowTest.java:467)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testNoWindowFnDoesNotReassignWindows FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testNoWindowFnDoesNotReassignWindows(WindowTest.java:433)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsShouldApplyTimestamps(WithTimestampsTest.java:78)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed(WithTimestampsTest.java:142)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsLambdaShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsLambdaShouldApplyTimestamps(WithTimestampsTest.java:205)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesWhenValueTimestampedLaterSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesWhenValueTimestampedLaterSucceeds(ReifyTimestampsTest.java:129)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesSucceeds(ReifyTimestampsTest.java:93)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > inValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
170 tests completed, 160 failed, 1 skipped
Finished generating test XML results (0.077 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 (0.063 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':',5,main]) completed. Took 21.171 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 3m 18s
61 actionable tasks: 58 executed, 3 from cache
Publishing build scan...
https://gradle.com/s/gpu6zqjbfen32
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #7
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/7/display/redirect?page=changes>
Changes:
[github] Revert "[BEAM-5706] Revert 324f0b3e3c (pull request #6564 from
------------------------------------------
[...truncated 290.62 KB...]
at org.apache.beam.sdk.transforms.ParDoSchemaTest.testReadAndWriteWithSchemaRegistry(ParDoSchemaTest.java:279)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoSchemaTest > testReadAndWriteMultiOutput FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoSchemaTest.testReadAndWriteMultiOutput(ParDoSchemaTest.java:234)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests > testWindowingInStartAndFinishBundle FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoTest$LifecycleTests.testWindowingInStartAndFinishBundle(ParDoTest.java:1217)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testMergingWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testMergingWindowing(WindowingTest.java:168)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testWindowPreservation FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testWindowPreservation(WindowingTest.java:197)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testNonPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testNonPartitioningWindowing(WindowingTest.java:150)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testPartitioningWindowing(WindowingTest.java:126)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerEndOfWindow FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerEndOfWindow(WindowTest.java:497)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerDefault FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerDefault(WindowTest.java:467)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testNoWindowFnDoesNotReassignWindows FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testNoWindowFnDoesNotReassignWindows(WindowTest.java:433)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsShouldApplyTimestamps(WithTimestampsTest.java:78)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed(WithTimestampsTest.java:142)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsLambdaShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsLambdaShouldApplyTimestamps(WithTimestampsTest.java:205)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesWhenValueTimestampedLaterSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesWhenValueTimestampedLaterSucceeds(ReifyTimestampsTest.java:129)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesSucceeds(ReifyTimestampsTest.java:93)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > inValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
170 tests completed, 160 failed, 1 skipped
Finished generating test XML results (0.079 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 (0.094 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 2,5,main]) completed. Took 23.839 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 3m 9s
61 actionable tasks: 57 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/k5t4emfxysnmw
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #6
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/6/display/redirect?page=changes>
Changes:
[heejong] remove redundant code in range_trackers.py
------------------------------------------
[...truncated 297.15 KB...]
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoSchemaTest > testReadAndWriteMultiOutput FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoSchemaTest.testReadAndWriteMultiOutput(ParDoSchemaTest.java:234)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests > testWindowingInStartAndFinishBundle FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoTest$LifecycleTests.testWindowingInStartAndFinishBundle(ParDoTest.java:1217)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testMergingWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testMergingWindowing(WindowingTest.java:168)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testWindowPreservation FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testWindowPreservation(WindowingTest.java:197)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testNonPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testNonPartitioningWindowing(WindowingTest.java:150)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testPartitioningWindowing(WindowingTest.java:126)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerEndOfWindow FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerEndOfWindow(WindowTest.java:497)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerDefault FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerDefault(WindowTest.java:467)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testNoWindowFnDoesNotReassignWindows FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testNoWindowFnDoesNotReassignWindows(WindowTest.java:433)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsShouldApplyTimestamps(WithTimestampsTest.java:78)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed(WithTimestampsTest.java:142)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsLambdaShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsLambdaShouldApplyTimestamps(WithTimestampsTest.java:205)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesWhenValueTimestampedLaterSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesWhenValueTimestampedLaterSucceeds(ReifyTimestampsTest.java:129)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesSucceeds(ReifyTimestampsTest.java:93)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > inValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
170 tests completed, 160 failed, 1 skipped
Finished generating test XML results (0.177 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 (0.157 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 10,5,main]) completed. Took 33.011 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 4m 3s
61 actionable tasks: 57 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/mvtyj5nipqs6m
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #5
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/5/display/redirect>
------------------------------------------
[...truncated 291.50 KB...]
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.ParDoSchemaTest.testReadAndWriteWithSchemaRegistry(ParDoSchemaTest.java:279)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoSchemaTest > testReadAndWriteMultiOutput FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoSchemaTest.testReadAndWriteMultiOutput(ParDoSchemaTest.java:234)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests > testWindowingInStartAndFinishBundle FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoTest$LifecycleTests.testWindowingInStartAndFinishBundle(ParDoTest.java:1217)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testMergingWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testMergingWindowing(WindowingTest.java:168)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testWindowPreservation FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testWindowPreservation(WindowingTest.java:197)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testNonPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testNonPartitioningWindowing(WindowingTest.java:150)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testPartitioningWindowing(WindowingTest.java:126)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerEndOfWindow FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerEndOfWindow(WindowTest.java:497)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerDefault FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerDefault(WindowTest.java:467)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testNoWindowFnDoesNotReassignWindows FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testNoWindowFnDoesNotReassignWindows(WindowTest.java:433)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsShouldApplyTimestamps(WithTimestampsTest.java:78)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed(WithTimestampsTest.java:142)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsLambdaShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsLambdaShouldApplyTimestamps(WithTimestampsTest.java:205)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesWhenValueTimestampedLaterSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesWhenValueTimestampedLaterSucceeds(ReifyTimestampsTest.java:129)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesSucceeds(ReifyTimestampsTest.java:93)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > inValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
170 tests completed, 160 failed, 1 skipped
Finished generating test XML results (0.078 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 (0.055 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 22.997 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 3m 17s
61 actionable tasks: 57 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/wjnuw3pciqabq
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #4
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/4/display/redirect?page=changes>
Changes:
[robertwb] [BEAM-3885] Translate impulse primitive for dataflow batch pipelines.
[ehudm] Update a few more apache/beam-site references
[scott] Add additional code owners for runners-core
[mergebot] Add instructions about how to sign and hash python wheels
[mergebot] Add the #beam channel
[ccy] [BEAM-3717] Fix problems with Beam downloads page
[ehudm] Fix dockerized-jenkins copy operation.
[daniel.o.programmer] [BEAM-5709] Fix flaky tests in BeamFnControlServiceTest.
[scott] Update release docs /current redirect for 2.7.0 release
[scott] [BEAM-5669] Ensure website publish doesn't create empty commits
[scott] Infer whether we need to publish Docker website port
[valentyn] [BEAM-5692] Exclude flaky in Python 3 tests from the suite.
[valentyn] Skip tests that halt test suite execution on Python 3
[valentyn] Unskip hadoopfilesystem_test which is already passing in Python 3.
[valentyn] Make it possible to run unskip Py3 tests by setting an environment
[juta_staes] [BEAM-5621] Fix unorderable types in python 3
[plovytsimon] [BEAM-5624] avro.schema parser for py3
[scott] [BEAM-5717] Only pass PR ID to Gradle if available
[scott] Trim PR ID property before checking for truthiness
[ehudm] Add individual emails on first build failure.
[kedin] Fix errorprone to version 2.3.1
[scott] [BEAM-5719] Use gcs rsync and validate that a valid baseUrl is
[yifanzou] [BEAM-5718] exclude BigQueryITReadIT
[pablo] Updating Dataflow v1b3 API
[ankurgoenka] [BEAM-5683] Print command logs on failure
[boyuanz] Make dataset id naming less possible to conflict
[boyuanz] Address Ken's comment
[scott] Use the PR context from the environment rather than Gradle properties
[migryz] Fix overriding coders due to duplicate coderId generation
[yifanzou] [BEAM-5701] port datastore_write Python integration tests to Beam
[scott] Pull URL out of logs for build description
[mxm] [BEAM-4130] Add tests for FlinkJobServerDriver
[scott] Use a unique path for staging non-PR changes instead of latest
[altay] Resolve conflicts in setup.py
[ccy] Revert "Merge pull request #6600: [BEAM-5442] Store duplicate unknown
[ccy] Revert "Merge pull request #6589: [BEAM-5442] Attempt to fix postcommit
[ccy] Revert "[BEAM-5442] Pass unknown SDK pipeline options to Runner (#6557)"
[altay] Revert "Moving to 2.9.0-SNAPSHOT on master branch."
[altay] Moving to 2.9.0-SNAPSHOT on master branch.
[ankurgoenka] [BEAM-5708] Cache environment in portable flink runner
[ajamato] Implementing a subset of the new metrics framework in python.
[boyuanz] [BEAM-5326] Java support for custom dataflow worker jar
[tweise] [BEAM-5442] Revert #6675 "Revert PRs #6557 #6589 #6600"
[github] Revert "[BEAM-5621] Fix unorderable types in python 3"
[mxm] [BEAM-3727] Add tests for ImpulseSourceFunction
[robertwb] [BEAM-5649] Conditionally remove CREATE_VIEW from java generated protos.
[robertwb] Explicitly use deprecated translation where needed.
[robertwb] Revert "[BEAM-5528] Re-add CREATE_VIEW in portable Flink translators
[migryz] Rename coders to be generated
------------------------------------------
[...truncated 295.74 KB...]
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.ParDoSchemaTest.testReadAndWriteWithSchemaRegistry(ParDoSchemaTest.java:279)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoSchemaTest > testReadAndWriteMultiOutput FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoSchemaTest.testReadAndWriteMultiOutput(ParDoSchemaTest.java:234)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ParDoTest$LifecycleTests > testWindowingInStartAndFinishBundle FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.ParDoTest$LifecycleTests.testWindowingInStartAndFinishBundle(ParDoTest.java:1217)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testMergingWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testMergingWindowing(WindowingTest.java:168)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testWindowPreservation FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testWindowPreservation(WindowingTest.java:197)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testNonPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testNonPartitioningWindowing(WindowingTest.java:150)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowingTest > testPartitioningWindowing FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowingTest.testPartitioningWindowing(WindowingTest.java:126)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerEndOfWindow FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerEndOfWindow(WindowTest.java:497)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerDefault FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testTimestampCombinerDefault(WindowTest.java:467)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.windowing.WindowTest > testNoWindowFnDoesNotReassignWindows FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.windowing.WindowTest.testNoWindowFnDoesNotReassignWindows(WindowTest.java:433)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsShouldApplyTimestamps(WithTimestampsTest.java:78)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsBackwardsInTimeAndWithAllowedTimestampSkewShouldSucceed(WithTimestampsTest.java:142)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.WithTimestampsTest > withTimestampsLambdaShouldApplyTimestamps FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.WithTimestampsTest.withTimestampsLambdaShouldApplyTimestamps(WithTimestampsTest.java:205)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesWhenValueTimestampedLaterSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesWhenValueTimestampedLaterSucceeds(ReifyTimestampsTest.java:129)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > extractFromValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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.extractFromValuesSucceeds(ReifyTimestampsTest.java:93)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
org.apache.beam.sdk.transforms.ReifyTimestampsTest > inValuesSucceeds FAILED
java.lang.IllegalArgumentException: java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:78)
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)
Caused by:
java.lang.NoSuchMethodException: org.apache.beam.runners.flink.FlinkJobServerDriver.start()
at java.lang.Class.getMethod(Class.java:1786)
at org.apache.beam.runners.reference.testing.TestPortableRunner.run(TestPortableRunner.java:76)
... 4 more
170 tests completed, 160 failed, 1 skipped
Finished generating test XML results (0.073 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 (0.062 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 23.321 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 3m 23s
61 actionable tasks: 57 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/4yuiwtpkoe2w6
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #3
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/3/display/redirect>
------------------------------------------
[...truncated 92.13 KB...]
:beam-sdks-java-extensions-google-cloud-platform-core:compileJava (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 11.387 secs.
> Task :beam-vendor-sdks-java-extensions-protobuf:compileJava
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/vendor/sdks-java-extensions-protobuf/src/main/java',> not found
Build cache key for task ':beam-vendor-sdks-java-extensions-protobuf:compileJava' is cbfa31f77c551f7ac252dedb2f315ec6
Task ':beam-vendor-sdks-java-extensions-protobuf:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-vendor-sdks-java-extensions-protobuf:compileJava'.
All input files are considered out-of-date for incremental task ':beam-vendor-sdks-java-extensions-protobuf:compileJava'.
Full recompilation is required because no incremental change information is available. This is usually caused by clean builds or changing compiler arguments.
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/vendor/sdks-java-extensions-protobuf/src/main/java',> not found
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
> Task :beam-sdks-java-core:compileTestJava FAILED
Build cache key for task ':beam-sdks-java-core:compileTestJava' is 3ff4b8b3d4b51871c23ed1895d156f28
Task ':beam-sdks-java-core:compileTestJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-core:compileTestJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-core:compileTestJava'.
Full recompilation is required because no incremental change information is available. This is usually caused by clean builds or changing compiler arguments.
Compiling with error-prone compiler
Found locally available resource with matching checksum: [https://repo.maven.apache.org/maven2/com/google/protobuf/protobuf-java/3.4.0/protobuf-java-3.4.0.pom, /home/jenkins/.m2/repository/com/google/protobuf/protobuf-java/3.4.0/protobuf-java-3.4.0.pom]
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/sdks/java/core/src/test/java/org/apache/beam/sdk/coders/AvroCoderTest.java>:105: warning: [EqualsGetClass] Overriding Object#equals in a non-final class by using getClass rather than instanceof breaks substitutability of subclasses.
public boolean equals(Object o) {
^
(see https://errorprone.info/bugpattern/EqualsGetClass)
Did you mean 'if (!(o instanceof Pojo)) {'?
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/sdks/java/core/src/test/java/org/apache/beam/sdk/coders/AvroCoderTest.java>:288: warning: [UnnecessaryParentheses] Unnecessary use of grouping parentheses
Schema schema = (new Schema.Parser()).parse(schemaString);
^
(see https://errorprone.info/bugpattern/UnnecessaryParentheses)
Did you mean 'Schema schema = new Schema.Parser().parse(schemaString);'?
error: warnings found and -Werror specified
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/sdks/java/core/src/test/java/org/apache/beam/sdk/coders/AvroCoderTest.java> uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 error
2 warnings
:beam-sdks-java-core:compileTestJava (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 11.484 secs.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':' Thread 5,5,main]) started.
> Task :beam-sdks-java-core:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/sdks/java/core/src/test/resources',> not found
Skipping task ':beam-sdks-java-core:processTestResources' as it has no source files and no previous output files.
:beam-sdks-java-core:processTestResources (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 0.004 secs.
> Task :beam-sdks-java-extensions-protobuf:compileJava
Build cache key for task ':beam-sdks-java-extensions-protobuf:compileJava' is 8a38bb7e18cec5270b0f8a6f65a08e00
Task ':beam-sdks-java-extensions-protobuf:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-extensions-protobuf:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-extensions-protobuf:compileJava'.
Full recompilation is required because no incremental change information is available. This is usually caused by clean builds or changing compiler arguments.
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/sdks/java/extensions/protobuf/build/generated/source/proto/main/java',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/sdks/java/extensions/protobuf/build/generated/source/proto/main/grpc',> not found
Compiling with error-prone compiler
Cached resource https://repo.spring.io/plugins-release/com/google/errorprone/error_prone_core/maven-metadata.xml is up-to-date (lastModified: Sun Apr 22 09:15:42 UTC 2018).
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Created classpath snapshot for incremental compilation in 3.554 secs. 39 duplicate classes found in classpath (see all with --debug).
Packing task ':beam-sdks-java-extensions-protobuf:compileJava'
> Task :beam-vendor-sdks-java-extensions-protobuf:compileJava
Created classpath snapshot for incremental compilation in 3.477 secs. 39 duplicate classes found in classpath (see all with --debug).
Packing task ':beam-vendor-sdks-java-extensions-protobuf:compileJava'
:beam-vendor-sdks-java-extensions-protobuf:compileJava (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 12.603 secs.
:beam-sdks-java-extensions-protobuf:compileJava (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 12.275 secs.
:beam-vendor-sdks-java-extensions-protobuf:classes (Thread[Task worker for ':' Thread 3,5,main]) started.
:beam-sdks-java-extensions-protobuf:classes (Thread[Task worker for ':' Thread 9,5,main]) started.
> Task :beam-vendor-sdks-java-extensions-protobuf:classes
Skipping task ':beam-vendor-sdks-java-extensions-protobuf:classes' as it has no actions.
:beam-vendor-sdks-java-extensions-protobuf:classes (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 0.0 secs.
> Task :beam-sdks-java-extensions-protobuf:classes
Skipping task ':beam-sdks-java-extensions-protobuf:classes' as it has no actions.
:beam-sdks-java-extensions-protobuf:classes (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 0.0 secs.
:beam-vendor-sdks-java-extensions-protobuf:shadowJar (Thread[Task worker for ':' Thread 3,5,main]) started.
:beam-sdks-java-extensions-protobuf:shadowJar (Thread[Task worker for ':' Thread 9,5,main]) started.
> Task :beam-model-fn-execution:shadowJar
Build cache key for task ':beam-model-fn-execution:shadowJar' is 4fa98f4c78f92d0e1f71dd537d4a01e8
Caching disabled for task ':beam-model-fn-execution:shadowJar': Caching has not been enabled for the task
Task ':beam-model-fn-execution:shadowJar' is not up-to-date because:
No history is available.
> Task :beam-vendor-sdks-java-extensions-protobuf:shadowJar
Build cache key for task ':beam-vendor-sdks-java-extensions-protobuf:shadowJar' is a7ffcf9880eb99e69b1e3a505f29553d
Caching disabled for task ':beam-vendor-sdks-java-extensions-protobuf:shadowJar': Caching has not been enabled for the task
Task ':beam-vendor-sdks-java-extensions-protobuf:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 1.722s [1722ms]
Average Time/Jar: 0.861s [861.0ms]
*******************
:beam-vendor-sdks-java-extensions-protobuf:shadowJar (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 1.778 secs.
> Task :beam-model-job-management:shadowJar
Build cache key for task ':beam-model-job-management:shadowJar' is d020837b58c95aec40c4c938a2e98b32
Caching disabled for task ':beam-model-job-management:shadowJar': Caching has not been enabled for the task
Task ':beam-model-job-management:shadowJar' is not up-to-date because:
No history is available.
> Task :beam-sdks-java-extensions-protobuf:shadowJar
Build cache key for task ':beam-sdks-java-extensions-protobuf:shadowJar' is a7ffcf9880eb99e69b1e3a505f29553d
Caching disabled for task ':beam-sdks-java-extensions-protobuf:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-extensions-protobuf:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 2.055s [2055ms]
Average Time/Jar: 1.0275s [1027.5ms]
*******************
:beam-sdks-java-extensions-protobuf:shadowJar (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 2.122 secs.
> Task :beam-model-job-management:shadowJar
*******************
GRADLE SHADOW STATS
Total Jars: 37 (includes project)
Total Time: 20.831s [20831ms]
Average Time/Jar: 0.563s [563.0ms]
*******************
:beam-model-job-management:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 22.801 secs.
:beam-runners-core-construction-java:compileJava (Thread[Task worker for ':' Thread 7,5,main]) started.
> Task :beam-model-fn-execution:shadowJar
*******************
GRADLE SHADOW STATS
Total Jars: 37 (includes project)
Total Time: 20.787s [20787ms]
Average Time/Jar: 0.5618108108108001s [561.8108108108ms]
*******************
:beam-model-fn-execution:shadowJar (Thread[Task worker for ':',5,main]) completed. Took 23.313 secs.
:beam-sdks-java-fn-execution:compileJava (Thread[Task worker for ':',5,main]) started.
> Task :beam-runners-core-construction-java:compileJava
Build cache key for task ':beam-runners-core-construction-java:compileJava' is d29ef25f5f6a2ca7d01cb0f8a2931cc9
Task ':beam-runners-core-construction-java:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-runners-core-construction-java:compileJava'.
All input files are considered out-of-date for incremental task ':beam-runners-core-construction-java:compileJava'.
Full recompilation is required because no incremental change information is available. This is usually caused by clean builds or changing compiler arguments.
Compiling with error-prone compiler
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java>:573: warning: [BadImport] Importing nested classes/static methods/static fields with commonly-used names can make code harder to read, because it may not be clear from the context exactly which type is being referred to. Qualifying the name with that of the containing class can make the code clearer.
Builder builder = SideInput.newBuilder();
^
(see https://errorprone.info/bugpattern/BadImport)
Did you mean 'SideInput.Builder builder = SideInput.newBuilder();'?
error: warnings found and -Werror specified
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 error
1 warning
> Task :beam-runners-core-construction-java:compileJava FAILED
:beam-runners-core-construction-java:compileJava (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 8.053 secs.
> Task :beam-sdks-java-fn-execution:compileJava
Build cache key for task ':beam-sdks-java-fn-execution:compileJava' is 1d357561f6f4f1f3db5e08cd7920347c
Task ':beam-sdks-java-fn-execution:compileJava' is not up-to-date because:
No history is available.
Custom actions are attached to task ':beam-sdks-java-fn-execution:compileJava'.
All input files are considered out-of-date for incremental task ':beam-sdks-java-fn-execution:compileJava'.
Full recompilation is required because no incremental change information is available. This is usually caused by clean builds or changing compiler arguments.
Compiling with error-prone compiler
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Created classpath snapshot for incremental compilation in 1.768 secs. 6714 duplicate classes found in classpath (see all with --debug).
Packing task ':beam-sdks-java-fn-execution:compileJava'
:beam-sdks-java-fn-execution:compileJava (Thread[Task worker for ':',5,main]) completed. Took 9.039 secs.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':',5,main]) started.
> Task :beam-sdks-java-fn-execution:classes
Skipping task ':beam-sdks-java-fn-execution:classes' as it has no actions.
:beam-sdks-java-fn-execution:classes (Thread[Task worker for ':',5,main]) completed. Took 0.0 secs.
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':',5,main]) started.
> Task :beam-sdks-java-fn-execution:shadowJar
Build cache key for task ':beam-sdks-java-fn-execution:shadowJar' is a8fa6da0c025fb2b252ef06fc85b4fef
Caching disabled for task ':beam-sdks-java-fn-execution:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-fn-execution:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 2 (includes project)
Total Time: 1.937s [1937ms]
Average Time/Jar: 0.9685s [968.5ms]
*******************
:beam-sdks-java-fn-execution:shadowJar (Thread[Task worker for ':',5,main]) completed. Took 2.012 secs.
FAILURE: Build completed with 3 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':beam-sdks-java-extensions-google-cloud-platform-core:compileJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':beam-sdks-java-core:compileTestJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* 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.
==============================================================================
3: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':beam-runners-core-construction-java:compileJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* 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 57s
36 actionable tasks: 32 executed, 4 from cache
Publishing build scan...
https://gradle.com/s/2os2prgncf7lk
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure