Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #459

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/459/display/redirect>

------------------------------------------
[...truncated 4.48 MB...]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://localhost:40333 was granted leadership with leaderSessionID=ff495be2-68ff-40b6-a53b-bf7a02088216
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader http://localhost:40333 , session=ff495be2-68ff-40b6-a53b-bf7a02088216
[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/dispatcher4615ad29-997a-454a-922d-c321c9f78155 .
[flink-runner-job-server] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.dispatcher.StandaloneDispatcher@9d39133 @ akka://flink/user/dispatcher4615ad29-997a-454a-922d-c321c9f78155
[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/dispatcher4615ad29-997a-454a-922d-c321c9f78155 was granted leadership with fencing token f8f1f453-09fc-4f04-af9a-8224cbb97a8e
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all persisted jobs.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/dispatcher4615ad29-997a-454a-922d-c321c9f78155 , session=f8f1f453-09fc-4f04-af9a-8224cbb97a8e
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job e0c33866ef0a813985778125913ef094 (test_windowing_1540272002.25).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_39 .
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job test_windowing_1540272002.25 (e0c33866ef0a813985778125913ef094).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy NoRestartStrategy for test_windowing_1540272002.25 (e0c33866ef0a813985778125913ef094).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.slotpool.SlotPool at akka://flink/user/fb750294-e212-495b-9439-71af63e0c2b2 .
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via failover strategy: full graph restart
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job test_windowing_1540272002.25 (e0c33866ef0a813985778125913ef094).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 0 ms.
[flink-akka.actor.default-dispatcher-2] 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-2] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.jobmaster.JobManagerRunner@36efe68f @ akka://flink/user/jobmanager_39
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job test_windowing_1540272002.25 (e0c33866ef0a813985778125913ef094) was granted leadership with session id 489ece2f-8548-4016-8752-c5100e174375 at akka://flink/user/jobmanager_39.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job test_windowing_1540272002.25 (e0c33866ef0a813985778125913ef094)
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1540272002.25 (e0c33866ef0a813985778125913ef094) switched from state CREATED to RUNNING.
[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) (1560878553f40e17016710e3bf878074) switched from CREATED to SCHEDULED.
[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) (cd6cf2f58dc261dd552c622fe84b7064) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (af6e1c455962e20d85259ab36d4394db) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (8d04243939b4d09bced3fdc3253193d5) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) switched from CREATED to SCHEDULED.
[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) (9ab4b29170ea150955d1bd35d477535a) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{e8a9c3d1f3e0cbf7324679aee6825b6e}]
[jobmanager-future-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/jobmanager_39 , session=489ece2f-8548-4016-8752-c5100e174375
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka://flink/user/resourcemanager_c2c5ecd9-ee31-4975-8934-192cf04d3676(9875be0b1e791bca7fce2e3e575c4b04)
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration
[flink-akka.actor.default-dispatcher-5] 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 8752c5100e174375489ece2f85484016@akka://flink/user/jobmanager_39 for job e0c33866ef0a813985778125913ef094.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registered job manager 8752c5100e174375489ece2f85484016@akka://flink/user/jobmanager_39 for job e0c33866ef0a813985778125913ef094.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully registered at ResourceManager, leader id: 9875be0b1e791bca7fce2e3e575c4b04.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{e8a9c3d1f3e0cbf7324679aee6825b6e}] 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 e0c33866ef0a813985778125913ef094 with allocation id AllocationID{9f6138b888fe6de30533eebf363f8563}.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{9f6138b888fe6de30533eebf363f8563} for job e0c33866ef0a813985778125913ef094 from resource manager with leader id 9875be0b1e791bca7fce2e3e575c4b04.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{9f6138b888fe6de30533eebf363f8563}.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job e0c33866ef0a813985778125913ef094 for job leader monitoring.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_39 with leader id 489ece2f-8548-4016-8752-c5100e174375.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager address, beginning registration
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Registration at JobManager attempt 1 (timeout=100ms)
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Successful registration at job manager akka://flink/user/jobmanager_39 for job e0c33866ef0a813985778125913ef094.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager connection for job e0c33866ef0a813985778125913ef094.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to the leader of job e0c33866ef0a813985778125913ef094.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{9f6138b888fe6de30533eebf363f8563}.
[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) (cd6cf2f58dc261dd552c622fe84b7064) 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) (1560878553f40e17016710e3bf878074) 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) (af6e1c455962e20d85259ab36d4394db) 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) (8d04243939b4d09bced3fdc3253193d5) 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-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).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) switched from SCHEDULED to DEPLOYING.
[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) (cd6cf2f58dc261dd552c622fe84b7064) 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) (cd6cf2f58dc261dd552c622fe84b7064) [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-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) (cd6cf2f58dc261dd552c622fe84b7064) [DEPLOYING].
[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) (9ab4b29170ea150955d1bd35d477535a) 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
[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) (1560878553f40e17016710e3bf878074) 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) (1560878553f40e17016710e3bf878074) [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) (1560878553f40e17016710e3bf878074) [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) (1560878553f40e17016710e3bf878074) [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) (cd6cf2f58dc261dd552c622fe84b7064) [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) (af6e1c455962e20d85259ab36d4394db) 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) (af6e1c455962e20d85259ab36d4394db) [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) (af6e1c455962e20d85259ab36d4394db) [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 - Registering task at network: Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (af6e1c455962e20d85259ab36d4394db) [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).
[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) (8d04243939b4d09bced3fdc3253193d5) 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) (8d04243939b4d09bced3fdc3253193d5) [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) (8d04243939b4d09bced3fdc3253193d5) [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) (8d04243939b4d09bced3fdc3253193d5) [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) (e8fc307ece575c9202e0b83828521887) 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) (e8fc307ece575c9202e0b83828521887) [DEPLOYING]
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) [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 - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (af6e1c455962e20d85259ab36d4394db) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) [DEPLOYING].
[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) (cd6cf2f58dc261dd552c622fe84b7064) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] 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) (af6e1c455962e20d85259ab36d4394db) 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.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 - Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 (1/1) (cd6cf2f58dc261dd552c622fe84b7064) switched from DEPLOYING to RUNNING.
[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) (1560878553f40e17016710e3bf878074) 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-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (1560878553f40e17016710e3bf878074) switched from DEPLOYING to RUNNING.
[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).
[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) (8d04243939b4d09bced3fdc3253193d5) 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)
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (8d04243939b4d09bced3fdc3253193d5) 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) (9ab4b29170ea150955d1bd35d477535a) 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) (9ab4b29170ea150955d1bd35d477535a) [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) (9ab4b29170ea150955d1bd35d477535a) [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) (9ab4b29170ea150955d1bd35d477535a) [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) (9ab4b29170ea150955d1bd35d477535a) 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-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (9ab4b29170ea150955d1bd35d477535a) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) 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)
[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.
[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.
[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.
[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-2] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/flinktestol2jSb/job_c9d1af74-4af7-4624-9ffd-e1971c774d0f/MANIFEST
[grpc-default-executor-2] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Loading manifest for retrieval token /tmp/flinktestol2jSb/job_c9d1af74-4af7-4624-9ffd-e1971c774d0f/MANIFEST
[grpc-default-executor-2] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/flinktestol2jSb/job_c9d1af74-4af7-4624-9ffd-e1971c774d0f/MANIFEST has 0 artifact locations
[grpc-default-executor-2] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/flinktestol2jSb/job_c9d1af74-4af7-4624-9ffd-e1971c774d0f/MANIFEST -> 0 artifacts
[grpc-default-executor-2] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client connected.
[grpc-default-executor-2] INFO sdk_worker_main.main - Logging handler created.
[grpc-default-executor-2] INFO sdk_worker_main.start - Status HTTP server running at localhost:40809
[grpc-default-executor-2] INFO sdk_worker_main.main - semi_persistent_directory: /tmp
[grpc-default-executor-2] 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-2] INFO pipeline_options.get_all_options - Parsing unknown args: [u'--options_id=20', u'--direct_runner_use_stacked_bundle', u'--pipeline_type_check', u'--sdk_worker_parallelism=pipeline']
[grpc-default-executor-2] 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_1540272002.25', 'options_id': u'20', 'pipeline_type_check': None, 'parallelism': 1, 'job_endpoint': u'localhost:43575'}
[grpc-default-executor-2] INFO sdk_worker.__init__ - Creating insecure control channel.
[grpc-default-executor-2] INFO sdk_worker.__init__ - Control channel established.
[grpc-default-executor-2] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 1
[grpc-default-executor-0] INFO sdk_worker.__init__ - Initializing SDKHarness with 12 workers.
[grpc-default-executor-0] INFO sdk_worker.create_state_handler - Creating channel for localhost:41567
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_24:1:0 
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_4:0 
[grpc-default-executor-0] INFO data_plane.create_data_channel - Creating channel for localhost:39463
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client connected.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_1:0 
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_17:0 
[grpc-default-executor-0] 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) (1560878553f40e17016710e3bf878074) 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) (1560878553f40e17016710e3bf878074).
[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) (1560878553f40e17016710e3bf878074) [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 Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem 1560878553f40e17016710e3bf878074.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (1560878553f40e17016710e3bf878074) switched from RUNNING to FINISHED.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_7:0 
[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) (cd6cf2f58dc261dd552c622fe84b7064) 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) (cd6cf2f58dc261dd552c622fe84b7064).
[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) (cd6cf2f58dc261dd552c622fe84b7064) [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 Source: Custom Source -> 26assert_that/Create/Impulse.None/beam:env:docker:v1:0 cd6cf2f58dc261dd552c622fe84b7064.
[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) (cd6cf2f58dc261dd552c622fe84b7064) 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 - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (af6e1c455962e20d85259ab36d4394db) 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) (af6e1c455962e20d85259ab36d4394db).
[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) (af6e1c455962e20d85259ab36d4394db) [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 Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem af6e1c455962e20d85259ab36d4394db.
[flink-akka.actor.default-dispatcher-3] 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) (af6e1c455962e20d85259ab36d4394db) switched from RUNNING to FINISHED.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_24:0:0 
[grpc-default-executor-0] 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) (8d04243939b4d09bced3fdc3253193d5) 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) (8d04243939b4d09bced3fdc3253193d5).
[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) (8d04243939b4d09bced3fdc3253193d5) [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 GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 8d04243939b4d09bced3fdc3253193d5.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887).
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) [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 e8fc307ece575c9202e0b83828521887.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (8d04243939b4d09bced3fdc3253193d5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (e8fc307ece575c9202e0b83828521887) switched from RUNNING to FINISHED.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_27:0 
[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] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-2] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-0] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-0] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-0] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-0] 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) (9ab4b29170ea150955d1bd35d477535a) 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) (9ab4b29170ea150955d1bd35d477535a).
[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) (9ab4b29170ea150955d1bd35d477535a) [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 9ab4b29170ea150955d1bd35d477535a.
[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) (9ab4b29170ea150955d1bd35d477535a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1540272002.25 (e0c33866ef0a813985778125913ef094) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job e0c33866ef0a813985778125913ef094.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job e0c33866ef0a813985778125913ef094 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_1540272002.25(e0c33866ef0a813985778125913ef094).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job e0c33866ef0a813985778125913ef094.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 6c971c8ddc315e550f2d0b30b6efc12e: JobManager is shutting down..
[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.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 8752c5100e174375489ece2f85484016@akka://flink/user/jobmanager_39 for job e0c33866ef0a813985778125913ef094 from the resource manager.
[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 16b613476f330d35459351cf3f378f3f from the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job e0c33866ef0a813985778125913ef094 with leader id 8752c5100e174375489ece2f85484016 lost leadership.
[flink-akka.actor.default-dispatcher-3] 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{9f6138b888fe6de30533eebf363f8563}, jobId: e0c33866ef0a813985778125913ef094).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job e0c33866ef0a813985778125913ef094 from job leader monitoring.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job e0c33866ef0a813985778125913ef094.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher4615ad29-997a-454a-922d-c321c9f78155.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher4615ad29-997a-454a-922d-c321c9f78155.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-6d849b87-f3a4-43ed-95d5-8e0cd077457a
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher4615ad29-997a-454a-922d-c321c9f78155.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_38.
[flink-akka.actor.default-dispatcher-3] 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:34531
[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 2080 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@2198875c
.
----------------------------------------------------------------------
Ran 26 tests in 80.777s

OK (skipped=8)
:beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 1 mins 23.256 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: 367

* 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 52s
61 actionable tasks: 54 executed, 6 from cache, 1 up-to-date

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

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

[Apache Jenkins Server <je...@builds.apache.org>]

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

Build failed in Jenkins: beam_PostCommit_Python_VR_Flink #461

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/461/display/redirect>

------------------------------------------
[...truncated 4.47 MB...]
[flink-runner-job-server] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.dispatcher.StandaloneDispatcher@3394a869 @ akka://flink/user/dispatcherde8f197f-f1d7-4179-b97d-ca2973c99f4b
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Flink Mini Cluster started successfully
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher akka://flink/user/dispatcherde8f197f-f1d7-4179-b97d-ca2973c99f4b was granted leadership with fencing token 687d34eb-cd4a-4230-875b-1cf33869ace6
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all persisted jobs.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/dispatcherde8f197f-f1d7-4179-b97d-ca2973c99f4b , session=687d34eb-cd4a-4230-875b-1cf33869ace6
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 38457691ce647fc0a1510cd47d8f2702 (test_windowing_1540275057.97).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_39 .
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job test_windowing_1540275057.97 (38457691ce647fc0a1510cd47d8f2702).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy NoRestartStrategy for test_windowing_1540275057.97 (38457691ce647fc0a1510cd47d8f2702).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.slotpool.SlotPool at akka://flink/user/f431d7d6-4df6-4902-a64e-523239d5c029 .
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via failover strategy: full graph restart
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job test_windowing_1540275057.97 (38457691ce647fc0a1510cd47d8f2702).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 0 ms.
[flink-akka.actor.default-dispatcher-4] 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-4] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.jobmaster.JobManagerRunner@4639f84c @ akka://flink/user/jobmanager_39
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job test_windowing_1540275057.97 (38457691ce647fc0a1510cd47d8f2702) was granted leadership with session id 3129d16f-1b9a-4579-b92f-5bd83dc939d4 at akka://flink/user/jobmanager_39.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job test_windowing_1540275057.97 (38457691ce647fc0a1510cd47d8f2702)
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1540275057.97 (38457691ce647fc0a1510cd47d8f2702) switched from state CREATED to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (6ec745901397e5bbbe2c0c211628b951) switched from CREATED to SCHEDULED.
[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) (e3f82875dec77c422ca0b889ba081ef2) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] 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) (3ef2a687adaf3237f66721b58ecc9f4e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (354c71ec39ffa2970ba6d687aecf9fda) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) switched from CREATED to SCHEDULED.
[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/1) (f7b397098ad7e30fc7d4a578cc123ebc) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{023b869678e1f267ce8046da2b07d5df}]
[jobmanager-future-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/jobmanager_39 , session=3129d16f-1b9a-4579-b92f-5bd83dc939d4
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka://flink/user/resourcemanager_10afac6c-b746-4c9f-9fa8-72d3b93e4a76(a4cd6546267dfa6e23e39d00413440fe)
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration
[flink-akka.actor.default-dispatcher-5] 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 b92f5bd83dc939d43129d16f1b9a4579@akka://flink/user/jobmanager_39 for job 38457691ce647fc0a1510cd47d8f2702.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registered job manager b92f5bd83dc939d43129d16f1b9a4579@akka://flink/user/jobmanager_39 for job 38457691ce647fc0a1510cd47d8f2702.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully registered at ResourceManager, leader id: a4cd6546267dfa6e23e39d00413440fe.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{023b869678e1f267ce8046da2b07d5df}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
[flink-akka.actor.default-dispatcher-2] 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 38457691ce647fc0a1510cd47d8f2702 with allocation id AllocationID{6ee813aac6e1655c6c45e0c526d0bb51}.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{6ee813aac6e1655c6c45e0c526d0bb51} for job 38457691ce647fc0a1510cd47d8f2702 from resource manager with leader id a4cd6546267dfa6e23e39d00413440fe.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{6ee813aac6e1655c6c45e0c526d0bb51}.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 38457691ce647fc0a1510cd47d8f2702 for job leader monitoring.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_39 with leader id 3129d16f-1b9a-4579-b92f-5bd83dc939d4.
[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_39 for job 38457691ce647fc0a1510cd47d8f2702.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager connection for job 38457691ce647fc0a1510cd47d8f2702.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to the leader of job 38457691ce647fc0a1510cd47d8f2702.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{6ee813aac6e1655c6c45e0c526d0bb51}.
[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) (e3f82875dec77c422ca0b889ba081ef2) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] 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-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (6ec745901397e5bbbe2c0c211628b951) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] 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-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) (3ef2a687adaf3237f66721b58ecc9f4e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] 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-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (354c71ec39ffa2970ba6d687aecf9fda) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] 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.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) (e3f82875dec77c422ca0b889ba081ef2) 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) (e3f82875dec77c422ca0b889ba081ef2) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying ToKeyedWorkItem (1/1) (attempt #0) to localhost
[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) (e3f82875dec77c422ca0b889ba081ef2) [DEPLOYING].
[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) (f7b397098ad7e30fc7d4a578cc123ebc) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] 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-4] 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 -> 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) (6ec745901397e5bbbe2c0c211628b951) 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) (6ec745901397e5bbbe2c0c211628b951) [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) (e3f82875dec77c422ca0b889ba081ef2) [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) (6ec745901397e5bbbe2c0c211628b951) [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) (6ec745901397e5bbbe2c0c211628b951) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] 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) (3ef2a687adaf3237f66721b58ecc9f4e) 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) (3ef2a687adaf3237f66721b58ecc9f4e) [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) (3ef2a687adaf3237f66721b58ecc9f4e) [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 - Registering task at network: Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (3ef2a687adaf3237f66721b58ecc9f4e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1).
[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) (354c71ec39ffa2970ba6d687aecf9fda) 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) (354c71ec39ffa2970ba6d687aecf9fda) [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) (354c71ec39ffa2970ba6d687aecf9fda) [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) (354c71ec39ffa2970ba6d687aecf9fda) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] 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) (9659cf6bd27d3032aaebf3281ed5c3fe) 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) (9659cf6bd27d3032aaebf3281ed5c3fe) [DEPLOYING]
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) [DEPLOYING].
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] 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).
[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) (f7b397098ad7e30fc7d4a578cc123ebc) 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) (f7b397098ad7e30fc7d4a578cc123ebc) [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) (f7b397098ad7e30fc7d4a578cc123ebc) [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) (f7b397098ad7e30fc7d4a578cc123ebc) [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 - Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem (1/1) (3ef2a687adaf3237f66721b58ecc9f4e) 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) (f7b397098ad7e30fc7d4a578cc123ebc) switched from DEPLOYING to RUNNING.
[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) (6ec745901397e5bbbe2c0c211628b951) 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)
[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-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) (3ef2a687adaf3237f66721b58ecc9f4e) 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-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) (f7b397098ad7e30fc7d4a578cc123ebc) switched from DEPLOYING to RUNNING.
[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) (6ec745901397e5bbbe2c0c211628b951) 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) (354c71ec39ffa2970ba6d687aecf9fda) 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)
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (354c71ec39ffa2970ba6d687aecf9fda) switched from DEPLOYING to RUNNING.
[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) (e3f82875dec77c422ca0b889ba081ef2) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) switched from DEPLOYING to RUNNING.
[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) (e3f82875dec77c422ca0b889ba081ef2) 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-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) 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)
[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.
[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)] 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.
[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.
[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-0] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/flinktestQol6zG/job_dd6d0745-86a9-4934-8c0b-d0b87744cbdb/MANIFEST
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Loading manifest for retrieval token /tmp/flinktestQol6zG/job_dd6d0745-86a9-4934-8c0b-d0b87744cbdb/MANIFEST
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/flinktestQol6zG/job_dd6d0745-86a9-4934-8c0b-d0b87744cbdb/MANIFEST has 0 artifact locations
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/flinktestQol6zG/job_dd6d0745-86a9-4934-8c0b-d0b87744cbdb/MANIFEST -> 0 artifacts
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client connected.
[grpc-default-executor-0] INFO sdk_worker_main.main - Logging handler created.
[grpc-default-executor-0] INFO sdk_worker_main.start - Status HTTP server running at localhost:40959
[grpc-default-executor-0] INFO sdk_worker_main.main - semi_persistent_directory: /tmp
[grpc-default-executor-0] 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-0] INFO pipeline_options.get_all_options - Parsing unknown args: [u'--options_id=20', u'--direct_runner_use_stacked_bundle', u'--pipeline_type_check', u'--sdk_worker_parallelism=pipeline']
[grpc-default-executor-0] 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_1540275057.97', 'options_id': u'20', 'pipeline_type_check': None, 'parallelism': 1, 'job_endpoint': u'localhost:55015'}
[grpc-default-executor-0] INFO sdk_worker.__init__ - Creating insecure control channel.
[grpc-default-executor-0] INFO sdk_worker.__init__ - Control channel established.
[grpc-default-executor-0] INFO sdk_worker.__init__ - Initializing SDKHarness with 12 workers.
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 1
[grpc-default-executor-0] INFO sdk_worker.create_state_handler - Creating channel for localhost:45797
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_4:0 
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_24:0:0 
[grpc-default-executor-0] INFO data_plane.create_data_channel - Creating channel for localhost:46119
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client connected.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_1:0 
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_17:0 
[grpc-default-executor-0] 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) (6ec745901397e5bbbe2c0c211628b951) 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) (6ec745901397e5bbbe2c0c211628b951).
[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) (6ec745901397e5bbbe2c0c211628b951) [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 Source: Custom Source -> 14Create/Impulse.None/beam:env:docker:v1:0 -> ToKeyedWorkItem 6ec745901397e5bbbe2c0c211628b951.
[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) (6ec745901397e5bbbe2c0c211628b951) 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) (e3f82875dec77c422ca0b889ba081ef2) 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) (e3f82875dec77c422ca0b889ba081ef2).
[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) (e3f82875dec77c422ca0b889ba081ef2) [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 e3f82875dec77c422ca0b889ba081ef2.
[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) (e3f82875dec77c422ca0b889ba081ef2) switched from RUNNING to FINISHED.
[grpc-default-executor-0] 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) (3ef2a687adaf3237f66721b58ecc9f4e) 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) (3ef2a687adaf3237f66721b58ecc9f4e).
[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) (3ef2a687adaf3237f66721b58ecc9f4e) [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 Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey -> 72Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 -> ToKeyedWorkItem 3ef2a687adaf3237f66721b58ecc9f4e.
[flink-akka.actor.default-dispatcher-2] 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) (3ef2a687adaf3237f66721b58ecc9f4e) switched from RUNNING to FINISHED.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/write/ref_PCollection_PCollection_24:1:0 
[grpc-default-executor-0] 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) (354c71ec39ffa2970ba6d687aecf9fda) 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) (354c71ec39ffa2970ba6d687aecf9fda).
[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) (354c71ec39ffa2970ba6d687aecf9fda) [FINISHED]
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) switched from RUNNING to 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 354c71ec39ffa2970ba6d687aecf9fda.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe).
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) [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 9659cf6bd27d3032aaebf3281ed5c3fe.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/beam:env:docker:v1:0 (1/1) (354c71ec39ffa2970ba6d687aecf9fda) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (9659cf6bd27d3032aaebf3281ed5c3fe) switched from RUNNING to FINISHED.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique name set for transform fn/read/ref_PCollection_PCollection_27:0 
[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] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-0] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-0] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-0] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-0] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-0] 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) (f7b397098ad7e30fc7d4a578cc123ebc) 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) (f7b397098ad7e30fc7d4a578cc123ebc).
[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) (f7b397098ad7e30fc7d4a578cc123ebc) [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 f7b397098ad7e30fc7d4a578cc123ebc.
[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/1) (f7b397098ad7e30fc7d4a578cc123ebc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1540275057.97 (38457691ce647fc0a1510cd47d8f2702) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 38457691ce647fc0a1510cd47d8f2702.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 38457691ce647fc0a1510cd47d8f2702 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job test_windowing_1540275057.97(38457691ce647fc0a1510cd47d8f2702).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 38457691ce647fc0a1510cd47d8f2702.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 40fe32e471ebdb31d5e78560c8bdcf31: 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-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager b92f5bd83dc939d43129d16f1b9a4579@akka://flink/user/jobmanager_39 for job 38457691ce647fc0a1510cd47d8f2702 from the resource manager.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 38457691ce647fc0a1510cd47d8f2702 with leader id b92f5bd83dc939d43129d16f1b9a4579 lost leadership.
[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/dispatcherde8f197f-f1d7-4179-b97d-ca2973c99f4b.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherde8f197f-f1d7-4179-b97d-ca2973c99f4b.
[flink-akka.actor.default-dispatcher-2] 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{6ee813aac6e1655c6c45e0c526d0bb51}, jobId: 38457691ce647fc0a1510cd47d8f2702).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 38457691ce647fc0a1510cd47d8f2702 from job leader monitoring.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 38457691ce647fc0a1510cd47d8f2702.
[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-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager d4b686d780d258c2a905fda446e4d814 from the SlotManager.
[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-93bf96a5-0b45-497f-8d41-66a9030a23bd
[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-4] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcherde8f197f-f1d7-4179-b97d-ca2973c99f4b.
[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-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:33095
[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 1956 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@4499e20b
.
----------------------------------------------------------------------
Ran 26 tests in 76.229s

OK (skipped=8)
Segmentation fault (core dumped)

> Task :beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 1 mins 18.707 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: 367

* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER'.
> 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.

* 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 10m 54s
61 actionable tasks: 56 executed, 4 from cache, 1 up-to-date

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

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

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/460/display/redirect>

------------------------------------------
[...truncated 451.03 KB...]
Collecting tensorflow==1.11.0 (from -r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/36/3a/59e68f1ece4eaa73726efebd8ba82b4b59ce31e2d69136297c8d81764892/tensorflow-1.11.0-cp27-cp27mu-manylinux1_x86_64.whl (63.0MB)
Collecting six>=1.5.2 (from grpcio==1.15.0->-r /tmp/base_image_requirements.txt (line 33))
  Downloading https://files.pythonhosted.org/packages/67/4b/141a581104b1f6397bfa78ac9d43d8ad29a7ca43ea90a2d863fe3056e86a/six-1.11.0-py2.py3-none-any.whl
Collecting enum34>=1.0.4 (from grpcio==1.15.0->-r /tmp/base_image_requirements.txt (line 33))
  Downloading https://files.pythonhosted.org/packages/c5/db/e56e6b4bbac7c4a06de1c50de6fe1ef3810018ae11732a50f15f62c7d050/enum34-1.1.6-py2-none-any.whl
Collecting docopt (from hdfs==2.1.0->-r /tmp/base_image_requirements.txt (line 34))
  Downloading https://files.pythonhosted.org/packages/a2/55/8f8cab2afd404cf578136ef2cc5dfb50baa1761b68c9da1fb1e4eed343c9/docopt-0.6.2.tar.gz
Collecting requests>=2.7.0 (from hdfs==2.1.0->-r /tmp/base_image_requirements.txt (line 34))
  Downloading https://files.pythonhosted.org/packages/f1/ca/10332a30cb25b627192b4ea272c351bce3ca1091e541245cccbace6051d8/requests-2.20.0-py2.py3-none-any.whl (60kB)
Collecting funcsigs>=1; python_version < "3.3" (from mock==2.0.0->-r /tmp/base_image_requirements.txt (line 36))
  Downloading https://files.pythonhosted.org/packages/69/cb/f5be453359271714c01b9bd06126eaf2e368f1fddfff30818754b5ac2328/funcsigs-1.0.2-py2.py3-none-any.whl
Collecting pbr>=0.11 (from mock==2.0.0->-r /tmp/base_image_requirements.txt (line 36))
  Downloading https://files.pythonhosted.org/packages/ca/81/4e8230c5648ea6d85d90ec3babc3dcc1c46d890f2f26b3e2b374819274dd/pbr-5.0.0-py2.py3-none-any.whl (106kB)
Collecting pyasn1>=0.1.7 (from oauth2client==3.0.0->-r /tmp/base_image_requirements.txt (line 37))
  Downloading https://files.pythonhosted.org/packages/d1/a1/7790cc85db38daa874f6a2e6308131b9953feb1367f2ae2d1123bb93a9f5/pyasn1-0.4.4-py2.py3-none-any.whl (72kB)
Collecting pyasn1-modules>=0.0.5 (from oauth2client==3.0.0->-r /tmp/base_image_requirements.txt (line 37))
  Downloading https://files.pythonhosted.org/packages/19/02/fa63f7ba30a0d7b925ca29d034510fc1ffde53264b71b4155022ddf3ab5d/pyasn1_modules-0.2.2-py2.py3-none-any.whl (62kB)
Collecting rsa>=3.1.4 (from oauth2client==3.0.0->-r /tmp/base_image_requirements.txt (line 37))
  Downloading https://files.pythonhosted.org/packages/02/e5/38518af393f7c214357079ce67a317307936896e961e35450b70fad2a9cf/rsa-4.0-py2.py3-none-any.whl
Collecting fasteners>=0.14 (from google-apitools==0.5.20->-r /tmp/base_image_requirements.txt (line 48))
  Downloading https://files.pythonhosted.org/packages/14/3a/096c7ad18e102d4f219f5dd15951f9728ca5092a3385d2e8f79a7c1e1017/fasteners-0.14.1-py2.py3-none-any.whl
Collecting grpc-google-iam-v1<0.12dev,>=0.11.1 (from google-cloud-pubsub==0.35.4->-r /tmp/base_image_requirements.txt (line 50))
  Downloading https://files.pythonhosted.org/packages/9b/28/f26f67381cb23e81271b8d66c00a846ad9d25a909ae1ae1df8222fad2744/grpc-google-iam-v1-0.11.4.tar.gz
Collecting google-api-core[grpc]<2.0.0dev,>=0.1.3 (from google-cloud-pubsub==0.35.4->-r /tmp/base_image_requirements.txt (line 50))
  Downloading https://files.pythonhosted.org/packages/e4/3a/f9a5746a4d1c03e4ae6d4fdea0b4275cd80320dde7b2a44439cf9e913e33/google_api_core-1.5.0-py2.py3-none-any.whl (62kB)
Collecting google-cloud-core<0.26dev,>=0.25.0 (from google-cloud-bigquery==0.25.0->-r /tmp/base_image_requirements.txt (line 51))
  Downloading https://files.pythonhosted.org/packages/ef/dd/00e90bd1f6788f06ca5ea83a0ec8dd76350b38303bb8f09d2bf692eb1294/google_cloud_core-0.25.0-py2.py3-none-any.whl (52kB)
Collecting googleapis-common-protos<2.0dev,>=1.5.2 (from proto-google-cloud-datastore-v1==0.90.4->-r /tmp/base_image_requirements.txt (line 52))
  Downloading https://files.pythonhosted.org/packages/00/03/d25bed04ec8d930bcfa488ba81a2ecbf7eb36ae3ffd7e8f5be0d036a89c9/googleapis-common-protos-1.5.3.tar.gz
Collecting python-dateutil>=2.5.0 (from pandas==0.23.4->-r /tmp/base_image_requirements.txt (line 61))
  Downloading https://files.pythonhosted.org/packages/cf/f5/af2b09c957ace60dcfac112b669c45c8c97e32f94aa8b56da4c6d1682825/python_dateutil-2.7.3-py2.py3-none-any.whl (211kB)
Collecting astor>=0.6.0 (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/35/6b/11530768cac581a12952a2aad00e1526b89d242d0b9f59534ef6e6a1752f/astor-0.7.1-py2.py3-none-any.whl
Collecting gast>=0.2.0 (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/5c/78/ff794fcae2ce8aa6323e789d1f8b3b7765f601e7702726f430e814822b96/gast-0.2.0.tar.gz
Collecting keras-applications>=1.0.5 (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/3f/c4/2ff40221029f7098d58f8d7fb99b97e8100f3293f9856f0fb5834bef100b/Keras_Applications-1.0.6-py2.py3-none-any.whl (44kB)
Collecting keras-preprocessing>=1.0.3 (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/fc/94/74e0fa783d3fc07e41715973435dd051ca89c550881b3454233c39c73e69/Keras_Preprocessing-1.0.5-py2.py3-none-any.whl
Collecting absl-py>=0.1.6 (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/fa/ef/1fa0376563b1e0495301ada8e881d88b7ebfda433f6b31f44447fe6ef795/absl-py-0.6.0.tar.gz (93kB)
Collecting backports.weakref>=1.0rc1 (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/88/ec/f598b633c3d5ffe267aaada57d961c94fdfa183c5c3ebda2b6d151943db6/backports.weakref-1.0.post1-py2.py3-none-any.whl
Collecting termcolor>=1.1.0 (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/8a/48/a76be51647d0eb9f10e2a4511bf3ffb8cc1e6b14e9e4fab46173aa79f981/termcolor-1.1.0.tar.gz
Collecting tensorboard<1.12.0,>=1.11.0 (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/76/f9/e62022d00940e4df9a629d6bfe42eb28907bb35808db62bb9e8b69ea5ef3/tensorboard-1.11.0-py2-none-any.whl (3.0MB)
Requirement already satisfied: wheel in /usr/local/lib/python2.7/site-packages (from tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65)) (0.32.1)
Collecting chardet<3.1.0,>=3.0.2 (from requests>=2.7.0->hdfs==2.1.0->-r /tmp/base_image_requirements.txt (line 34))
  Downloading https://files.pythonhosted.org/packages/bc/a9/01ffebfb562e4274b6487b4bb1ddec7ca55ec7510b22e4c51f14098443b8/chardet-3.0.4-py2.py3-none-any.whl (133kB)
Collecting certifi>=2017.4.17 (from requests>=2.7.0->hdfs==2.1.0->-r /tmp/base_image_requirements.txt (line 34))
  Downloading https://files.pythonhosted.org/packages/56/9d/1d02dd80bc4cd955f98980f28c5ee2200e1209292d5f9e9cc8d030d18655/certifi-2018.10.15-py2.py3-none-any.whl (146kB)
Collecting urllib3<1.25,>=1.21.1 (from requests>=2.7.0->hdfs==2.1.0->-r /tmp/base_image_requirements.txt (line 34))
  Downloading https://files.pythonhosted.org/packages/8c/4b/5cbc4cb46095f369117dcb751821e1bef9dd86a07c968d8757e9204c324c/urllib3-1.24-py2.py3-none-any.whl (117kB)
Collecting idna<2.8,>=2.5 (from requests>=2.7.0->hdfs==2.1.0->-r /tmp/base_image_requirements.txt (line 34))
  Downloading https://files.pythonhosted.org/packages/4b/2a/0276479a4b3caeb8a8c1af2f8e4355746a97fab05a372e4a2c6a6b876165/idna-2.7-py2.py3-none-any.whl (58kB)
Collecting monotonic>=0.1 (from fasteners>=0.14->google-apitools==0.5.20->-r /tmp/base_image_requirements.txt (line 48))
  Downloading https://files.pythonhosted.org/packages/ac/aa/063eca6a416f397bd99552c534c6d11d57f58f2e94c14780f3bbf818c4cf/monotonic-1.5-py2.py3-none-any.whl
Collecting google-auth<2.0.0dev,>=0.4.0 (from google-api-core[grpc]<2.0.0dev,>=0.1.3->google-cloud-pubsub==0.35.4->-r /tmp/base_image_requirements.txt (line 50))
  Downloading https://files.pythonhosted.org/packages/58/cb/96dbb4e50e7a9d856e89cc9c8e36ab1055f9774f7d85f37e2156c1d79d9f/google_auth-1.5.1-py2.py3-none-any.whl (65kB)
Collecting google-auth-httplib2 (from google-cloud-core<0.26dev,>=0.25.0->google-cloud-bigquery==0.25.0->-r /tmp/base_image_requirements.txt (line 51))
  Downloading https://files.pythonhosted.org/packages/33/49/c814d6d438b823441552198f096fcd0377fd6c88714dbed34f1d3c8c4389/google_auth_httplib2-0.0.3-py2.py3-none-any.whl
Collecting h5py (from keras-applications>=1.0.5->tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/33/0c/1c5dfa85e05052aa5f50969d87c67a2128dc39a6f8ce459a503717e56bd0/h5py-2.8.0-cp27-cp27mu-manylinux1_x86_64.whl (2.7MB)
Collecting markdown>=2.6.8 (from tensorboard<1.12.0,>=1.11.0->tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/7a/6b/5600647404ba15545ec37d2f7f58844d690baf2f81f3a60b862e48f29287/Markdown-3.0.1-py2.py3-none-any.whl (89kB)
Collecting werkzeug>=0.11.10 (from tensorboard<1.12.0,>=1.11.0->tensorflow==1.11.0->-r /tmp/base_image_requirements.txt (line 65))
  Downloading https://files.pythonhosted.org/packages/20/c4/12e3e56473e52375aa29c4764e70d1b8f3efa6682bef8d0aae04fe335243/Werkzeug-0.14.1-py2.py3-none-any.whl (322kB)
Collecting cachetools>=2.0.0 (from google-auth<2.0.0dev,>=0.4.0->google-api-core[grpc]<2.0.0dev,>=0.1.3->google-cloud-pubsub==0.35.4->-r /tmp/base_image_requirements.txt (line 50))
  Downloading https://files.pythonhosted.org/packages/0a/58/cbee863250b31d80f47401d04f34038db6766f95dea1cc909ea099c7e571/cachetools-2.1.0-py2.py3-none-any.whl
Building wheels for collected packages: avro, fastavro, crcmod, dill, future, hdfs, httplib2, oauth2client, pyvcf, pyyaml, typing, googledatastore, proto-google-cloud-datastore-v1, python-snappy, python-gflags, docopt, grpc-google-iam-v1, googleapis-common-protos, gast, absl-py, termcolor
  Running setup.py bdist_wheel for avro: started
  Running setup.py bdist_wheel for avro: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/bf/0b/75/1b3517b7d36ddc8ba5d22c0df5eb01e83979f34420066d643e
  Running setup.py bdist_wheel for fastavro: started
  Running setup.py bdist_wheel for fastavro: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/19/eb/58/a3b86f4ae93b28c5dd23ece0cef5f5af242f4fc9a22afbe55b
  Running setup.py bdist_wheel for crcmod: started
  Running setup.py bdist_wheel for crcmod: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/50/24/4d/4580ca4a299f1ad6fd63443e6e584cb21e9a07988e4aa8daac
  Running setup.py bdist_wheel for dill: started
  Running setup.py bdist_wheel for dill: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/e2/5d/17/f87cb7751896ac629b435a8696f83ee75b11029f5d6f6bda72
  Running setup.py bdist_wheel for future: started
  Running setup.py bdist_wheel for future: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/bf/c9/a3/c538d90ef17cf7823fa51fc701a7a7a910a80f6a405bf15b1a
  Running setup.py bdist_wheel for hdfs: started
  Running setup.py bdist_wheel for hdfs: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/8c/89/59/b95e6bf2d5957541862f2cd109a052f26b61dc2fad2f04a1b4
  Running setup.py bdist_wheel for httplib2: started
  Running setup.py bdist_wheel for httplib2: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/36/f2/49/5adbf90fba31e02a7784e1147d7f8b6c4af3718739e568c8cb
  Running setup.py bdist_wheel for oauth2client: started
  Running setup.py bdist_wheel for oauth2client: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/48/f7/87/b932f09c6335dbcf45d916937105a372ab14f353a9ca431d7d
  Running setup.py bdist_wheel for pyvcf: started
  Running setup.py bdist_wheel for pyvcf: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/81/91/41/3272543c0b9c61da9c525f24ee35bae6fe8f60d4858c66805d
  Running setup.py bdist_wheel for pyyaml: started
  Running setup.py bdist_wheel for pyyaml: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/03/05/65/bdc14f2c6e09e82ae3e0f13d021e1b6b2481437ea2f207df3f
  Running setup.py bdist_wheel for typing: started
  Running setup.py bdist_wheel for typing: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/68/f9/c6/c4d6004ab42e39c63114793eb3d652805ba01b9a9ca37c4a1b
  Running setup.py bdist_wheel for googledatastore: started
  Running setup.py bdist_wheel for googledatastore: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/93/fa/12/99c490525fff40bcd240504f694bd02848479bc2debc31daae
  Running setup.py bdist_wheel for proto-google-cloud-datastore-v1: started
  Running setup.py bdist_wheel for proto-google-cloud-datastore-v1: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/bd/ce/33/8b769968db3761c42c7a91d8a0dbbafc50acfa0750866c8abd
  Running setup.py bdist_wheel for python-snappy: started
  Running setup.py bdist_wheel for python-snappy: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/e0/fe/5d/0f4592c9e217799cf3db4be1d2e0cb7a2795345777a09b1e80
  Running setup.py bdist_wheel for python-gflags: started
  Running setup.py bdist_wheel for python-gflags: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/43/7e/90/b5dfc39cdf0376f79174f6923974d599d4afcc0192cb5208e2
  Running setup.py bdist_wheel for docopt: started
  Running setup.py bdist_wheel for docopt: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/9b/04/dd/7daf4150b6d9b12949298737de9431a324d4b797ffd63f526e
  Running setup.py bdist_wheel for grpc-google-iam-v1: started
  Running setup.py bdist_wheel for grpc-google-iam-v1: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/b6/c6/31/c20321a5a3fde456fc375b7c2814135e6e98bc0d74c40239d9
  Running setup.py bdist_wheel for googleapis-common-protos: started
  Running setup.py bdist_wheel for googleapis-common-protos: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/62/45/af/649bbf07b6595fda010be1bda667cd56d0444d07afc6f8b687
  Running setup.py bdist_wheel for gast: started
  Running setup.py bdist_wheel for gast: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/9a/1f/0e/3cde98113222b853e98fc0a8e9924480a3e25f1b4008cedb4f
  Running setup.py bdist_wheel for absl-py: started
  Running setup.py bdist_wheel for absl-py: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/91/3f/fc/04598e99d64928bec676e07245b132e985df067cf5d469c460
  Running setup.py bdist_wheel for termcolor: started
  Running setup.py bdist_wheel for termcolor: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/7c/06/54/bc84598ba1daf8f970247f550b175aaaee85f68b4b0c5ab2c6
Successfully built avro fastavro crcmod dill future hdfs httplib2 oauth2client pyvcf pyyaml typing googledatastore proto-google-cloud-datastore-v1 python-snappy python-gflags docopt grpc-google-iam-v1 googleapis-common-protos gast absl-py termcolor
google-api-core 1.5.0 has requirement futures>=3.2.0; python_version < "3.2", but you'll have futures 3.1.1 which is incompatible.
Installing collected packages: avro, fastavro, crcmod, dill, future, futures, six, enum34, grpcio, docopt, chardet, certifi, urllib3, idna, requests, hdfs, httplib2, funcsigs, pbr, mock, pyasn1, pyasn1-modules, rsa, oauth2client, setuptools, protobuf, pytz, pyvcf, pyyaml, typing, nose, monotonic, fasteners, google-apitools, googleapis-common-protos, proto-google-cloud-datastore-v1, googledatastore, grpc-google-iam-v1, cachetools, google-auth, google-api-core, google-cloud-pubsub, google-auth-httplib2, google-cloud-core, google-cloud-bigquery, cython, python-snappy, numpy, scipy, python-dateutil, pandas, protorpc, python-gflags, astor, gast, h5py, keras-applications, keras-preprocessing, absl-py, backports.weakref, termcolor, markdown, werkzeug, tensorboard, tensorflow
  Found existing installation: setuptools 40.4.3
    Uninstalling setuptools-40.4.3:
      Successfully uninstalled setuptools-40.4.3
Successfully installed absl-py-0.6.0 astor-0.7.1 avro-1.8.2 backports.weakref-1.0.post1 cachetools-2.1.0 certifi-2018.10.15 chardet-3.0.4 crcmod-1.7 cython-0.28.1 dill-0.2.8.2 docopt-0.6.2 enum34-1.1.6 fastavro-0.21.4 fasteners-0.14.1 funcsigs-1.0.2 future-0.16.0 futures-3.1.1 gast-0.2.0 google-api-core-1.5.0 google-apitools-0.5.20 google-auth-1.5.1 google-auth-httplib2-0.0.3 google-cloud-bigquery-0.25.0 google-cloud-core-0.25.0 google-cloud-pubsub-0.35.4 googleapis-common-protos-1.5.3 googledatastore-7.0.1 grpc-google-iam-v1-0.11.4 grpcio-1.15.0 h5py-2.8.0 hdfs-2.1.0 httplib2-0.9.2 idna-2.7 keras-applications-1.0.6 keras-preprocessing-1.0.5 markdown-3.0.1 mock-2.0.0 monotonic-1.5 nose-1.3.7 numpy-1.15.2 oauth2client-3.0.0 pandas-0.23.4 pbr-5.0.0 proto-google-cloud-datastore-v1-0.90.4 protobuf-3.6.1 protorpc-0.11.1 pyasn1-0.4.4 pyasn1-modules-0.2.2 python-dateutil-2.7.3 python-gflags-3.0.6 python-snappy-0.5.3 pytz-2018.4 pyvcf-0.6.8 pyyaml-3.12 requests-2.20.0 rsa-4.0 scipy-1.1.0 setuptools-39.1.0 six-1.11.0 tensorboard-1.11.0 tensorflow-1.11.0 termcolor-1.1.0 typing-3.6.1 urllib3-1.24 werkzeug-0.14.1
Verified fast protobuf used.
 ---> 0cc705e6bc06
Removing intermediate container 626133ef0231
Step 6/9 : COPY target/apache-beam.tar.gz /opt/apache/beam/tars/
 ---> a40de28f42fc
Removing intermediate container c181fd9cc67d
Step 7/9 : RUN pip install /opt/apache/beam/tars/apache-beam.tar.gz[gcp] &&     rm -rf /root/.cache/pip
 ---> Running in 549dedeb253b
Processing /opt/apache/beam/tars/apache-beam.tar.gz
Requirement already satisfied: crcmod<2.0,>=1.7 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (1.7)
Requirement already satisfied: dill<=0.2.8.2,>=0.2.6 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.2.8.2)
Requirement already satisfied: fastavro<0.22,>=0.21.4 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.21.4)
Requirement already satisfied: grpcio<2,>=1.8 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (1.15.0)
Requirement already satisfied: hdfs<3.0.0,>=2.1.0 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (2.1.0)
Requirement already satisfied: httplib2<=0.11.3,>=0.8 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.9.2)
Requirement already satisfied: mock<3.0.0,>=1.0.1 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (2.0.0)
Requirement already satisfied: oauth2client<5,>=2.0.1 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (3.0.0)
Requirement already satisfied: protobuf<4,>=3.5.0.post1 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (3.6.1)
Collecting pydot<1.3,>=1.2.0 (from apache-beam==2.9.0.dev0)
  Downloading https://files.pythonhosted.org/packages/c3/f1/e61d6dfe6c1768ed2529761a68f70939e2569da043e9f15a8d84bf56cadf/pydot-1.2.4.tar.gz (132kB)
Requirement already satisfied: pytz<=2018.4,>=2018.3 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (2018.4)
Requirement already satisfied: pyyaml<4.0.0,>=3.12 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (3.12)
Requirement already satisfied: pyvcf<0.7.0,>=0.6.8 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.6.8)
Requirement already satisfied: futures<4.0.0,>=3.1.1 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (3.1.1)
Requirement already satisfied: future<1.0.0,>=0.16.0 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.16.0)
Requirement already satisfied: avro<2.0.0,>=1.8.1 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (1.8.2)
Requirement already satisfied: typing<3.7.0,>=3.6.0 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (3.6.1)
Requirement already satisfied: google-apitools<=0.5.20,>=0.5.18 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.5.20)
Requirement already satisfied: proto-google-cloud-datastore-v1<=0.90.4,>=0.90.0 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.90.4)
Requirement already satisfied: google-cloud-pubsub==0.35.4 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.35.4)
Requirement already satisfied: google-cloud-bigquery==0.25.0 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (0.25.0)
Requirement already satisfied: googledatastore==7.0.1 in /usr/local/lib/python2.7/site-packages (from apache-beam==2.9.0.dev0) (7.0.1)
Requirement already satisfied: six>=1.5.2 in /usr/local/lib/python2.7/site-packages (from grpcio<2,>=1.8->apache-beam==2.9.0.dev0) (1.11.0)
Requirement already satisfied: enum34>=1.0.4 in /usr/local/lib/python2.7/site-packages (from grpcio<2,>=1.8->apache-beam==2.9.0.dev0) (1.1.6)
Requirement already satisfied: requests>=2.7.0 in /usr/local/lib/python2.7/site-packages (from hdfs<3.0.0,>=2.1.0->apache-beam==2.9.0.dev0) (2.20.0)
Requirement already satisfied: docopt in /usr/local/lib/python2.7/site-packages (from hdfs<3.0.0,>=2.1.0->apache-beam==2.9.0.dev0) (0.6.2)
Requirement already satisfied: funcsigs>=1; python_version < "3.3" in /usr/local/lib/python2.7/site-packages (from mock<3.0.0,>=1.0.1->apache-beam==2.9.0.dev0) (1.0.2)
Requirement already satisfied: pbr>=0.11 in /usr/local/lib/python2.7/site-packages (from mock<3.0.0,>=1.0.1->apache-beam==2.9.0.dev0) (5.0.0)
Requirement already satisfied: pyasn1>=0.1.7 in /usr/local/lib/python2.7/site-packages (from oauth2client<5,>=2.0.1->apache-beam==2.9.0.dev0) (0.4.4)
Requirement already satisfied: pyasn1-modules>=0.0.5 in /usr/local/lib/python2.7/site-packages (from oauth2client<5,>=2.0.1->apache-beam==2.9.0.dev0) (0.2.2)
Requirement already satisfied: rsa>=3.1.4 in /usr/local/lib/python2.7/site-packages (from oauth2client<5,>=2.0.1->apache-beam==2.9.0.dev0) (4.0)
Requirement already satisfied: setuptools in /usr/local/lib/python2.7/site-packages (from protobuf<4,>=3.5.0.post1->apache-beam==2.9.0.dev0) (39.1.0)
Collecting pyparsing>=2.1.4 (from pydot<1.3,>=1.2.0->apache-beam==2.9.0.dev0)
  Downloading https://files.pythonhosted.org/packages/2b/4a/f06b45ab9690d4c37641ec776f7ad691974f4cf6943a73267475b05cbfca/pyparsing-2.2.2-py2.py3-none-any.whl (57kB)
Requirement already satisfied: fasteners>=0.14 in /usr/local/lib/python2.7/site-packages (from google-apitools<=0.5.20,>=0.5.18->apache-beam==2.9.0.dev0) (0.14.1)
Requirement already satisfied: googleapis-common-protos<2.0dev,>=1.5.2 in /usr/local/lib/python2.7/site-packages (from proto-google-cloud-datastore-v1<=0.90.4,>=0.90.0->apache-beam==2.9.0.dev0) (1.5.3)
Requirement already satisfied: grpc-google-iam-v1<0.12dev,>=0.11.1 in /usr/local/lib/python2.7/site-packages (from google-cloud-pubsub==0.35.4->apache-beam==2.9.0.dev0) (0.11.4)
Requirement already satisfied: google-api-core[grpc]<2.0.0dev,>=0.1.3 in /usr/local/lib/python2.7/site-packages (from google-cloud-pubsub==0.35.4->apache-beam==2.9.0.dev0) (1.5.0)
Requirement already satisfied: google-cloud-core<0.26dev,>=0.25.0 in /usr/local/lib/python2.7/site-packages (from google-cloud-bigquery==0.25.0->apache-beam==2.9.0.dev0) (0.25.0)
Requirement already satisfied: chardet<3.1.0,>=3.0.2 in /usr/local/lib/python2.7/site-packages (from requests>=2.7.0->hdfs<3.0.0,>=2.1.0->apache-beam==2.9.0.dev0) (3.0.4)
Requirement already satisfied: certifi>=2017.4.17 in /usr/local/lib/python2.7/site-packages (from requests>=2.7.0->hdfs<3.0.0,>=2.1.0->apache-beam==2.9.0.dev0) (2018.10.15)
Requirement already satisfied: urllib3<1.25,>=1.21.1 in /usr/local/lib/python2.7/site-packages (from requests>=2.7.0->hdfs<3.0.0,>=2.1.0->apache-beam==2.9.0.dev0) (1.24)
Requirement already satisfied: idna<2.8,>=2.5 in /usr/local/lib/python2.7/site-packages (from requests>=2.7.0->hdfs<3.0.0,>=2.1.0->apache-beam==2.9.0.dev0) (2.7)
Requirement already satisfied: monotonic>=0.1 in /usr/local/lib/python2.7/site-packages (from fasteners>=0.14->google-apitools<=0.5.20,>=0.5.18->apache-beam==2.9.0.dev0) (1.5)
Requirement already satisfied: google-auth<2.0.0dev,>=0.4.0 in /usr/local/lib/python2.7/site-packages (from google-api-core[grpc]<2.0.0dev,>=0.1.3->google-cloud-pubsub==0.35.4->apache-beam==2.9.0.dev0) (1.5.1)
Requirement already satisfied: google-auth-httplib2 in /usr/local/lib/python2.7/site-packages (from google-cloud-core<0.26dev,>=0.25.0->google-cloud-bigquery==0.25.0->apache-beam==2.9.0.dev0) (0.0.3)
Requirement already satisfied: cachetools>=2.0.0 in /usr/local/lib/python2.7/site-packages (from google-auth<2.0.0dev,>=0.4.0->google-api-core[grpc]<2.0.0dev,>=0.1.3->google-cloud-pubsub==0.35.4->apache-beam==2.9.0.dev0) (2.1.0)
Building wheels for collected packages: apache-beam, pydot
  Running setup.py bdist_wheel for apache-beam: started
  Running setup.py bdist_wheel for apache-beam: still running...
  Running setup.py bdist_wheel for apache-beam: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/4b/7d/dd/a19128d4b755625dce0a4a284246bffb9f82e49379d8e9d5f5
  Running setup.py bdist_wheel for pydot: started
  Running setup.py bdist_wheel for pydot: finished with status 'done'
  Stored in directory: /root/.cache/pip/wheels/6a/a5/14/25541ebcdeaf97a37b6d05c7ff15f5bd20f5e91b99d313e5b4
Successfully built apache-beam pydot
Installing collected packages: pyparsing, pydot, apache-beam
Successfully installed apache-beam-2.9.0.dev0 pydot-1.2.4 pyparsing-2.2.2
 ---> 4a8b4cfed551
Removing intermediate container 549dedeb253b
Step 8/9 : ADD target/launcher/linux_amd64/boot /opt/apache/beam/
 ---> 04cdac6f2489
Removing intermediate container 7cf1f9274666
Step 9/9 : ENTRYPOINT /opt/apache/beam/boot
 ---> Running in fbe82709b03a
 ---> 10c912f8737c
Removing intermediate container fbe82709b03a
Successfully built 10c912f8737c
Successfully tagged jenkins-docker-apache.bintray.io/beam/python:latest
:beam-sdks-python-container:docker (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 3 mins 41.834 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: 419

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

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

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure