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/24 20:37:27 UTC

Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #491

See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/491/display/redirect?page=changes>

Changes:

[amyrvold] [BEAM-4431] Add "Edit this Page" button to website

------------------------------------------
[...truncated 4.38 MB...]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://localhost:44555 was granted leadership with leaderSessionID=4d8c0ed4-77a8-4b64-9de1-5ee876c86dec
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader http://localhost:44555 , session=4d8c0ed4-77a8-4b64-9de1-5ee876c86dec
[flink-runner-job-server] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatcher7c055423-99cd-4f51-ac4a-152f21131641 .
[flink-runner-job-server] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.dispatcher.StandaloneDispatcher@3fe6450 @ akka://flink/user/dispatcher7c055423-99cd-4f51-ac4a-152f21131641
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Flink Mini Cluster started successfully
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher akka://flink/user/dispatcher7c055423-99cd-4f51-ac4a-152f21131641 was granted leadership with fencing token 41079882-3cb8-4abe-91ba-2faedf508138
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all persisted jobs.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/dispatcher7c055423-99cd-4f51-ac4a-152f21131641 , session=41079882-3cb8-4abe-91ba-2faedf508138
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 14ed18f54049a5a6aca3a22ebb062f52 (test_windowing_1540413442.58).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_41 .
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job test_windowing_1540413442.58 (14ed18f54049a5a6aca3a22ebb062f52).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy NoRestartStrategy for test_windowing_1540413442.58 (14ed18f54049a5a6aca3a22ebb062f52).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.slotpool.SlotPool at akka://flink/user/590aeb49-13df-4e55-ace0-0dc85e6a7ca0 .
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via failover strategy: full graph restart
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job test_windowing_1540413442.58 (14ed18f54049a5a6aca3a22ebb062f52).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 0 ms.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.jobmaster.JobManagerRunner@617f2bd0 @ akka://flink/user/jobmanager_41
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job test_windowing_1540413442.58 (14ed18f54049a5a6aca3a22ebb062f52) was granted leadership with session id 813b94a1-0cd4-435a-9058-854191377335 at akka://flink/user/jobmanager_41.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job test_windowing_1540413442.58 (14ed18f54049a5a6aca3a22ebb062f52)
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1540413442.58 (14ed18f54049a5a6aca3a22ebb062f52) switched from state CREATED to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (3315393c08410646dbc3d7da69f2a190) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{9fc056a4dea1eda78cf69c0d22b1fa0c}]
[jobmanager-future-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/jobmanager_41 , session=813b94a1-0cd4-435a-9058-854191377335
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka://flink/user/resourcemanager_ff1d2b59-005b-40e2-8961-c281e3ab93fa(81c29b98c0509c75ca9159049fba4c55)
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager attempt 1 (timeout=100ms)
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering job manager 9058854191377335813b94a10cd4435a@akka://flink/user/jobmanager_41 for job 14ed18f54049a5a6aca3a22ebb062f52.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registered job manager 9058854191377335813b94a10cd4435a@akka://flink/user/jobmanager_41 for job 14ed18f54049a5a6aca3a22ebb062f52.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully registered at ResourceManager, leader id: 81c29b98c0509c75ca9159049fba4c55.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{9fc056a4dea1eda78cf69c0d22b1fa0c}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 14ed18f54049a5a6aca3a22ebb062f52 with allocation id AllocationID{2058451987821195f214683ea109fdf5}.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{2058451987821195f214683ea109fdf5} for job 14ed18f54049a5a6aca3a22ebb062f52 from resource manager with leader id 81c29b98c0509c75ca9159049fba4c55.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{2058451987821195f214683ea109fdf5}.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 14ed18f54049a5a6aca3a22ebb062f52 for job leader monitoring.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_41 with leader id 813b94a1-0cd4-435a-9058-854191377335.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager address, beginning registration
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Registration at JobManager attempt 1 (timeout=100ms)
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Successful registration at job manager akka://flink/user/jobmanager_41 for job 14ed18f54049a5a6aca3a22ebb062f52.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager connection for job 14ed18f54049a5a6aca3a22ebb062f52.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to the leader of job 14ed18f54049a5a6aca3a22ebb062f52.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{2058451987821195f214683ea109fdf5}.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying ToKeyedWorkItem (1/1) (attempt #0) to localhost
[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/1) (3315393c08410646dbc3d7da69f2a190) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1).
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) switched from CREATED to DEPLOYING.
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1).
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) [DEPLOYING].
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) switched from CREATED to DEPLOYING.
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) [DEPLOYING]
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) [DEPLOYING].
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) [DEPLOYING].
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1).
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) switched from CREATED to DEPLOYING.
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) [DEPLOYING]
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1).
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) [DEPLOYING].
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) switched from CREATED to DEPLOYING.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) [DEPLOYING]
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) [DEPLOYING].
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task ToKeyedWorkItem (1/1).
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) switched from CREATED to DEPLOYING.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) [DEPLOYING]
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) [DEPLOYING].
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) [DEPLOYING].
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) switched from DEPLOYING to RUNNING.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) switched from DEPLOYING to RUNNING.
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) switched from DEPLOYING to RUNNING.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) switched from DEPLOYING to RUNNING.
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) switched from DEPLOYING to RUNNING.
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) switched from DEPLOYING to RUNNING.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (3315393c08410646dbc3d7da69f2a190) switched from CREATED to DEPLOYING.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (3315393c08410646dbc3d7da69f2a190) [DEPLOYING]
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (3315393c08410646dbc3d7da69f2a190) [DEPLOYING].
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (3315393c08410646dbc3d7da69f2a190) [DEPLOYING].
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (3315393c08410646dbc3d7da69f2a190) switched from DEPLOYING to RUNNING.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
[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 (1/1) (3315393c08410646dbc3d7da69f2a190) switched from DEPLOYING to RUNNING.
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 exceeded the 80 characters length limit and was truncated.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull docker image jenkins-docker-apache.bintray.io/beam/python:latest, cause: Received exit code 1 for command 'docker pull jenkins-docker-apache.bintray.io/beam/python:latest'. stderr: Error response from daemon: unknown: Repo 'apache' was not found
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/flinktestj3590A/job_d66a5de6-8980-4f9e-857b-e279bf6218e7/MANIFEST
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Loading manifest for retrieval token /tmp/flinktestj3590A/job_d66a5de6-8980-4f9e-857b-e279bf6218e7/MANIFEST
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/flinktestj3590A/job_d66a5de6-8980-4f9e-857b-e279bf6218e7/MANIFEST has 0 artifact locations
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/flinktestj3590A/job_d66a5de6-8980-4f9e-857b-e279bf6218e7/MANIFEST -> 0 artifacts
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client connected.
[grpc-default-executor-4] INFO sdk_worker_main.main - Logging handler created.
[grpc-default-executor-4] INFO sdk_worker_main.start - Status HTTP server running at localhost:38639
[grpc-default-executor-4] INFO sdk_worker_main.main - semi_persistent_directory: /tmp
[grpc-default-executor-4] WARN sdk_worker_main._load_main_session - No session file found: /tmp/staged/pickled_main_session. Functions defined in __main__ (interactive session) may fail. 
[grpc-default-executor-4] INFO pipeline_options.get_all_options - Parsing unknown args: [u'--options_id=21', u'--direct_runner_use_stacked_bundle', u'--pipeline_type_check', u'--sdk_worker_parallelism=pipeline']
[grpc-default-executor-4] INFO sdk_worker_main.main - Python sdk harness started with pipeline_options: {'runner': u'None', 'streaming': True, 'experiments': [u'beam_fn_api'], 'sdk_location': u'container', 'flink_master': '[auto]', 'direct_runner_use_stacked_bundle': None, 'sdk_worker_parallelism': u'pipeline', 'job_name': u'test_windowing_1540413442.58', 'options_id': u'21', 'pipeline_type_check': None, 'parallelism': 1, 'job_endpoint': u'localhost:50113'}
[grpc-default-executor-4] INFO sdk_worker.__init__ - Creating insecure control channel.
[grpc-default-executor-4] INFO sdk_worker.__init__ - Control channel established.
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 1
[grpc-default-executor-5] INFO sdk_worker.__init__ - Initializing SDKHarness with 12 workers.
[grpc-default-executor-4] INFO sdk_worker.create_state_handler - Creating channel for localhost:40967
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_4:0 
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_24:0:0 
[grpc-default-executor-4] INFO data_plane.create_data_channel - Creating channel for localhost:46191
[grpc-default-executor-4] INFO org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client connected.
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_1:0 
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_17:0 
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_12:0 
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) switched from RUNNING to FINISHED.
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e).
[Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) [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 Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem dfea59c8d3a8050332fdeb6bd68e6a2e.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (dfea59c8d3a8050332fdeb6bd68e6a2e) switched from RUNNING to FINISHED.
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) switched from RUNNING to FINISHED.
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be).
[Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) [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 Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 3020e2ada3192a811f3451ac2302a0be.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (3020e2ada3192a811f3451ac2302a0be) switched from RUNNING to FINISHED.
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_7:0 
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) switched from RUNNING to FINISHED.
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3).
[Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem 055efff0e9329b4d5dd098aa2b7db1e3.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (055efff0e9329b4d5dd098aa2b7db1e3) switched from RUNNING to FINISHED.
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_24:1:0 
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_15:0 
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374).
[GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) [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 GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 f86d9b6e2f36154f9fc94f572c5d8374.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e).
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) [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 ToKeyedWorkItem a848d186ab4470a2e28de4ca6407c29e.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (f86d9b6e2f36154f9fc94f572c5d8374) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (a848d186ab4470a2e28de4ca6407c29e) switched from RUNNING to FINISHED.
[grpc-default-executor-4] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_27:0 
[grpc-default-executor-4] INFO sdk_worker.run - No more requests from control plane
[grpc-default-executor-4] INFO sdk_worker.run - SDK Harness waiting for in-flight requests to complete
[grpc-default-executor-4] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-4] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-4] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-4] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-4] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-4] 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 (1/1)] 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 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (3315393c08410646dbc3d7da69f2a190) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] 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/1) (3315393c08410646dbc3d7da69f2a190).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1)] 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/1) (3315393c08410646dbc3d7da69f2a190) [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 3315393c08410646dbc3d7da69f2a190.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (3315393c08410646dbc3d7da69f2a190) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1540413442.58 (14ed18f54049a5a6aca3a22ebb062f52) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 14ed18f54049a5a6aca3a22ebb062f52.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 14ed18f54049a5a6aca3a22ebb062f52 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job test_windowing_1540413442.58(14ed18f54049a5a6aca3a22ebb062f52).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection bc1dff361940685f14ef930f0e838313: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 9058854191377335813b94a10cd4435a@akka://flink/user/jobmanager_41 for job 14ed18f54049a5a6aca3a22ebb062f52 from the resource manager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher7c055423-99cd-4f51-ac4a-152f21131641.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher7c055423-99cd-4f51-ac4a-152f21131641.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 14ed18f54049a5a6aca3a22ebb062f52 with leader id 9058854191377335813b94a10cd4435a lost leadership.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 14ed18f54049a5a6aca3a22ebb062f52.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher7c055423-99cd-4f51-ac4a-152f21131641.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager b5fdb1b37a91ba768aaee0674e629262 from the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2058451987821195f214683ea109fdf5}, jobId: 14ed18f54049a5a6aca3a22ebb062f52).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 14ed18f54049a5a6aca3a22ebb062f52 from job leader monitoring.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 14ed18f54049a5a6aca3a22ebb062f52.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_40.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-e020aa41-c747-480d-a6e5-802ada4df4c1
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_40.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:46381
[flink-akka.actor.default-dispatcher-2] 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 1923 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@d17ee317
.
----------------------------------------------------------------------
Ran 26 tests in 102.966s

OK (skipped=7)
:beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 1 mins 45.166 secs.

FAILURE: Build failed with an exception.

* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'> line: 368

* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER'.
> 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 12m 47s
60 actionable tasks: 55 executed, 4 from cache, 1 up-to-date

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

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 #493

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/493/display/redirect?page=changes>

Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #492

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/492/display/redirect?page=changes>

Changes:

[scott] [BEAM-5837] Add health check prober for community metrics infrastructure

------------------------------------------
[...truncated 262.59 KB...]
Note: Recompile with -Xlint:unchecked for details.
Created classpath snapshot for incremental compilation in 0.824 secs. 415 duplicate classes found in classpath (see all with --debug).
Packing task ':beam-sdks-java-harness:compileJava'
:beam-sdks-java-harness:compileJava (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 8.014 secs.
:beam-sdks-java-harness:classes (Thread[Task worker for ':' Thread 7,5,main]) started.

> Task :beam-sdks-java-harness:classes
Skipping task ':beam-sdks-java-harness:classes' as it has no actions.
:beam-sdks-java-harness:classes (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 0.0 secs.
:beam-sdks-java-harness:jar (Thread[Task worker for ':' Thread 7,5,main]) started.

> Task :beam-sdks-java-harness:jar
Build cache key for task ':beam-sdks-java-harness:jar' is 05a8b416f59b8244e5b470e02702d2fb
Caching disabled for task ':beam-sdks-java-harness:jar': Caching has not been enabled for the task
Task ':beam-sdks-java-harness:jar' is not up-to-date because:
  No history is available.
:beam-sdks-java-harness:jar (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 0.042 secs.
:beam-sdks-java-harness:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) started.

> Task :beam-sdks-python-container:buildLinuxAmd64
Build cache key for task ':beam-sdks-python-container:buildLinuxAmd64' is 8b3c1dec1f894d25b8482e148deb094a
Caching disabled for task ':beam-sdks-python-container:buildLinuxAmd64': Caching has not been enabled for the task
Task ':beam-sdks-python-container:buildLinuxAmd64' is not up-to-date because:
  No history is available.
:beam-sdks-python-container:buildLinuxAmd64 (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 3.025 secs.
:beam-sdks-python-container:build (Thread[Task worker for ':' Thread 6,5,main]) started.

> Task :beam-sdks-python-container:build
Caching disabled for task ':beam-sdks-python-container:build': Caching has not been enabled for the task
Task ':beam-sdks-python-container:build' is not up-to-date because:
  Task has not declared any outputs despite executing actions.
:beam-sdks-python-container:build (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 0.0 secs.
:beam-sdks-python-container:copyDockerfileDependencies (Thread[Task worker for ':' Thread 6,5,main]) started.

> Task :beam-sdks-python-container:copyDockerfileDependencies
Build cache key for task ':beam-sdks-python-container:copyDockerfileDependencies' is 1213041a9569e8a6a16f48838ddf1ef1
Caching disabled for task ':beam-sdks-python-container:copyDockerfileDependencies': Caching has not been enabled for the task
Task ':beam-sdks-python-container:copyDockerfileDependencies' is not up-to-date because:
  No history is available.
:beam-sdks-python-container:copyDockerfileDependencies (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 0.037 secs.
:beam-sdks-python-container:dockerPrepare (Thread[Task worker for ':' Thread 6,5,main]) started.

> Task :beam-sdks-python-container:dockerPrepare
Build cache key for task ':beam-sdks-python-container:dockerPrepare' is 3eeea70c627d157069808e28aa42f609
Caching disabled for task ':beam-sdks-python-container:dockerPrepare': Caching has not been enabled for the task
Task ':beam-sdks-python-container:dockerPrepare' is not up-to-date because:
  No history is available.
:beam-sdks-python-container:dockerPrepare (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 0.099 secs.
:beam-sdks-python-container:docker (Thread[Task worker for ':' Thread 6,5,main]) started.

> Task :beam-sdks-java-harness:shadowJar
Build cache key for task ':beam-sdks-java-harness:shadowJar' is b3ad4679192c5b0e9b8a8f13824e5895
Caching disabled for task ':beam-sdks-java-harness:shadowJar': Caching has not been enabled for the task
Task ':beam-sdks-java-harness:shadowJar' is not up-to-date because:
  No history is available.

> Task :beam-sdks-python-container:docker FAILED
Caching disabled for task ':beam-sdks-python-container:docker': Caching has not been enabled for the task
Task ':beam-sdks-python-container:docker' is not up-to-date because:
  Task has not declared any outputs despite executing actions.
Starting process 'command 'docker''. Working directory: <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/container/build/docker> Command: docker build --no-cache -t jenkins-docker-apache.bintray.io/beam/python:latest .
Successfully started process 'command 'docker''
Sending build context to Docker daemon  17.65MB
Step 1/9 : FROM python:2-stretch
2-stretch: Pulling from library/python
Digest: sha256:629868162ed980d9b24bf3bf0699cb300b368e8b144be9fc43a6a4740cc02561
Status: Downloaded newer image for python:2-stretch
 ---> 3c43a5d4034a
Step 2/9 : MAINTAINER "Apache Beam <de...@beam.apache.org>"
 ---> Running in c2b35e8cee44
 ---> 0a6de51fb9fc
Removing intermediate container c2b35e8cee44
Step 3/9 : RUN apt-get update &&     apt-get install -y        libsnappy-dev        libyaml-dev        &&     rm -rf /var/lib/apt/lists/*
 ---> Running in bd05988b5e2c
Ign:1 http://deb.debian.org/debian stretch InRelease
Get:2 http://deb.debian.org/debian stretch-updates InRelease [91.0 kB]
Get:3 http://deb.debian.org/debian stretch Release [118 kB]
Get:4 http://deb.debian.org/debian stretch Release.gpg [2434 B]
Get:5 http://deb.debian.org/debian stretch-updates/main amd64 Packages [5152 B]
Get:6 http://deb.debian.org/debian stretch/main amd64 Packages [7099 kB]
Get:7 http://security.debian.org/debian-security stretch/updates InRelease [94.3 kB]
Get:8 http://security.debian.org/debian-security stretch/updates/main amd64 Packages [452 kB]
Err:8 http://security.debian.org/debian-security stretch/updates/main amd64 Packages
  Hash Sum mismatch
  Hashes of expected file:
   - Filesize:452116 [weak]
   - SHA256:4f6a2b1cb0591e3c6986498115047e2ab8c42e724c850738598c5447fa83052b
   - SHA1:e35b5091a3eab9bf67be4247c0d367ae1132e50c [weak]
   - MD5Sum:e948b36f928e6a198b38b4d67599066b [weak]
  Hashes of received file:
   - SHA256:f5c92c4fa6a819c56f9f50c15560bad23de9bb0d32774abecc2fa4e12d5bd889
   - SHA1:70d77d0f573f4215474ef8f495ab42e272007349 [weak]
   - MD5Sum:434c9de693ad0e53b72cbfe245816d8e [weak]
   - Filesize:452096 [weak]
  Last modification reported: Thu, 18 Oct 2018 21:05:06 +0000
  Release file created at: Wed, 24 Oct 2018 20:38:18 +0000
Fetched 7862 kB in 5s (1396 kB/s)
Reading package lists...
E: Failed to fetch http://security.debian.org/debian-security/dists/stretch/updates/main/binary-amd64/Packages.xz  Hash Sum mismatch
   Hashes of expected file:
    - Filesize:452116 [weak]
    - SHA256:4f6a2b1cb0591e3c6986498115047e2ab8c42e724c850738598c5447fa83052b
    - SHA1:e35b5091a3eab9bf67be4247c0d367ae1132e50c [weak]
    - MD5Sum:e948b36f928e6a198b38b4d67599066b [weak]
   Hashes of received file:
    - SHA256:f5c92c4fa6a819c56f9f50c15560bad23de9bb0d32774abecc2fa4e12d5bd889
    - SHA1:70d77d0f573f4215474ef8f495ab42e272007349 [weak]
    - MD5Sum:434c9de693ad0e53b72cbfe245816d8e [weak]
    - Filesize:452096 [weak]
   Last modification reported: Thu, 18 Oct 2018 21:05:06 +0000
   Release file created at: Wed, 24 Oct 2018 20:38:18 +0000
E: Some index files failed to download. They have been ignored, or old ones used instead.
The command '/bin/sh -c apt-get update &&     apt-get install -y        libsnappy-dev        libyaml-dev        &&     rm -rf /var/lib/apt/lists/*' returned a non-zero code: 100
:beam-sdks-python-container:docker (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 11.231 secs.

> Task :beam-sdks-java-harness:shadowJar
*******************
GRADLE SHADOW STATS

Total Jars: 44 (includes project)
Total Time: 35.987s [35987ms]
Average Time/Jar: 0.8178863636364s [817.8863636364ms]
*******************
:beam-sdks-java-harness:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 36.589 secs.
:beam-runners-java-fn-execution:compileJava (Thread[Task worker for ':' Thread 7,5,main]) started.

> Task :beam-runners-java-fn-execution:compileJava
Build cache key for task ':beam-runners-java-fn-execution:compileJava' is 1a6594191ec2093272314038c90534e8
Task ':beam-runners-java-fn-execution:compileJava' is not up-to-date because:
  No history is available.
Custom actions are attached to task ':beam-runners-java-fn-execution:compileJava'.
All input files are considered out-of-date for incremental task ':beam-runners-java-fn-execution:compileJava'.
Full recompilation is required because no incremental change information is available. This is usually caused by clean builds or changing compiler arguments.
Compiling with error-prone compiler
Note: <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/ServerFactory.java> uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Created classpath snapshot for incremental compilation in 4.211 secs. 26887 duplicate classes found in classpath (see all with --debug).
Packing task ':beam-runners-java-fn-execution:compileJava'
:beam-runners-java-fn-execution:compileJava (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 15.71 secs.
:beam-runners-java-fn-execution:classes (Thread[Task worker for ':' Thread 7,5,main]) started.

> Task :beam-runners-java-fn-execution:classes
Skipping task ':beam-runners-java-fn-execution:classes' as it has no actions.
:beam-runners-java-fn-execution:classes (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 0.0 secs.
:beam-runners-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) started.

> Task :beam-runners-java-fn-execution:shadowJar
Build cache key for task ':beam-runners-java-fn-execution:shadowJar' is 03f764983ae2c315ee1fa03417837a25
Caching disabled for task ':beam-runners-java-fn-execution:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-java-fn-execution:shadowJar' is not up-to-date because:
  No history is available.
*******************
GRADLE SHADOW STATS

Total Jars: 2 (includes project)
Total Time: 2.342s [2342ms]
Average Time/Jar: 1.171s [1171.0ms]
*******************
:beam-runners-java-fn-execution:shadowJar (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 2.515 secs.
:beam-runners-flink_2.11:compileJava (Thread[Task worker for ':' Thread 7,5,main]) started.

> Task :beam-runners-flink_2.11:compileJava
Build cache key for task ':beam-runners-flink_2.11:compileJava' is 803858c096416b6c1b7b51d9a2c0bbc7
Task ':beam-runners-flink_2.11:compileJava' is not up-to-date because:
  No history is available.
Custom actions are attached to task ':beam-runners-flink_2.11:compileJava'.
All input files are considered out-of-date for incremental task ':beam-runners-flink_2.11:compileJava'.
Full recompilation is required because no incremental change information is available. This is usually caused by clean builds or changing compiler arguments.
Compiling with error-prone compiler
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
Created classpath snapshot for incremental compilation in 0.688 secs. 2217 duplicate classes found in classpath (see all with --debug).
Packing task ':beam-runners-flink_2.11:compileJava'
:beam-runners-flink_2.11:compileJava (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 11.971 secs.
:beam-runners-flink_2.11:classes (Thread[Task worker for ':' Thread 7,5,main]) started.

> Task :beam-runners-flink_2.11:classes
Skipping task ':beam-runners-flink_2.11:classes' as it has no actions.
:beam-runners-flink_2.11:classes (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 0.0 secs.
:beam-runners-flink_2.11:shadowJar (Thread[Task worker for ':' Thread 5,5,main]) started.

> Task :beam-runners-flink_2.11:shadowJar
Build cache key for task ':beam-runners-flink_2.11:shadowJar' is 14bbf438ce27db473ad0c2e832ed4982
Caching disabled for task ':beam-runners-flink_2.11:shadowJar': Caching has not been enabled for the task
Task ':beam-runners-flink_2.11:shadowJar' is not up-to-date because:
  No history is available.
*******************
GRADLE SHADOW STATS

Total Jars: 2 (includes project)
Total Time: 2.052s [2052ms]
Average Time/Jar: 1.026s [1026.0ms]
*******************
:beam-runners-flink_2.11:shadowJar (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 2.542 secs.
:beam-runners-flink_2.11-job-server:compileJava (Thread[Task worker for ':' Thread 5,5,main]) started.

> Task :beam-runners-flink_2.11-job-server:compileJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/runners/flink/job-server/src/main/java',> not found
Skipping task ':beam-runners-flink_2.11-job-server:compileJava' as it has no source files and no previous output files.
:beam-runners-flink_2.11-job-server:compileJava (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 0.002 secs.
:beam-runners-flink_2.11-job-server:classes (Thread[Task worker for ':' Thread 5,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 ':' Thread 5,5,main]) completed. Took 0.0 secs.
:beam-runners-flink_2.11-job-server:shadowJar (Thread[Task worker for ':' Thread 2,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 006a5532941aafe9b62a8ac805834c26
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.256s [16256ms]
Average Time/Jar: 0.189023255814s [189.023255814ms]
*******************
:beam-runners-flink_2.11-job-server:shadowJar (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 17.477 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 3m 42s
58 actionable tasks: 57 executed, 1 up-to-date

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

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