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/20 00:16:10 UTC
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #439
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/439/display/redirect>
------------------------------------------
[...truncated 38.45 MB...]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (7dedb318689f202124a147f2f263695c) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (7dedb318689f202124a147f2f263695c).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (7dedb318689f202124a147f2f263695c) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 7dedb318689f202124a147f2f263695c.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (7dedb318689f202124a147f2f263695c) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (ae724df08ddac1e66575d59b06a8bfe9) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (ae724df08ddac1e66575d59b06a8bfe9).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (ae724df08ddac1e66575d59b06a8bfe9) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 ae724df08ddac1e66575d59b06a8bfe9.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (ae724df08ddac1e66575d59b06a8bfe9) switched from RUNNING to FINISHED.
[grpc-default-executor-7] INFO sdk_worker.run - No more requests from control plane
[grpc-default-executor-7] INFO sdk_worker.run - SDK Harness waiting for in-flight requests to complete
[grpc-default-executor-7] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-6] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-3] WARN org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client failed unexpectedly.
org.apache.beam.vendor.grpc.v1.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close
at org.apache.beam.vendor.grpc.v1.io.grpc.Status.asRuntimeException(Status.java:517)
at org.apache.beam.vendor.grpc.v1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
at org.apache.beam.vendor.grpc.v1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at org.apache.beam.vendor.grpc.v1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at org.apache.beam.vendor.grpc.v1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at org.apache.beam.vendor.grpc.v1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
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)
[grpc-default-executor-3] WARN org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client failed to be complete.
org.apache.beam.vendor.grpc.v1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled
at org.apache.beam.vendor.grpc.v1.io.grpc.Status.asRuntimeException(Status.java:517)
at org.apache.beam.vendor.grpc.v1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.completeIfNotNull(GrpcLoggingService.java:79)
at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.access$400(GrpcLoggingService.java:34)
at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService$InboundObserver.onError(GrpcLoggingService.java:106)
at org.apache.beam.vendor.grpc.v1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
at org.apache.beam.vendor.grpc.v1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at org.apache.beam.vendor.grpc.v1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at org.apache.beam.vendor.grpc.v1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at org.apache.beam.vendor.grpc.v1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
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)
Oct 20, 2018 12:16:08 AM org.apache.beam.vendor.grpc.v1.io.grpc.internal.SerializingExecutor run
SEVERE: Exception while executing runnable org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@ac4fcbe
org.apache.beam.vendor.grpc.v1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled
at org.apache.beam.vendor.grpc.v1.io.grpc.Status.asRuntimeException(Status.java:517)
at org.apache.beam.vendor.grpc.v1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
at org.apache.beam.runners.fnexecution.state.GrpcStateService$Inbound.onError(GrpcStateService.java:145)
at org.apache.beam.vendor.grpc.v1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
at org.apache.beam.vendor.grpc.v1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at org.apache.beam.vendor.grpc.v1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at org.apache.beam.vendor.grpc.v1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at org.apache.beam.vendor.grpc.v1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
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)
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (2eca907374eb7bbc5a4056dddcd48384) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (2eca907374eb7bbc5a4056dddcd48384).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (2eca907374eb7bbc5a4056dddcd48384) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 2eca907374eb7bbc5a4056dddcd48384.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (2eca907374eb7bbc5a4056dddcd48384) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1539994554.51 (cf2c637b8425069ea7613b6783af2f7d) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job cf2c637b8425069ea7613b6783af2f7d.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job cf2c637b8425069ea7613b6783af2f7d reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job test_windowing_1539994554.51(cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection c8c1ab4adfff101c90dd8098aad14229: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 81639e14be22eeb3784e30a09a694926@akka://flink/user/jobmanager_39 for job cf2c637b8425069ea7613b6783af2f7d from the resource manager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job cf2c637b8425069ea7613b6783af2f7d.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job cf2c637b8425069ea7613b6783af2f7d with leader id 81639e14be22eeb3784e30a09a694926 lost leadership.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b50580ef191e72fa1c98a5f3a904c2e9}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[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.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{326de743769d72ca144e58da5a640ebe}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{9a8a048654718b3298feaa8238c7fed1}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{7773b3fbfef36f8a7289fbeb92a38a1f}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{f16d667ae442159e343f935c3e35ba71}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ef38a4f9350ff9f624ae27eaca142279}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ad5f76cb383f2afceaa92e94f4644bdb}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{5b8eab339f6483a8fe3ae03bfd6eba90}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatchera5407b12-5e45-491b-bade-aa819fbb59a9.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatchera5407b12-5e45-491b-bade-aa819fbb59a9.
[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 b8f50c553ea13f32006689fd30f5735c from the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{26d55610cab6d3ef8775578ae82342b9}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{00ec09c237d90769a4a8a9019cc46c20}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a69a99abbefe4250dc0af832a7865cf2}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a4faeb1180caef2e4038f3f5ef3dbac9}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{8999a69ef456413396f177f6e43f4cd5}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{68a8bf5c28e3f12e201492b10aa536e7}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{9c9e0afdba8cc6195852e2046965509f}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{62f4b2a765e746bfa47977c5f06efc8d}, jobId: cf2c637b8425069ea7613b6783af2f7d).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job cf2c637b8425069ea7613b6783af2f7d from job leader monitoring.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job cf2c637b8425069ea7613b6783af2f7d.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job cf2c637b8425069ea7613b6783af2f7d.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-950c1403-d57f-44b7-ac51-7ec056db1e51
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatchera5407b12-5e45-491b-bade-aa819fbb59a9.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:35063
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 12950 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@78c54ce1
.
==================== Timed out after 30 seconds. ====================
======================================================================
# Thread: <Thread(Thread-63, started daemon 140697827014400)>
# Thread: <Thread(wait_until_finish_read, started daemon 140698313529088)>
# Thread: <Thread(Thread-24, started daemon 140698900756224)>
# Thread: <Thread(Thread-39, started daemon 140698850400000)>
ERROR: test_pardo_side_and_main_outputs (__main__.FlinkRunnerTest)
# Thread: <Thread(Thread-4, started daemon 140699930498816)>
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 149, in test_pardo_side_and_main_outputs
assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd')
File "apache_beam/pipeline.py", line 423, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 242, in wait_until_finish
beam_job_api_pb2.GetJobStateRequest(job_id=self._job_id)):
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/grpc/_channel.py",> line 366, in next
# Thread: <Thread(wait_until_finish_read, started daemon 140698858792704)>
# Thread: <Thread(wait_until_finish_read, started daemon 140699387270912)>
# Thread: <Thread(Thread-19, started daemon 140699395663616)>
# Thread: <Thread(wait_until_finish_read, started daemon 140698330314496)>
# Thread: <Thread(wait_until_finish_read, started daemon 140698875578112)>
return self._next()
# Thread: <Thread(wait_until_finish_read, started daemon 140698347099904)>
# Thread: <Thread(wait_until_finish_read, started daemon 140698892363520)>
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/grpc/_channel.py",> line 348, in _next
self._state.condition.wait()
File "/usr/lib/python2.7/threading.py", line 340, in wait
waiter.acquire()
# Thread: <Thread(wait_until_finish_read, started daemon 140699404056320)>
File "apache_beam/runners/portability/portable_runner_test.py", line 69, in handler
raise BaseException(msg)
# Thread: <Thread(Thread-34, started daemon 140698867185408)>
BaseException: Timed out after 30 seconds.
----------------------------------------------------------------------
Ran 26 tests in 267.140s
FAILED (errors=1, skipped=8)
# Thread: <Thread(wait_until_finish_read, started daemon 140699437627136)>
# Thread: <Thread(Thread-54, started daemon 140698321921792)>
# Thread: <_MainThread(MainThread, started 140700081985280)>
# Thread: <Thread(Thread-14, started daemon 140699412449024)>
# Thread: <Thread(Thread-49, started daemon 140698338707200)>
# Thread: <Thread(wait_until_finish_read, started daemon 140698363885312)>
# Thread: <Thread(Thread-29, started daemon 140698883970816)>
# Thread: <Thread(wait_until_finish_read, started daemon 140699938891520)>
# Thread: <Thread(Thread-9, started daemon 140699429234432)>
# Thread: <Thread(Thread-44, started daemon 140698355492608)>
# Thread: <Thread(wait_until_finish_read, started daemon 140699420841728)>
> Task :beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 4 mins 29.621 secs.
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 367
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER'.
> Process 'command 'sh'' finished with non-zero exit value 139
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 367
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 15m 59s
61 actionable tasks: 56 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/sciq7kontsz5e
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_Python_VR_Flink
#443
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/443/display/redirect>
Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #442
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/442/display/redirect?page=changes>
Changes:
[thw] [BEAM-5467] Set parallelism in Flink test runner to avoid running out of
------------------------------------------
[...truncated 434.41 KB...]
> Task :beam-runners-flink_2.11-job-server:classes UP-TO-DATE
Skipping task ':beam-runners-flink_2.11-job-server:classes' as it has no actions.
:beam-runners-flink_2.11-job-server:classes (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 0.0 secs.
:beam-runners-flink_2.11-job-server:shadowJar (Thread[Task worker for ':' Thread 11,5,main]) started.
> Task :beam-runners-flink_2.11-job-server:shadowJar
Build cache key for task ':beam-runners-flink_2.11-job-server:shadowJar' is 2f85dce82a031df761bccecce505f6fe
Caching disabled for task ':beam-runners-flink_2.11-job-server:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-flink_2.11-job-server:shadowJar' is not up-to-date because:
No history is available.
> Task :beam-sdks-python:createProcessWorker
creating <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/fastavro-0.21.9-py2.7-linux-x86_64.egg>
Extracting fastavro-0.21.9-py2.7-linux-x86_64.egg to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding fastavro 0.21.9 to easy-install.pth file
Installing fastavro script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/fastavro-0.21.9-py2.7-linux-x86_64.egg>
Searching for dill<=0.2.8.2,>=0.2.6
Reading https://pypi.org/simple/dill/
Downloading https://files.pythonhosted.org/packages/6f/78/8b96476f4ae426db71c6e86a8e6a81407f015b34547e442291cd397b18f3/dill-0.2.8.2.tar.gz#sha256=624dc244b94371bb2d6e7f40084228a2edfff02373fe20e018bef1ee92fdd5b3
Best match: dill 0.2.8.2
Processing dill-0.2.8.2.tar.gz
Writing /tmp/easy_install-ppIMo1/dill-0.2.8.2/setup.cfg
Running dill-0.2.8.2/setup.py -q bdist_egg --dist-dir /tmp/easy_install-ppIMo1/dill-0.2.8.2/egg-dist-tmp-SRQr6x
creating <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/dill-0.2.8.2-py2.7.egg>
Extracting dill-0.2.8.2-py2.7.egg to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding dill 0.2.8.2 to easy-install.pth file
Installing get_objgraph script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing undill script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/dill-0.2.8.2-py2.7.egg>
Searching for crcmod<2.0,>=1.7
Reading https://pypi.org/simple/crcmod/
Downloading https://files.pythonhosted.org/packages/6b/b0/e595ce2a2527e169c3bcd6c33d2473c1918e0b7f6826a043ca1245dd4e5b/crcmod-1.7.tar.gz#sha256=dc7051a0db5f2bd48665a990d3ec1cc305a466a77358ca4492826f41f283601e
Best match: crcmod 1.7
Processing crcmod-1.7.tar.gz
Writing /tmp/easy_install-w0zelP/crcmod-1.7/setup.cfg
Running crcmod-1.7/setup.py -q bdist_egg --dist-dir /tmp/easy_install-w0zelP/crcmod-1.7/egg-dist-tmp-3wPKCN
python2/src/_crcfunext.c: In function ‘init_crcfunext’:
python2/src/_crcfunext.c:492:13: warning: variable ‘m’ set but not used [-Wunused-but-set-variable]
PyObject *m;
^
zip_safe flag not set; analyzing archive contents...
Moving crcmod-1.7-py2.7-linux-x86_64.egg to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding crcmod 1.7 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/crcmod-1.7-py2.7-linux-x86_64.egg>
Searching for pyparsing>=2.1.4
Reading https://pypi.org/simple/pyparsing/
Downloading https://files.pythonhosted.org/packages/2b/4a/f06b45ab9690d4c37641ec776f7ad691974f4cf6943a73267475b05cbfca/pyparsing-2.2.2-py2.py3-none-any.whl#sha256=d29593d8ebe7b57d6967b62494f8c72b03ac0262b1eed63826c6f788b3606401
Best match: pyparsing 2.2.2
Processing pyparsing-2.2.2-py2.py3-none-any.whl
Installing pyparsing-2.2.2-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding pyparsing 2.2.2 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pyparsing-2.2.2-py2.7.egg>
Searching for rsa>=3.1.4
Reading https://pypi.org/simple/rsa/
Downloading https://files.pythonhosted.org/packages/02/e5/38518af393f7c214357079ce67a317307936896e961e35450b70fad2a9cf/rsa-4.0-py2.py3-none-any.whl#sha256=14ba45700ff1ec9eeb206a2ce76b32814958a98e372006c8fb76ba820211be66
Best match: rsa 4.0
Processing rsa-4.0-py2.py3-none-any.whl
Installing rsa-4.0-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
writing requirements to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/rsa-4.0-py2.7.egg/EGG-INFO/requires.txt>
Adding rsa 4.0 to easy-install.pth file
Installing pyrsa-encrypt script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-verify script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-sign script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-priv2pub script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-decrypt script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-keygen script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/rsa-4.0-py2.7.egg>
Searching for pyasn1>=0.1.7
Reading https://pypi.org/simple/pyasn1/
Downloading https://files.pythonhosted.org/packages/d1/a1/7790cc85db38daa874f6a2e6308131b9953feb1367f2ae2d1123bb93a9f5/pyasn1-0.4.4-py2.py3-none-any.whl#sha256=b9d3abc5031e61927c82d4d96c1cec1e55676c1a991623cfed28faea73cdd7ca
Best match: pyasn1 0.4.4
Processing pyasn1-0.4.4-py2.py3-none-any.whl
Installing pyasn1-0.4.4-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding pyasn1 0.4.4 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pyasn1-0.4.4-py2.7.egg>
Searching for pyasn1-modules>=0.0.5
Reading https://pypi.org/simple/pyasn1-modules/
Downloading https://files.pythonhosted.org/packages/19/02/fa63f7ba30a0d7b925ca29d034510fc1ffde53264b71b4155022ddf3ab5d/pyasn1_modules-0.2.2-py2.py3-none-any.whl#sha256=a38a8811ea784c0136abfdba73963876328f66172db21a05a82f9515909bfb4e
Best match: pyasn1-modules 0.2.2
Processing pyasn1_modules-0.2.2-py2.py3-none-any.whl
Installing pyasn1_modules-0.2.2-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
writing requirements to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pyasn1_modules-0.2.2-py2.7.egg/EGG-INFO/requires.txt>
Adding pyasn1-modules 0.2.2 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pyasn1_modules-0.2.2-py2.7.egg>
Searching for pbr>=0.11
Reading https://pypi.org/simple/pbr/
Downloading https://files.pythonhosted.org/packages/ca/81/4e8230c5648ea6d85d90ec3babc3dcc1c46d890f2f26b3e2b374819274dd/pbr-5.0.0-py2.py3-none-any.whl#sha256=bfcff1a3878eebf559392c2130a17f612a03f96a0d44c3559d9c1e62a4235a2d
Best match: pbr 5.0.0
Processing pbr-5.0.0-py2.py3-none-any.whl
Installing pbr-5.0.0-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding pbr 5.0.0 to easy-install.pth file
Installing pbr script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pbr-5.0.0-py2.7.egg>
Searching for funcsigs>=1
Reading https://pypi.org/simple/funcsigs/
Downloading https://files.pythonhosted.org/packages/69/cb/f5be453359271714c01b9bd06126eaf2e368f1fddfff30818754b5ac2328/funcsigs-1.0.2-py2.py3-none-any.whl#sha256=330cc27ccbf7f1e992e69fef78261dc7c6569012cf397db8d3de0234e6c937ca
Best match: funcsigs 1.0.2
Processing funcsigs-1.0.2-py2.py3-none-any.whl
Installing funcsigs-1.0.2-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding funcsigs 1.0.2 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/funcsigs-1.0.2-py2.7.egg>
Searching for requests>=2.7.0
Reading https://pypi.org/simple/requests/
Downloading https://files.pythonhosted.org/packages/f1/ca/10332a30cb25b627192b4ea272c351bce3ca1091e541245cccbace6051d8/requests-2.20.0-py2.py3-none-any.whl#sha256=a84b8c9ab6239b578f22d1c21d51b696dcfe004032bb80ea832398d6909d7279
Best match: requests 2.20.0
Processing requests-2.20.0-py2.py3-none-any.whl
Installing requests-2.20.0-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
writing requirements to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/requests-2.20.0-py2.7.egg/EGG-INFO/requires.txt>
Adding requests 2.20.0 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/requests-2.20.0-py2.7.egg>
Searching for docopt
Reading https://pypi.org/simple/docopt/
Downloading https://files.pythonhosted.org/packages/a2/55/8f8cab2afd404cf578136ef2cc5dfb50baa1761b68c9da1fb1e4eed343c9/docopt-0.6.2.tar.gz#sha256=49b3a825280bd66b3aa83585ef59c4a8c82f2c8a522dbe754a8bc8d08c85c491
Best match: docopt 0.6.2
Processing docopt-0.6.2.tar.gz
Writing /tmp/easy_install-uFKtOa/docopt-0.6.2/setup.cfg
Running docopt-0.6.2/setup.py -q bdist_egg --dist-dir /tmp/easy_install-uFKtOa/docopt-0.6.2/egg-dist-tmp-A7l9jq
zip_safe flag not set; analyzing archive contents...
Moving docopt-0.6.2-py2.7.egg to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding docopt 0.6.2 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/docopt-0.6.2-py2.7.egg>
Searching for urllib3<1.25,>=1.21.1
Reading https://pypi.org/simple/urllib3/
Downloading https://files.pythonhosted.org/packages/8c/4b/5cbc4cb46095f369117dcb751821e1bef9dd86a07c968d8757e9204c324c/urllib3-1.24-py2.py3-none-any.whl#sha256=8819bba37a02d143296a4d032373c4dd4aca11f6d4c9973335ca75f9c8475f59
Best match: urllib3 1.24
Processing urllib3-1.24-py2.py3-none-any.whl
Installing urllib3-1.24-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
writing requirements to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/urllib3-1.24-py2.7.egg/EGG-INFO/requires.txt>
Adding urllib3 1.24 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/urllib3-1.24-py2.7.egg>
Searching for idna<2.8,>=2.5
Reading https://pypi.org/simple/idna/
Downloading https://files.pythonhosted.org/packages/4b/2a/0276479a4b3caeb8a8c1af2f8e4355746a97fab05a372e4a2c6a6b876165/idna-2.7-py2.py3-none-any.whl#sha256=156a6814fb5ac1fc6850fb002e0852d56c0c8d2531923a51032d1b70760e186e
Best match: idna 2.7
Processing idna-2.7-py2.py3-none-any.whl
Installing idna-2.7-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding idna 2.7 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/idna-2.7-py2.7.egg>
Searching for chardet<3.1.0,>=3.0.2
Reading https://pypi.org/simple/chardet/
Downloading https://files.pythonhosted.org/packages/bc/a9/01ffebfb562e4274b6487b4bb1ddec7ca55ec7510b22e4c51f14098443b8/chardet-3.0.4-py2.py3-none-any.whl#sha256=fc323ffcaeaed0e0a02bf4d117757b98aed530d9ed4531e3e15460124c106691
Best match: chardet 3.0.4
Processing chardet-3.0.4-py2.py3-none-any.whl
Installing chardet-3.0.4-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding chardet 3.0.4 to easy-install.pth file
Installing chardetect script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/chardet-3.0.4-py2.7.egg>
Searching for certifi>=2017.4.17
Reading https://pypi.org/simple/certifi/
Downloading https://files.pythonhosted.org/packages/56/9d/1d02dd80bc4cd955f98980f28c5ee2200e1209292d5f9e9cc8d030d18655/certifi-2018.10.15-py2.py3-none-any.whl#sha256=339dc09518b07e2fa7eda5450740925974815557727d6bd35d319c1524a04a4c
Best match: certifi 2018.10.15
Processing certifi-2018.10.15-py2.py3-none-any.whl
Installing certifi-2018.10.15-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding certifi 2018.10.15 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/certifi-2018.10.15-py2.7.egg>
Searching for future==0.16.0
Best match: future 0.16.0
Adding future 0.16.0 to easy-install.pth file
Installing pasteurize script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing futurize script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for futures==3.2.0
Best match: futures 3.2.0
Adding futures 3.2.0 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for protobuf==3.6.1
Best match: protobuf 3.6.1
Adding protobuf 3.6.1 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for grpcio==1.15.0
Best match: grpcio 1.15.0
Adding grpcio 1.15.0 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for setuptools==40.4.3
Best match: setuptools 40.4.3
Adding setuptools 40.4.3 to easy-install.pth file
Installing easy_install script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing easy_install-3.6 script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for six==1.11.0
Best match: six 1.11.0
Adding six 1.11.0 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for enum34==1.1.6
Best match: enum34 1.1.6
Adding enum34 1.1.6 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Finished processing dependencies for apache-beam==2.9.0.dev0
Starting process 'command 'chmod''. Working directory: <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python> Command: chmod +x <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/sdk_worker.sh>
Successfully started process 'command 'chmod''
:beam-sdks-python:createProcessWorker (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 33.053 secs.
> Task :beam-runners-flink_2.11-job-server:shadowJar
*******************
GRADLE SHADOW STATS
Total Jars: 86 (includes project)
Total Time: 15.947s [15947ms]
Average Time/Jar: 0.18543023255809998s [185.4302325581ms]
*******************
:beam-runners-flink_2.11-job-server:shadowJar (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 17.138 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-python-container:docker'.
> Process 'command 'docker'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2m 38s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/ir4ihr44ewogg
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_Python_VR_Flink #441
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/441/display/redirect>
------------------------------------------
[...truncated 38.38 MB...]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (faf8a0ee48a18faf6a9431b894b7e9f8) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 faf8a0ee48a18faf6a9431b894b7e9f8.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/16) (faf8a0ee48a18faf6a9431b894b7e9f8) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (dd053af332a504ced37da02202ced693) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (dd053af332a504ced37da02202ced693).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (dd053af332a504ced37da02202ced693) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 dd053af332a504ced37da02202ced693.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (11/16) (dd053af332a504ced37da02202ced693) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (85c46646e040dac55c0f1601f4a9822b) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (85c46646e040dac55c0f1601f4a9822b).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (85c46646e040dac55c0f1601f4a9822b) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 85c46646e040dac55c0f1601f4a9822b.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (13/16) (85c46646e040dac55c0f1601f4a9822b) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (10c51db25535ae3cf9a90f44933b4c86) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (10c51db25535ae3cf9a90f44933b4c86).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (10c51db25535ae3cf9a90f44933b4c86) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 10c51db25535ae3cf9a90f44933b4c86.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (14/16) (10c51db25535ae3cf9a90f44933b4c86) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (d0193749078dd9238b5932a152e7246d) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (d0193749078dd9238b5932a152e7246d).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (d0193749078dd9238b5932a152e7246d) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 d0193749078dd9238b5932a152e7246d.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (15/16) (d0193749078dd9238b5932a152e7246d) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (d34e93d10f9dd4b6ab1b9fdc6e8a5df8) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (d34e93d10f9dd4b6ab1b9fdc6e8a5df8).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (d34e93d10f9dd4b6ab1b9fdc6e8a5df8) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 d34e93d10f9dd4b6ab1b9fdc6e8a5df8.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (4/16) (d34e93d10f9dd4b6ab1b9fdc6e8a5df8) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (afc57de81655a1fb579edb7209ac8d42) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (afc57de81655a1fb579edb7209ac8d42).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (afc57de81655a1fb579edb7209ac8d42) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 afc57de81655a1fb579edb7209ac8d42.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (16/16) (afc57de81655a1fb579edb7209ac8d42) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (6695dacece904738f1b4cf0cda99eaaa) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (6695dacece904738f1b4cf0cda99eaaa).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (6695dacece904738f1b4cf0cda99eaaa) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 6695dacece904738f1b4cf0cda99eaaa.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (3/16) (6695dacece904738f1b4cf0cda99eaaa) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (978713f7b4b22b8781ce4ba823b169b2) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (978713f7b4b22b8781ce4ba823b169b2).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (978713f7b4b22b8781ce4ba823b169b2) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 978713f7b4b22b8781ce4ba823b169b2.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (8/16) (978713f7b4b22b8781ce4ba823b169b2) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (19ae6facb0aee410b8019b23ec3126c9) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (19ae6facb0aee410b8019b23ec3126c9).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (19ae6facb0aee410b8019b23ec3126c9) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 19ae6facb0aee410b8019b23ec3126c9.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (10/16) (19ae6facb0aee410b8019b23ec3126c9) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (19184601c3bb134085f97d2ae002d135) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (19184601c3bb134085f97d2ae002d135).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (19184601c3bb134085f97d2ae002d135) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 19184601c3bb134085f97d2ae002d135.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (7/16) (19184601c3bb134085f97d2ae002d135) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (70375a3b38ef5c98d2c030a68f663b45) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (70375a3b38ef5c98d2c030a68f663b45).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (70375a3b38ef5c98d2c030a68f663b45) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 70375a3b38ef5c98d2c030a68f663b45.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (5/16) (70375a3b38ef5c98d2c030a68f663b45) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (b763a1b2dcc8fc2a3c4622fdc8677ed7) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (b763a1b2dcc8fc2a3c4622fdc8677ed7).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (b763a1b2dcc8fc2a3c4622fdc8677ed7) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 b763a1b2dcc8fc2a3c4622fdc8677ed7.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (2/16) (b763a1b2dcc8fc2a3c4622fdc8677ed7) switched from RUNNING to FINISHED.
[grpc-default-executor-0] INFO sdk_worker.run - No more requests from control plane
[grpc-default-executor-0] INFO sdk_worker.run - SDK Harness waiting for in-flight requests to complete
[grpc-default-executor-0] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-0] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-0] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-5] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-5] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-5] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client hanged up.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (792e86585a63dfd902dc175ae8685062) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (792e86585a63dfd902dc175ae8685062).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (792e86585a63dfd902dc175ae8685062) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 792e86585a63dfd902dc175ae8685062.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (12/16) (792e86585a63dfd902dc175ae8685062) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1540037662.37 (96b14875714eb86730598c34e9c34a5e) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 96b14875714eb86730598c34e9c34a5e.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 96b14875714eb86730598c34e9c34a5e reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job test_windowing_1540037662.37(96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 96b14875714eb86730598c34e9c34a5e.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection a00c789a459a2fff6b335ccfb7e493d8: JobManager is shutting down..
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - 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.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcherb610051c-792e-4d10-80ad-18c847eabc46.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherb610051c-792e-4d10-80ad-18c847eabc46.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager b0d448f0596c068cd28bb27bbeb14e91@akka://flink/user/jobmanager_39 for job 96b14875714eb86730598c34e9c34a5e from the resource manager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6043f52cd3619cfa1737fbeecd716607}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 297cfaab12f6112ed6f4cd223b6a2200 from the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{5861c80c7b6522148a647c9557e29566}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{406a6a1dcdf542997c30f2415d3cd66d}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 96b14875714eb86730598c34e9c34a5e with leader id b0d448f0596c068cd28bb27bbeb14e91 lost leadership.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Could not resolve JobManager address akka://flink/user/jobmanager_39, retrying in 10000 ms: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_39..
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d639aefb4c72ed1e5ca9bd9fd437a102}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2ab0108d203e5b000202d8248560dc14}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6293d2ef4776eddb0db54d37ec279663}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c21d0a1bb299ddc1ace533eb4a6b24a4}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{8d72ec697b01b3024ec573b404a239ac}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{1cce1d741cbf0b364b0a228f07288d90}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d58cb7acd33f23cd27d55c5936d1f2cf}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{adeaf7b58634768f63b81797dd92858f}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{cf02f459d1fde89dbfcc064e2025fbb6}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{1be24b1f56184fad542f0dea2040289b}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{42a7c5afd95efa1f6f6f81e54a794be4}, jobId: 96b14875714eb86730598c34e9c34a5e).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcherb610051c-792e-4d10-80ad-18c847eabc46.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-0d33b808-51d5-4727-a314-6cb6d0db5e5d
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:38313
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 10834 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@b9da9cac
.
======================================================================
ERROR: test_pardo_side_and_main_outputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 149, in test_pardo_side_and_main_outputs
assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd')
==================== Timed out after 30 seconds. ====================
File "apache_beam/pipeline.py", line 423, in __exit__
self.run().wait_until_finish()
# Thread: <Thread(Thread-64, started daemon 139654879766272)>
File "apache_beam/runners/portability/portable_runner.py", line 242, in wait_until_finish
beam_job_api_pb2.GetJobStateRequest(job_id=self._job_id)):
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/grpc/_channel.py",> line 366, in next
return self._next()
# Thread: <Thread(wait_until_finish_read, started daemon 139654888158976)>
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/grpc/_channel.py",> line 348, in _next
self._state.condition.wait()
File "/usr/lib/python2.7/threading.py", line 340, in wait
waiter.acquire()
# Thread: <Thread(Thread-40, started daemon 139655425029888)>
File "apache_beam/runners/portability/portable_runner_test.py", line 69, in handler
raise BaseException(msg)
BaseException: Timed out after 30 seconds.
# Thread: <Thread(wait_until_finish_read, started daemon 139655911544576)>
----------------------------------------------------------------------
# Thread: <Thread(wait_until_finish_read, started daemon 139655961900800)>
Ran 26 tests in 270.103s
FAILED (errors=1, skipped=8)
# Thread: <Thread(Thread-20, started daemon 139656515524352)>
# Thread: <Thread(Thread-5, started daemon 139656913983232)>
# Thread: <Thread(wait_until_finish_read, started daemon 139655919937280)>
# Thread: <Thread(Thread-50, started daemon 139655391459072)>
# Thread: <Thread(Thread-30, started daemon 139655936722688)>
# Thread: <Thread(wait_until_finish_read, started daemon 139655945115392)>
# Thread: <Thread(wait_until_finish_read, started daemon 139655416637184)>
# Thread: <Thread(Thread-35, started daemon 139655928329984)>
# Thread: <Thread(wait_until_finish_read, started daemon 139656523917056)>
# Thread: <Thread(wait_until_finish_read, started daemon 139656922375936)>
# Thread: <Thread(Thread-15, started daemon 139656532309760)>
# Thread: <Thread(Thread-55, started daemon 139655374673664)>
# Thread: <Thread(wait_until_finish_read, started daemon 139656540702464)>
# Thread: <Thread(wait_until_finish_read, started daemon 139655399851776)>
# Thread: <Thread(Thread-45, started daemon 139655408244480)>
# Thread: <Thread(wait_until_finish_read, started daemon 139656557487872)>
# Thread: <Thread(Thread-25, started daemon 139655953508096)>
# Thread: <Thread(wait_until_finish_read, started daemon 139655383066368)>
# Thread: <_MainThread(MainThread, started 139657065469696)>
# Thread: <Thread(Thread-10, started daemon 139656549095168)>
> Task :beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 4 mins 32.411 secs.
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 367
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER'.
> Process 'command 'sh'' finished with non-zero exit value 139
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 367
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 14m 23s
61 actionable tasks: 56 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/th35ilholcsya
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_Python_VR_Flink #440
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/440/display/redirect>
------------------------------------------
[...truncated 435.69 KB...]
:beam-runners-flink_2.11-job-server:compileJava (Thread[Task worker for ':',5,main]) completed. Took 0.001 secs.
:beam-runners-flink_2.11-job-server:classes (Thread[Task worker for ':',5,main]) started.
> Task :beam-runners-flink_2.11-job-server:classes UP-TO-DATE
Skipping task ':beam-runners-flink_2.11-job-server:classes' as it has no actions.
:beam-runners-flink_2.11-job-server:classes (Thread[Task worker for ':',5,main]) completed. Took 0.0 secs.
:beam-runners-flink_2.11-job-server:shadowJar (Thread[Task worker for ':',5,main]) started.
> Task :beam-runners-flink_2.11-job-server:shadowJar
Build cache key for task ':beam-runners-flink_2.11-job-server:shadowJar' is 2fe98d02fcbb37018a7a76828c70609c
Caching disabled for task ':beam-runners-flink_2.11-job-server:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-flink_2.11-job-server:shadowJar' is not up-to-date because:
No history is available.
*******************
GRADLE SHADOW STATS
Total Jars: 86 (includes project)
Total Time: 16.25s [16250ms]
Average Time/Jar: 0.1889534883721s [188.9534883721ms]
*******************
:beam-runners-flink_2.11-job-server:shadowJar (Thread[Task worker for ':',5,main]) completed. Took 17.48 secs.
> Task :beam-sdks-python:createProcessWorker
creating <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/fastavro-0.21.9-py2.7-linux-x86_64.egg>
Extracting fastavro-0.21.9-py2.7-linux-x86_64.egg to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding fastavro 0.21.9 to easy-install.pth file
Installing fastavro script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/fastavro-0.21.9-py2.7-linux-x86_64.egg>
Searching for dill<=0.2.8.2,>=0.2.6
Reading https://pypi.org/simple/dill/
Downloading https://files.pythonhosted.org/packages/6f/78/8b96476f4ae426db71c6e86a8e6a81407f015b34547e442291cd397b18f3/dill-0.2.8.2.tar.gz#sha256=624dc244b94371bb2d6e7f40084228a2edfff02373fe20e018bef1ee92fdd5b3
Best match: dill 0.2.8.2
Processing dill-0.2.8.2.tar.gz
Writing /tmp/easy_install-iWJYau/dill-0.2.8.2/setup.cfg
Running dill-0.2.8.2/setup.py -q bdist_egg --dist-dir /tmp/easy_install-iWJYau/dill-0.2.8.2/egg-dist-tmp-Hyd6qc
creating <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/dill-0.2.8.2-py2.7.egg>
Extracting dill-0.2.8.2-py2.7.egg to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding dill 0.2.8.2 to easy-install.pth file
Installing get_objgraph script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing undill script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/dill-0.2.8.2-py2.7.egg>
Searching for crcmod<2.0,>=1.7
Reading https://pypi.org/simple/crcmod/
Downloading https://files.pythonhosted.org/packages/6b/b0/e595ce2a2527e169c3bcd6c33d2473c1918e0b7f6826a043ca1245dd4e5b/crcmod-1.7.tar.gz#sha256=dc7051a0db5f2bd48665a990d3ec1cc305a466a77358ca4492826f41f283601e
Best match: crcmod 1.7
Processing crcmod-1.7.tar.gz
Writing /tmp/easy_install-RSX58F/crcmod-1.7/setup.cfg
Running crcmod-1.7/setup.py -q bdist_egg --dist-dir /tmp/easy_install-RSX58F/crcmod-1.7/egg-dist-tmp-XNGA47
python2/src/_crcfunext.c: In function ‘init_crcfunext’:
python2/src/_crcfunext.c:492:13: warning: variable ‘m’ set but not used [-Wunused-but-set-variable]
PyObject *m;
^
zip_safe flag not set; analyzing archive contents...
Moving crcmod-1.7-py2.7-linux-x86_64.egg to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding crcmod 1.7 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/crcmod-1.7-py2.7-linux-x86_64.egg>
Searching for pyparsing>=2.1.4
Reading https://pypi.org/simple/pyparsing/
Downloading https://files.pythonhosted.org/packages/2b/4a/f06b45ab9690d4c37641ec776f7ad691974f4cf6943a73267475b05cbfca/pyparsing-2.2.2-py2.py3-none-any.whl#sha256=d29593d8ebe7b57d6967b62494f8c72b03ac0262b1eed63826c6f788b3606401
Best match: pyparsing 2.2.2
Processing pyparsing-2.2.2-py2.py3-none-any.whl
Installing pyparsing-2.2.2-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding pyparsing 2.2.2 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pyparsing-2.2.2-py2.7.egg>
Searching for rsa>=3.1.4
Reading https://pypi.org/simple/rsa/
Downloading https://files.pythonhosted.org/packages/02/e5/38518af393f7c214357079ce67a317307936896e961e35450b70fad2a9cf/rsa-4.0-py2.py3-none-any.whl#sha256=14ba45700ff1ec9eeb206a2ce76b32814958a98e372006c8fb76ba820211be66
Best match: rsa 4.0
Processing rsa-4.0-py2.py3-none-any.whl
Installing rsa-4.0-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
writing requirements to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/rsa-4.0-py2.7.egg/EGG-INFO/requires.txt>
Adding rsa 4.0 to easy-install.pth file
Installing pyrsa-encrypt script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-verify script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-sign script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-priv2pub script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-decrypt script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing pyrsa-keygen script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/rsa-4.0-py2.7.egg>
Searching for pyasn1>=0.1.7
Reading https://pypi.org/simple/pyasn1/
Downloading https://files.pythonhosted.org/packages/d1/a1/7790cc85db38daa874f6a2e6308131b9953feb1367f2ae2d1123bb93a9f5/pyasn1-0.4.4-py2.py3-none-any.whl#sha256=b9d3abc5031e61927c82d4d96c1cec1e55676c1a991623cfed28faea73cdd7ca
Best match: pyasn1 0.4.4
Processing pyasn1-0.4.4-py2.py3-none-any.whl
Installing pyasn1-0.4.4-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding pyasn1 0.4.4 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pyasn1-0.4.4-py2.7.egg>
Searching for pyasn1-modules>=0.0.5
Reading https://pypi.org/simple/pyasn1-modules/
Downloading https://files.pythonhosted.org/packages/19/02/fa63f7ba30a0d7b925ca29d034510fc1ffde53264b71b4155022ddf3ab5d/pyasn1_modules-0.2.2-py2.py3-none-any.whl#sha256=a38a8811ea784c0136abfdba73963876328f66172db21a05a82f9515909bfb4e
Best match: pyasn1-modules 0.2.2
Processing pyasn1_modules-0.2.2-py2.py3-none-any.whl
Installing pyasn1_modules-0.2.2-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
writing requirements to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pyasn1_modules-0.2.2-py2.7.egg/EGG-INFO/requires.txt>
Adding pyasn1-modules 0.2.2 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pyasn1_modules-0.2.2-py2.7.egg>
Searching for pbr>=0.11
Reading https://pypi.org/simple/pbr/
Downloading https://files.pythonhosted.org/packages/ca/81/4e8230c5648ea6d85d90ec3babc3dcc1c46d890f2f26b3e2b374819274dd/pbr-5.0.0-py2.py3-none-any.whl#sha256=bfcff1a3878eebf559392c2130a17f612a03f96a0d44c3559d9c1e62a4235a2d
Best match: pbr 5.0.0
Processing pbr-5.0.0-py2.py3-none-any.whl
Installing pbr-5.0.0-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding pbr 5.0.0 to easy-install.pth file
Installing pbr script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/pbr-5.0.0-py2.7.egg>
Searching for funcsigs>=1
Reading https://pypi.org/simple/funcsigs/
Downloading https://files.pythonhosted.org/packages/69/cb/f5be453359271714c01b9bd06126eaf2e368f1fddfff30818754b5ac2328/funcsigs-1.0.2-py2.py3-none-any.whl#sha256=330cc27ccbf7f1e992e69fef78261dc7c6569012cf397db8d3de0234e6c937ca
Best match: funcsigs 1.0.2
Processing funcsigs-1.0.2-py2.py3-none-any.whl
Installing funcsigs-1.0.2-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding funcsigs 1.0.2 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/funcsigs-1.0.2-py2.7.egg>
Searching for requests>=2.7.0
Reading https://pypi.org/simple/requests/
Downloading https://files.pythonhosted.org/packages/f1/ca/10332a30cb25b627192b4ea272c351bce3ca1091e541245cccbace6051d8/requests-2.20.0-py2.py3-none-any.whl#sha256=a84b8c9ab6239b578f22d1c21d51b696dcfe004032bb80ea832398d6909d7279
Best match: requests 2.20.0
Processing requests-2.20.0-py2.py3-none-any.whl
Installing requests-2.20.0-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
writing requirements to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/requests-2.20.0-py2.7.egg/EGG-INFO/requires.txt>
Adding requests 2.20.0 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/requests-2.20.0-py2.7.egg>
Searching for docopt
Reading https://pypi.org/simple/docopt/
Downloading https://files.pythonhosted.org/packages/a2/55/8f8cab2afd404cf578136ef2cc5dfb50baa1761b68c9da1fb1e4eed343c9/docopt-0.6.2.tar.gz#sha256=49b3a825280bd66b3aa83585ef59c4a8c82f2c8a522dbe754a8bc8d08c85c491
Best match: docopt 0.6.2
Processing docopt-0.6.2.tar.gz
Writing /tmp/easy_install-NWv27g/docopt-0.6.2/setup.cfg
Running docopt-0.6.2/setup.py -q bdist_egg --dist-dir /tmp/easy_install-NWv27g/docopt-0.6.2/egg-dist-tmp-30jlQk
zip_safe flag not set; analyzing archive contents...
Moving docopt-0.6.2-py2.7.egg to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding docopt 0.6.2 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/docopt-0.6.2-py2.7.egg>
Searching for urllib3<1.25,>=1.21.1
Reading https://pypi.org/simple/urllib3/
Downloading https://files.pythonhosted.org/packages/8c/4b/5cbc4cb46095f369117dcb751821e1bef9dd86a07c968d8757e9204c324c/urllib3-1.24-py2.py3-none-any.whl#sha256=8819bba37a02d143296a4d032373c4dd4aca11f6d4c9973335ca75f9c8475f59
Best match: urllib3 1.24
Processing urllib3-1.24-py2.py3-none-any.whl
Installing urllib3-1.24-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
writing requirements to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/urllib3-1.24-py2.7.egg/EGG-INFO/requires.txt>
Adding urllib3 1.24 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/urllib3-1.24-py2.7.egg>
Searching for idna<2.8,>=2.5
Reading https://pypi.org/simple/idna/
Downloading https://files.pythonhosted.org/packages/4b/2a/0276479a4b3caeb8a8c1af2f8e4355746a97fab05a372e4a2c6a6b876165/idna-2.7-py2.py3-none-any.whl#sha256=156a6814fb5ac1fc6850fb002e0852d56c0c8d2531923a51032d1b70760e186e
Best match: idna 2.7
Processing idna-2.7-py2.py3-none-any.whl
Installing idna-2.7-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding idna 2.7 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/idna-2.7-py2.7.egg>
Searching for chardet<3.1.0,>=3.0.2
Reading https://pypi.org/simple/chardet/
Downloading https://files.pythonhosted.org/packages/bc/a9/01ffebfb562e4274b6487b4bb1ddec7ca55ec7510b22e4c51f14098443b8/chardet-3.0.4-py2.py3-none-any.whl#sha256=fc323ffcaeaed0e0a02bf4d117757b98aed530d9ed4531e3e15460124c106691
Best match: chardet 3.0.4
Processing chardet-3.0.4-py2.py3-none-any.whl
Installing chardet-3.0.4-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding chardet 3.0.4 to easy-install.pth file
Installing chardetect script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/chardet-3.0.4-py2.7.egg>
Searching for certifi>=2017.4.17
Reading https://pypi.org/simple/certifi/
Downloading https://files.pythonhosted.org/packages/56/9d/1d02dd80bc4cd955f98980f28c5ee2200e1209292d5f9e9cc8d030d18655/certifi-2018.10.15-py2.py3-none-any.whl#sha256=339dc09518b07e2fa7eda5450740925974815557727d6bd35d319c1524a04a4c
Best match: certifi 2018.10.15
Processing certifi-2018.10.15-py2.py3-none-any.whl
Installing certifi-2018.10.15-py2.py3-none-any.whl to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Adding certifi 2018.10.15 to easy-install.pth file
Installed <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages/certifi-2018.10.15-py2.7.egg>
Searching for future==0.16.0
Best match: future 0.16.0
Adding future 0.16.0 to easy-install.pth file
Installing pasteurize script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing futurize script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for futures==3.2.0
Best match: futures 3.2.0
Adding futures 3.2.0 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for protobuf==3.6.1
Best match: protobuf 3.6.1
Adding protobuf 3.6.1 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for grpcio==1.15.0
Best match: grpcio 1.15.0
Adding grpcio 1.15.0 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for setuptools==40.4.3
Best match: setuptools 40.4.3
Adding setuptools 40.4.3 to easy-install.pth file
Installing easy_install script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Installing easy_install-3.6 script to <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/bin>
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for six==1.11.0
Best match: six 1.11.0
Adding six 1.11.0 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Searching for enum34==1.1.6
Best match: enum34 1.1.6
Adding enum34 1.1.6 to easy-install.pth file
Using <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/gradleenv/lib/python2.7/site-packages>
Finished processing dependencies for apache-beam==2.9.0.dev0
Starting process 'command 'chmod''. Working directory: <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python> Command: chmod +x <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build/sdk_worker.sh>
Successfully started process 'command 'chmod''
:beam-sdks-python:createProcessWorker (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 35.057 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-python-container:docker'.
> Process 'command 'docker'' finished with non-zero exit value 100
* 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 2m 45s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/6yfgunucoye6g
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure