Build failed in Jenkins: beam_PreCommit_Portable_Python_Cron #449

Apache Jenkins Server Sat, 23 Mar 2019 11:18:25 -0700

See 
<https://builds.apache.org/job/beam_PreCommit_Portable_Python_Cron/449/display/redirect>


------------------------------------------
[...truncated 807.78 KB...]
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) 
(dc40bee9758d7987ad3c94954243ee6f).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) 
(dc40bee9758d7987ad3c94954243ee6f) switched from RUNNING to CANCELING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
(41988949f06c54419d6be701c4f4ec5e) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task 
code ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2) (dc40bee9758d7987ad3c94954243ee6f).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) 
(52940c31fb5bc11c3711a413b0d5e8ee).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) 
(52940c31fb5bc11c3711a413b0d5e8ee) switched from RUNNING to CANCELING.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task 
code ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map 
(1/2) (52940c31fb5bc11c3711a413b0d5e8ee).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(5e4cb4f1548193a7cd19393153af556c).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(5e4cb4f1548193a7cd19393153af556c) switched from RUNNING to CANCELING.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task 
code ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map 
(2/2) (5e4cb4f1548193a7cd19393153af556c).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Discarding the results 
produced by task execution 890fee020aa7eac6887286a5133ad2a0.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) 
(de7a6eb0caf29d6601fcccbd878700d4).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) 
(de7a6eb0caf29d6601fcccbd878700d4) switched from RUNNING to CANCELING.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task 
code ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2) (de7a6eb0caf29d6601fcccbd878700d4).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) 
(3d4f3bb795ef6fca42278fa627ed5588).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) 
(3d4f3bb795ef6fca42278fa627ed5588) switched from RUNNING to CANCELING.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task 
code ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2) (3d4f3bb795ef6fca42278fa627ed5588).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (1/2) 
(767254dfc7b7118823f238686c5a275e).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (1/2) 
(767254dfc7b7118823f238686c5a275e) switched from RUNNING to CANCELING.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task 
code ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(1/2) (767254dfc7b7118823f238686c5a275e).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) 
(202a1db8407916e64deb299049f7ea52).
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) 
(202a1db8407916e64deb299049f7ea52) switched from RUNNING to CANCELING.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task 
code ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2) (202a1db8407916e64deb299049f7ea52).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) 
(202a1db8407916e64deb299049f7ea52) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2) (202a1db8407916e64deb299049f7ea52).
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) 
(cacd3debac5378b567ba86a5bb844ffc) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) 
(cacd3debac5378b567ba86a5bb844ffc).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) 
(3d4f3bb795ef6fca42278fa627ed5588) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2) (3d4f3bb795ef6fca42278fa627ed5588).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) 
(202a1db8407916e64deb299049f7ea52) [CANCELED]
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) 
(cacd3debac5378b567ba86a5bb844ffc) [CANCELED]
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(5e4cb4f1548193a7cd19393153af556c) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(5e4cb4f1548193a7cd19393153af556c).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) 
(dc40bee9758d7987ad3c94954243ee6f) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2) (dc40bee9758d7987ad3c94954243ee6f).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) 
(dc40bee9758d7987ad3c94954243ee6f) [CANCELED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
202a1db8407916e64deb299049f7ea52.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (1/2) 
(c6efdcdf8f80551bb2d76741e65edf29) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (1/2) 
(b8ad47a2fcd3f0c962b06cc8ff8ec963) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(1/2) (b8ad47a2fcd3f0c962b06cc8ff8ec963).
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) 
(512dda05a2b3e76126b8f36a84e191cc) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) 
(512dda05a2b3e76126b8f36a84e191cc).
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) 
(52940c31fb5bc11c3711a413b0d5e8ee) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (1/2) 
(b8ad47a2fcd3f0c962b06cc8ff8ec963) [CANCELED]
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) 
(512dda05a2b3e76126b8f36a84e191cc) [CANCELED]
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) 
(52940c31fb5bc11c3711a413b0d5e8ee).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(1/2) (c6efdcdf8f80551bb2d76741e65edf29).
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(5e4cb4f1548193a7cd19393153af556c) [CANCELED]
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) 
(3d4f3bb795ef6fca42278fa627ed5588) [CANCELED]
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (1/2) 
(767254dfc7b7118823f238686c5a275e) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(1/2) (767254dfc7b7118823f238686c5a275e).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (1/2) 
(767254dfc7b7118823f238686c5a275e) [CANCELED]
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) 
(202a1db8407916e64deb299049f7ea52) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) 
(de7a6eb0caf29d6601fcccbd878700d4) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (2/2) 
(4ff8f7b639a69b669c102e7c211cf16f) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2) (de7a6eb0caf29d6601fcccbd878700d4).
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map 
cacd3debac5378b567ba86a5bb844ffc.
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) 
(52940c31fb5bc11c3711a413b0d5e8ee) [CANCELED]
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) 
(de7a6eb0caf29d6601fcccbd878700d4) [CANCELED]
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(2/2) (4ff8f7b639a69b669c102e7c211cf16f).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (1/2) 
(c6efdcdf8f80551bb2d76741e65edf29) [CANCELED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
dc40bee9758d7987ad3c94954243ee6f.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) 
(cacd3debac5378b567ba86a5bb844ffc) switched from CANCELING to CANCELED.
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (2/2) 
(4ff8f7b639a69b669c102e7c211cf16f) [CANCELED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
b8ad47a2fcd3f0c962b06cc8ff8ec963.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map 
512dda05a2b3e76126b8f36a84e191cc.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) 
(dc40bee9758d7987ad3c94954243ee6f) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map 
5e4cb4f1548193a7cd19393153af556c.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
767254dfc7b7118823f238686c5a275e.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (1/2) 
(b8ad47a2fcd3f0c962b06cc8ff8ec963) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
3d4f3bb795ef6fca42278fa627ed5588.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map 
52940c31fb5bc11c3711a413b0d5e8ee.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
de7a6eb0caf29d6601fcccbd878700d4.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
c6efdcdf8f80551bb2d76741e65edf29.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) 
(512dda05a2b3e76126b8f36a84e191cc) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state CANCELED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
4ff8f7b639a69b669c102e7c211cf16f.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(5e4cb4f1548193a7cd19393153af556c) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (1/2) 
(767254dfc7b7118823f238686c5a275e) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) 
(3d4f3bb795ef6fca42278fa627ed5588) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) 
(52940c31fb5bc11c3711a413b0d5e8ee) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) 
(de7a6eb0caf29d6601fcccbd878700d4) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (1/2) 
(c6efdcdf8f80551bb2d76741e65edf29) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (2/2) 
(4ff8f7b639a69b669c102e7c211cf16f) switched from CANCELING to CANCELED.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Try to restart or fail 
the job BeamApp-root-0323181758-2b12ff0e (3dadb5def6acdef61d3e304219ce4224) if 
no longer possible.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
BeamApp-root-0323181758-2b12ff0e (3dadb5def6acdef61d3e304219ce4224) switched 
from state FAILING to FAILED.
org.apache.beam.vendor.guava.v20_0.com.google.common.util.concurrent.UncheckedExecutionException:
 java.io.IOException: Received exit code 2 for command 'docker run -d 
--network=host --env=DOCKER_MAC_CONTAINER=null --rm 
jenkins-docker-apache.bintray.io/beam/python:latest --id=1 
--logging_endpoint=localhost:39843 --artifact_endpoint=localhost:45409 
--provision_endpoint=localhost:43973 --control_endpoint=localhost:46033'. 
stderr: runtime/cgo: pthread_create failed: Resource temporarily 
unavailableSIGABRT: abortPC=0x7fe8bee1bfff m=0goroutine 0 [idle]:goroutine 34 
[running]:runtime.systemstack_switch()    
/usr/local/go/src/runtime/asm_amd64.s:252 fp=0xc4204b2528 
sp=0xc4204b2520runtime.gcMarkTermination()    
/usr/local/go/src/runtime/mgc.go:1272 +0x380 fp=0xc4204b2720 
sp=0xc4204b2528runtime.gcMarkDone()        
/usr/local/go/src/runtime/mgc.go:1158 +0x21e fp=0xc4204b2748 
sp=0xc4204b2720runtime.gcBgMarkWorker(0xc42001aa00)        
/usr/local/go/src/runtime/mgc.go:1505 +0x2c2 fp=0xc4204b27b8 
sp=0xc4204b2748runtime.goexit()    /usr/local/go/src/runtime/asm_amd64.s:2086 
+0x1 fp=0xc4204b27c0 sp=0xc4204b27b8created by runtime.gcBgMarkStartWorkers  
/usr/local/go/src/runtime/mgc.go:1349 +0x98goroutine 1 
[select]:net/http.(*persistConn).roundTrip(0xc4202e1600, 0xc420015660, 0x0, 
0x0, 0x0)    /usr/local/go/src/net/http/transport.go:1840 
+0x93bnet/http.(*Transport).RoundTrip(0xc4200f6870, 0xc4204fe2d0, 0xc4200f6870, 
0x0, 0xc400000000) /usr/local/go/src/net/http/transport.go:380 
+0x4fanet/http.send(0xc4204fe2d0, 0x1516c20, 0xc4200f6870, 0x0, 0xc400000000, 
0x0, 0xc4204eee80, 0x416f5d, 0xc420038790)    
/usr/local/go/src/net/http/client.go:256 
+0x15fnet/http.(*Client).send(0xc42046d050, 0xc4204fe2d0, 0x0, 0x0, 0x0, 
0xc420038790, 0x0, 0x1)       /usr/local/go/src/net/http/client.go:146 
+0x102net/http.(*Client).doFollowingRedirects(0xc42046d050, 0xc4204fe2d0, 
0xee92f0, 0x4, 0xc4204fe101, 0x413cff)       
/usr/local/go/src/net/http/client.go:528 
+0x5e5net/http.(*Client).Do(0xc42046d050, 0xc4204fe2d0, 0xc420064100, 
0xc4204fe2d0, 0xc420064100)      /usr/local/go/src/net/http/client.go:187 
+0x11dgithub.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp.Do(0x7fe8bf6ec050,
 0xc420064100, 0xc42046d050, 0xc4204fe1e0, 0x0, 0x0, 0xd4f940)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp/ctxhttp.go:30
 +0x92github.com/docker/docker/client.(*Client).doRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc4204fe1e0, 0x18, 0x1514da0, 0xc420066150, 
0xc420011c80, 0xc4204fe1e0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:127 
+0x6egithub.com/docker/docker/client.(*Client).sendRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe44ce9, 0x4, 0xe552cf, 0x12, 0xc420010510, 
0x1514da0, 0xc420066150, ...)    
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:121 
+0xf4github.com/docker/docker/client.(*Client).post(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe552cf, 0x12, 0xc420010510, 0xda9140, 
0xc420014340, 0x0, 0x19, ...)        
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:45 
+0xfagithub.com/docker/docker/client.(*Client).ContainerCreate(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc42048e000, 0xc42003b400, 0xc420038010, 0x0, 
0x0, 0x0, 0x0, ...) 
/usr/src/docker/.gopath/src/github.com/docker/docker/client/container_create.go:45
 
+0x27fgithub.com/docker/docker/cli/command/container.createContainer(0x7fe8bf6ec050,
 0xc420064100, 0xc4203e5730, 0xc420014240, 0x0, 0x0, 0x0, 0x0, 0x0)      
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/create.go:188
 
+0x21fgithub.com/docker/docker/cli/command/container.runContainer(0xc4203e5730, 
0xc420395ce0, 0xc4203dd900, 0xc420014240, 0x0, 0x0)    
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:139
 +0x22fgithub.com/docker/docker/cli/command/container.runRun(0xc4203e5730, 
0xc4200ab3b0, 0xc420395ce0, 0xc4203dd900, 0x0, 0x0)     
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:93
 
+0x14agithub.com/docker/docker/cli/command/container.NewRunCommand.func1(0xc420404b40,
 0xc420463680, 0x6, 0xa, 0x0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:47
 
+0x10fgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).execute(0xc420404b40,
 0xc42008e020, 0xa, 0xa, 0xc420404b40, 0xc42008e020)  
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:646
 
+0x26dgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).ExecuteC(0xc4200b3d40,
 0xc4203e8240, 0xc420391e30, 0xc42008a4c8)      
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:742
 
+0x377github.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).Execute(0xc4200b3d40,
 0xc4200b3d40, 0x1517260)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:695
 +0x2bmain.main()      
/usr/src/docker/.gopath/src/github.com/docker/docker/cmd/docker/docker.go:169 
+0xcbgoroutine 17 [syscall, locked to thread]:runtime.goexit()    
/usr/local/go/src/runtime/asm_amd64.s:2086 +0x1goroutine 19 
[syscall]:os/signal.signal_recv(0x0)        
/usr/local/go/src/runtime/sigqueue.go:116 +0x157os/signal.loop()        
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22created by os/signal.init.1  
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41goroutine 22 [IO 
wait]:net.runtime_pollWait(0x7fe8bf73db60, 0x72, 0x3)       
/usr/local/go/src/runtime/netpoll.go:160 
+0x59net.(*pollDesc).wait(0xc42044afb0, 0x72, 0xc4200449d0, 0xc4200820a0)      
/usr/local/go/src/net/fd_poll_runtime.go:73 
+0x38net.(*pollDesc).waitRead(0xc42044afb0, 0x151a920, 0xc4200820a0)        
/usr/local/go/src/net/fd_poll_runtime.go:78 
+0x34net.(*netFD).Read(0xc42044af50, 0xc420470000, 0x1000, 0x1000, 0x0, 
0x151a920, 0xc4200820a0)    /usr/local/go/src/net/fd_unix.go:243 
+0x1a1net.(*conn).Read(0xc42008a610, 0xc420470000, 0x1000, 0x1000, 0x0, 0x0, 
0x0)  /usr/local/go/src/net/net.go:173 
+0x70net/http.(*persistConn).Read(0xc4202e1600, 0xc420470000, 0x1000, 0x1000, 
0x5e13e0, 0xc420044b58, 0x40ac1d)        
/usr/local/go/src/net/http/transport.go:1261 
+0x154bufio.(*Reader).fill(0xc420464780)   /usr/local/go/src/bufio/bufio.go:97 
+0x10cbufio.(*Reader).Peek(0xc420464780, 0x1, 0xc420044bbd, 0x1, 0x0, 
0xc4204647e0, 0x0)    /usr/local/go/src/bufio/bufio.go:129 
+0x62net/http.(*persistConn).readLoop(0xc4202e1600)        
/usr/local/go/src/net/http/transport.go:1418 +0x1a1created by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1062 
+0x4e9goroutine 23 [select]:net/http.(*persistConn).writeLoop(0xc4202e1600)     
   /usr/local/go/src/net/http/transport.go:1646 +0x3bdcreated by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1063 
+0x50erax    0x0rbx    0x6rcx    0x7fe8bee1bfffrdx    0x0rdi    0x2rsi    
0x7ffe98b63d40rbp    0xf1d11ersp    0x7ffe98b63db8r8     0x0r9     
0x7ffe98b63d40r10    0x8r11    0x246r12    0x218c050r13    0xf3r14    0x30r15   
 0x3rip    0x7fe8bee1bfffrflags 0x246cs     0x33fs     0x0gs     0x0
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4994)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:186)
        at 
org.apache.beam.runners.flink.translation.functions.FlinkDefaultExecutableStageContext.getStageBundleFactory(FlinkDefaultExecutableStageContext.java:49)
        at 
org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.getStageBundleFactory(ReferenceCountingFlinkExecutableStageContextFactory.java:203)
        at 
org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator.open(ExecutableStageDoFnOperator.java:187)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:420)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:296)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.io.IOException: Received exit code 2 for command 'docker run -d 
--network=host --env=DOCKER_MAC_CONTAINER=null --rm 
jenkins-docker-apache.bintray.io/beam/python:latest --id=1 
--logging_endpoint=localhost:39843 --artifact_endpoint=localhost:45409 
--provision_endpoint=localhost:43973 --control_endpoint=localhost:46033'. 
stderr: runtime/cgo: pthread_create failed: Resource temporarily 
unavailableSIGABRT: abortPC=0x7fe8bee1bfff m=0goroutine 0 [idle]:goroutine 34 
[running]:runtime.systemstack_switch()   
/usr/local/go/src/runtime/asm_amd64.s:252 fp=0xc4204b2528 
sp=0xc4204b2520runtime.gcMarkTermination()    
/usr/local/go/src/runtime/mgc.go:1272 +0x380 fp=0xc4204b2720 
sp=0xc4204b2528runtime.gcMarkDone()        
/usr/local/go/src/runtime/mgc.go:1158 +0x21e fp=0xc4204b2748 
sp=0xc4204b2720runtime.gcBgMarkWorker(0xc42001aa00)        
/usr/local/go/src/runtime/mgc.go:1505 +0x2c2 fp=0xc4204b27b8 
sp=0xc4204b2748runtime.goexit()    /usr/local/go/src/runtime/asm_amd64.s:2086 
+0x1 fp=0xc4204b27c0 sp=0xc4204b27b8created by runtime.gcBgMarkStartWorkers  
/usr/local/go/src/runtime/mgc.go:1349 +0x98goroutine 1 
[select]:net/http.(*persistConn).roundTrip(0xc4202e1600, 0xc420015660, 0x0, 
0x0, 0x0)    /usr/local/go/src/net/http/transport.go:1840 
+0x93bnet/http.(*Transport).RoundTrip(0xc4200f6870, 0xc4204fe2d0, 0xc4200f6870, 
0x0, 0xc400000000) /usr/local/go/src/net/http/transport.go:380 
+0x4fanet/http.send(0xc4204fe2d0, 0x1516c20, 0xc4200f6870, 0x0, 0xc400000000, 
0x0, 0xc4204eee80, 0x416f5d, 0xc420038790)    
/usr/local/go/src/net/http/client.go:256 
+0x15fnet/http.(*Client).send(0xc42046d050, 0xc4204fe2d0, 0x0, 0x0, 0x0, 
0xc420038790, 0x0, 0x1)       /usr/local/go/src/net/http/client.go:146 
+0x102net/http.(*Client).doFollowingRedirects(0xc42046d050, 0xc4204fe2d0, 
0xee92f0, 0x4, 0xc4204fe101, 0x413cff)       
/usr/local/go/src/net/http/client.go:528 
+0x5e5net/http.(*Client).Do(0xc42046d050, 0xc4204fe2d0, 0xc420064100, 
0xc4204fe2d0, 0xc420064100)      /usr/local/go/src/net/http/client.go:187 
+0x11dgithub.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp.Do(0x7fe8bf6ec050,
 0xc420064100, 0xc42046d050, 0xc4204fe1e0, 0x0, 0x0, 0xd4f940)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp/ctxhttp.go:30
 +0x92github.com/docker/docker/client.(*Client).doRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc4204fe1e0, 0x18, 0x1514da0, 0xc420066150, 
0xc420011c80, 0xc4204fe1e0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:127 
+0x6egithub.com/docker/docker/client.(*Client).sendRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe44ce9, 0x4, 0xe552cf, 0x12, 0xc420010510, 
0x1514da0, 0xc420066150, ...)    
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:121 
+0xf4github.com/docker/docker/client.(*Client).post(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe552cf, 0x12, 0xc420010510, 0xda9140, 
0xc420014340, 0x0, 0x19, ...)        
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:45 
+0xfagithub.com/docker/docker/client.(*Client).ContainerCreate(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc42048e000, 0xc42003b400, 0xc420038010, 0x0, 
0x0, 0x0, 0x0, ...) 
/usr/src/docker/.gopath/src/github.com/docker/docker/client/container_create.go:45
 
+0x27fgithub.com/docker/docker/cli/command/container.createContainer(0x7fe8bf6ec050,
 0xc420064100, 0xc4203e5730, 0xc420014240, 0x0, 0x0, 0x0, 0x0, 0x0)      
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/create.go:188
 
+0x21fgithub.com/docker/docker/cli/command/container.runContainer(0xc4203e5730, 
0xc420395ce0, 0xc4203dd900, 0xc420014240, 0x0, 0x0)    
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:139
 +0x22fgithub.com/docker/docker/cli/command/container.runRun(0xc4203e5730, 
0xc4200ab3b0, 0xc420395ce0, 0xc4203dd900, 0x0, 0x0)     
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:93
 
+0x14agithub.com/docker/docker/cli/command/container.NewRunCommand.func1(0xc420404b40,
 0xc420463680, 0x6, 0xa, 0x0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:47
 
+0x10fgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).execute(0xc420404b40,
 0xc42008e020, 0xa, 0xa, 0xc420404b40, 0xc42008e020)  
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:646
 
+0x26dgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).ExecuteC(0xc4200b3d40,
 0xc4203e8240, 0xc420391e30, 0xc42008a4c8)      
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:742
 
+0x377github.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).Execute(0xc4200b3d40,
 0xc4200b3d40, 0x1517260)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:695
 +0x2bmain.main()      
/usr/src/docker/.gopath/src/github.com/docker/docker/cmd/docker/docker.go:169 
+0xcbgoroutine 17 [syscall, locked to thread]:runtime.goexit()    
/usr/local/go/src/runtime/asm_amd64.s:2086 +0x1goroutine 19 
[syscall]:os/signal.signal_recv(0x0)        
/usr/local/go/src/runtime/sigqueue.go:116 +0x157os/signal.loop()        
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22created by os/signal.init.1  
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41goroutine 22 [IO 
wait]:net.runtime_pollWait(0x7fe8bf73db60, 0x72, 0x3)       
/usr/local/go/src/runtime/netpoll.go:160 
+0x59net.(*pollDesc).wait(0xc42044afb0, 0x72, 0xc4200449d0, 0xc4200820a0)      
/usr/local/go/src/net/fd_poll_runtime.go:73 
+0x38net.(*pollDesc).waitRead(0xc42044afb0, 0x151a920, 0xc4200820a0)        
/usr/local/go/src/net/fd_poll_runtime.go:78 
+0x34net.(*netFD).Read(0xc42044af50, 0xc420470000, 0x1000, 0x1000, 0x0, 
0x151a920, 0xc4200820a0)    /usr/local/go/src/net/fd_unix.go:243 
+0x1a1net.(*conn).Read(0xc42008a610, 0xc420470000, 0x1000, 0x1000, 0x0, 0x0, 
0x0)  /usr/local/go/src/net/net.go:173 
+0x70net/http.(*persistConn).Read(0xc4202e1600, 0xc420470000, 0x1000, 0x1000, 
0x5e13e0, 0xc420044b58, 0x40ac1d)        
/usr/local/go/src/net/http/transport.go:1261 
+0x154bufio.(*Reader).fill(0xc420464780)   /usr/local/go/src/bufio/bufio.go:97 
+0x10cbufio.(*Reader).Peek(0xc420464780, 0x1, 0xc420044bbd, 0x1, 0x0, 
0xc4204647e0, 0x0)    /usr/local/go/src/bufio/bufio.go:129 
+0x62net/http.(*persistConn).readLoop(0xc4202e1600)        
/usr/local/go/src/net/http/transport.go:1418 +0x1a1created by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1062 
+0x4e9goroutine 23 [select]:net/http.(*persistConn).writeLoop(0xc4202e1600)     
   /usr/local/go/src/net/http/transport.go:1646 +0x3bdcreated by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1063 
+0x50erax    0x0rbx    0x6rcx    0x7fe8bee1bfffrdx    0x0rdi    0x2rsi    
0x7ffe98b63d40rbp    0xf1d11ersp    0x7ffe98b63db8r8     0x0r9     
0x7ffe98b63d40r10    0x8r11    0x246r12    0x218c050r13    0xf3r14    0x30r15   
 0x3rip    0x7fe8bee1bfffrflags 0x246cs     0x33fs     0x0gs     0x0
        at 
org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:179)
        at 
org.apache.beam.runners.fnexecution.environment.DockerCommand.runImage(DockerCommand.java:92)
        at 
org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory.createEnvironment(DockerEnvironmentFactory.java:152)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:178)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:161)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3628)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2336)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2295)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2208)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache.get(LocalCache.java:4053)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4992)
        ... 8 more
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Could not restart the 
job BeamApp-root-0323181758-2b12ff0e (3dadb5def6acdef61d3e304219ce4224) because 
the restart strategy prevented it.
org.apache.beam.vendor.guava.v20_0.com.google.common.util.concurrent.UncheckedExecutionException:
 java.io.IOException: Received exit code 2 for command 'docker run -d 
--network=host --env=DOCKER_MAC_CONTAINER=null --rm 
jenkins-docker-apache.bintray.io/beam/python:latest --id=1 
--logging_endpoint=localhost:39843 --artifact_endpoint=localhost:45409 
--provision_endpoint=localhost:43973 --control_endpoint=localhost:46033'. 
stderr: runtime/cgo: pthread_create failed: Resource temporarily 
unavailableSIGABRT: abortPC=0x7fe8bee1bfff m=0goroutine 0 [idle]:goroutine 34 
[running]:runtime.systemstack_switch()    
/usr/local/go/src/runtime/asm_amd64.s:252 fp=0xc4204b2528 
sp=0xc4204b2520runtime.gcMarkTermination()    
/usr/local/go/src/runtime/mgc.go:1272 +0x380 fp=0xc4204b2720 
sp=0xc4204b2528runtime.gcMarkDone()        
/usr/local/go/src/runtime/mgc.go:1158 +0x21e fp=0xc4204b2748 
sp=0xc4204b2720runtime.gcBgMarkWorker(0xc42001aa00)        
/usr/local/go/src/runtime/mgc.go:1505 +0x2c2 fp=0xc4204b27b8 
sp=0xc4204b2748runtime.goexit()    /usr/local/go/src/runtime/asm_amd64.s:2086 
+0x1 fp=0xc4204b27c0 sp=0xc4204b27b8created by runtime.gcBgMarkStartWorkers  
/usr/local/go/src/runtime/mgc.go:1349 +0x98goroutine 1 
[select]:net/http.(*persistConn).roundTrip(0xc4202e1600, 0xc420015660, 0x0, 
0x0, 0x0)    /usr/local/go/src/net/http/transport.go:1840 
+0x93bnet/http.(*Transport).RoundTrip(0xc4200f6870, 0xc4204fe2d0, 0xc4200f6870, 
0x0, 0xc400000000) /usr/local/go/src/net/http/transport.go:380 
+0x4fanet/http.send(0xc4204fe2d0, 0x1516c20, 0xc4200f6870, 0x0, 0xc400000000, 
0x0, 0xc4204eee80, 0x416f5d, 0xc420038790)    
/usr/local/go/src/net/http/client.go:256 
+0x15fnet/http.(*Client).send(0xc42046d050, 0xc4204fe2d0, 0x0, 0x0, 0x0, 
0xc420038790, 0x0, 0x1)       /usr/local/go/src/net/http/client.go:146 
+0x102net/http.(*Client).doFollowingRedirects(0xc42046d050, 0xc4204fe2d0, 
0xee92f0, 0x4, 0xc4204fe101, 0x413cff)       
/usr/local/go/src/net/http/client.go:528 
+0x5e5net/http.(*Client).Do(0xc42046d050, 0xc4204fe2d0, 0xc420064100, 
0xc4204fe2d0, 0xc420064100)      /usr/local/go/src/net/http/client.go:187 
+0x11dgithub.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp.Do(0x7fe8bf6ec050,
 0xc420064100, 0xc42046d050, 0xc4204fe1e0, 0x0, 0x0, 0xd4f940)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp/ctxhttp.go:30
 +0x92github.com/docker/docker/client.(*Client).doRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc4204fe1e0, 0x18, 0x1514da0, 0xc420066150, 
0xc420011c80, 0xc4204fe1e0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:127 
+0x6egithub.com/docker/docker/client.(*Client).sendRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe44ce9, 0x4, 0xe552cf, 0x12, 0xc420010510, 
0x1514da0, 0xc420066150, ...)    
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:121 
+0xf4github.com/docker/docker/client.(*Client).post(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe552cf, 0x12, 0xc420010510, 0xda9140, 
0xc420014340, 0x0, 0x19, ...)        
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:45 
+0xfagithub.com/docker/docker/client.(*Client).ContainerCreate(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc42048e000, 0xc42003b400, 0xc420038010, 0x0, 
0x0, 0x0, 0x0, ...) 
/usr/src/docker/.gopath/src/github.com/docker/docker/client/container_create.go:45
 
+0x27fgithub.com/docker/docker/cli/command/container.createContainer(0x7fe8bf6ec050,
 0xc420064100, 0xc4203e5730, 0xc420014240, 0x0, 0x0, 0x0, 0x0, 0x0)      
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/create.go:188
 
+0x21fgithub.com/docker/docker/cli/command/container.runContainer(0xc4203e5730, 
0xc420395ce0, 0xc4203dd900, 0xc420014240, 0x0, 0x0)    
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:139
 +0x22fgithub.com/docker/docker/cli/command/container.runRun(0xc4203e5730, 
0xc4200ab3b0, 0xc420395ce0, 0xc4203dd900, 0x0, 0x0)     
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:93
 
+0x14agithub.com/docker/docker/cli/command/container.NewRunCommand.func1(0xc420404b40,
 0xc420463680, 0x6, 0xa, 0x0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:47
 
+0x10fgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).execute(0xc420404b40,
 0xc42008e020, 0xa, 0xa, 0xc420404b40, 0xc42008e020)  
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:646
 
+0x26dgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).ExecuteC(0xc4200b3d40,
 0xc4203e8240, 0xc420391e30, 0xc42008a4c8)      
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:742
 
+0x377github.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).Execute(0xc4200b3d40,
 0xc4200b3d40, 0x1517260)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:695
 +0x2bmain.main()      
/usr/src/docker/.gopath/src/github.com/docker/docker/cmd/docker/docker.go:169 
+0xcbgoroutine 17 [syscall, locked to thread]:runtime.goexit()    
/usr/local/go/src/runtime/asm_amd64.s:2086 +0x1goroutine 19 
[syscall]:os/signal.signal_recv(0x0)        
/usr/local/go/src/runtime/sigqueue.go:116 +0x157os/signal.loop()        
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22created by os/signal.init.1  
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41goroutine 22 [IO 
wait]:net.runtime_pollWait(0x7fe8bf73db60, 0x72, 0x3)       
/usr/local/go/src/runtime/netpoll.go:160 
+0x59net.(*pollDesc).wait(0xc42044afb0, 0x72, 0xc4200449d0, 0xc4200820a0)      
/usr/local/go/src/net/fd_poll_runtime.go:73 
+0x38net.(*pollDesc).waitRead(0xc42044afb0, 0x151a920, 0xc4200820a0)        
/usr/local/go/src/net/fd_poll_runtime.go:78 
+0x34net.(*netFD).Read(0xc42044af50, 0xc420470000, 0x1000, 0x1000, 0x0, 
0x151a920, 0xc4200820a0)    /usr/local/go/src/net/fd_unix.go:243 
+0x1a1net.(*conn).Read(0xc42008a610, 0xc420470000, 0x1000, 0x1000, 0x0, 0x0, 
0x0)  /usr/local/go/src/net/net.go:173 
+0x70net/http.(*persistConn).Read(0xc4202e1600, 0xc420470000, 0x1000, 0x1000, 
0x5e13e0, 0xc420044b58, 0x40ac1d)        
/usr/local/go/src/net/http/transport.go:1261 
+0x154bufio.(*Reader).fill(0xc420464780)   /usr/local/go/src/bufio/bufio.go:97 
+0x10cbufio.(*Reader).Peek(0xc420464780, 0x1, 0xc420044bbd, 0x1, 0x0, 
0xc4204647e0, 0x0)    /usr/local/go/src/bufio/bufio.go:129 
+0x62net/http.(*persistConn).readLoop(0xc4202e1600)        
/usr/local/go/src/net/http/transport.go:1418 +0x1a1created by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1062 
+0x4e9goroutine 23 [select]:net/http.(*persistConn).writeLoop(0xc4202e1600)     
   /usr/local/go/src/net/http/transport.go:1646 +0x3bdcreated by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1063 
+0x50erax    0x0rbx    0x6rcx    0x7fe8bee1bfffrdx    0x0rdi    0x2rsi    
0x7ffe98b63d40rbp    0xf1d11ersp    0x7ffe98b63db8r8     0x0r9     
0x7ffe98b63d40r10    0x8r11    0x246r12    0x218c050r13    0xf3r14    0x30r15   
 0x3rip    0x7fe8bee1bfffrflags 0x246cs     0x33fs     0x0gs     0x0
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4994)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:186)
        at 
org.apache.beam.runners.flink.translation.functions.FlinkDefaultExecutableStageContext.getStageBundleFactory(FlinkDefaultExecutableStageContext.java:49)
        at 
org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.getStageBundleFactory(ReferenceCountingFlinkExecutableStageContextFactory.java:203)
        at 
org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator.open(ExecutableStageDoFnOperator.java:187)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:420)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:296)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.io.IOException: Received exit code 2 for command 'docker run -d 
--network=host --env=DOCKER_MAC_CONTAINER=null --rm 
jenkins-docker-apache.bintray.io/beam/python:latest --id=1 
--logging_endpoint=localhost:39843 --artifact_endpoint=localhost:45409 
--provision_endpoint=localhost:43973 --control_endpoint=localhost:46033'. 
stderr: runtime/cgo: pthread_create failed: Resource temporarily 
unavailableSIGABRT: abortPC=0x7fe8bee1bfff m=0goroutine 0 [idle]:goroutine 34 
[running]:runtime.systemstack_switch()   
/usr/local/go/src/runtime/asm_amd64.s:252 fp=0xc4204b2528 
sp=0xc4204b2520runtime.gcMarkTermination()    
/usr/local/go/src/runtime/mgc.go:1272 +0x380 fp=0xc4204b2720 
sp=0xc4204b2528runtime.gcMarkDone()        
/usr/local/go/src/runtime/mgc.go:1158 +0x21e fp=0xc4204b2748 
sp=0xc4204b2720runtime.gcBgMarkWorker(0xc42001aa00)        
/usr/local/go/src/runtime/mgc.go:1505 +0x2c2 fp=0xc4204b27b8 
sp=0xc4204b2748runtime.goexit()    /usr/local/go/src/runtime/asm_amd64.s:2086 
+0x1 fp=0xc4204b27c0 sp=0xc4204b27b8created by runtime.gcBgMarkStartWorkers  
/usr/local/go/src/runtime/mgc.go:1349 +0x98goroutine 1 
[select]:net/http.(*persistConn).roundTrip(0xc4202e1600, 0xc420015660, 0x0, 
0x0, 0x0)    /usr/local/go/src/net/http/transport.go:1840 
+0x93bnet/http.(*Transport).RoundTrip(0xc4200f6870, 0xc4204fe2d0, 0xc4200f6870, 
0x0, 0xc400000000) /usr/local/go/src/net/http/transport.go:380 
+0x4fanet/http.send(0xc4204fe2d0, 0x1516c20, 0xc4200f6870, 0x0, 0xc400000000, 
0x0, 0xc4204eee80, 0x416f5d, 0xc420038790)    
/usr/local/go/src/net/http/client.go:256 
+0x15fnet/http.(*Client).send(0xc42046d050, 0xc4204fe2d0, 0x0, 0x0, 0x0, 
0xc420038790, 0x0, 0x1)       /usr/local/go/src/net/http/client.go:146 
+0x102net/http.(*Client).doFollowingRedirects(0xc42046d050, 0xc4204fe2d0, 
0xee92f0, 0x4, 0xc4204fe101, 0x413cff)       
/usr/local/go/src/net/http/client.go:528 
+0x5e5net/http.(*Client).Do(0xc42046d050, 0xc4204fe2d0, 0xc420064100, 
0xc4204fe2d0, 0xc420064100)      /usr/local/go/src/net/http/client.go:187 
+0x11dgithub.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp.Do(0x7fe8bf6ec050,
 0xc420064100, 0xc42046d050, 0xc4204fe1e0, 0x0, 0x0, 0xd4f940)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp/ctxhttp.go:30
 +0x92github.com/docker/docker/client.(*Client).doRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc4204fe1e0, 0x18, 0x1514da0, 0xc420066150, 
0xc420011c80, 0xc4204fe1e0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:127 
+0x6egithub.com/docker/docker/client.(*Client).sendRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe44ce9, 0x4, 0xe552cf, 0x12, 0xc420010510, 
0x1514da0, 0xc420066150, ...)    
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:121 
+0xf4github.com/docker/docker/client.(*Client).post(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe552cf, 0x12, 0xc420010510, 0xda9140, 
0xc420014340, 0x0, 0x19, ...)        
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:45 
+0xfagithub.com/docker/docker/client.(*Client).ContainerCreate(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc42048e000, 0xc42003b400, 0xc420038010, 0x0, 
0x0, 0x0, 0x0, ...) 
/usr/src/docker/.gopath/src/github.com/docker/docker/client/container_create.go:45
 
+0x27fgithub.com/docker/docker/cli/command/container.createContainer(0x7fe8bf6ec050,
 0xc420064100, 0xc4203e5730, 0xc420014240, 0x0, 0x0, 0x0, 0x0, 0x0)      
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/create.go:188
 
+0x21fgithub.com/docker/docker/cli/command/container.runContainer(0xc4203e5730, 
0xc420395ce0, 0xc4203dd900, 0xc420014240, 0x0, 0x0)    
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:139
 +0x22fgithub.com/docker/docker/cli/command/container.runRun(0xc4203e5730, 
0xc4200ab3b0, 0xc420395ce0, 0xc4203dd900, 0x0, 0x0)     
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:93
 
+0x14agithub.com/docker/docker/cli/command/container.NewRunCommand.func1(0xc420404b40,
 0xc420463680, 0x6, 0xa, 0x0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:47
 
+0x10fgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).execute(0xc420404b40,
 0xc42008e020, 0xa, 0xa, 0xc420404b40, 0xc42008e020)  
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:646
 
+0x26dgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).ExecuteC(0xc4200b3d40,
 0xc4203e8240, 0xc420391e30, 0xc42008a4c8)      
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:742
 
+0x377github.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).Execute(0xc4200b3d40,
 0xc4200b3d40, 0x1517260)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:695
 +0x2bmain.main()      
/usr/src/docker/.gopath/src/github.com/docker/docker/cmd/docker/docker.go:169 
+0xcbgoroutine 17 [syscall, locked to thread]:runtime.goexit()    
/usr/local/go/src/runtime/asm_amd64.s:2086 +0x1goroutine 19 
[syscall]:os/signal.signal_recv(0x0)        
/usr/local/go/src/runtime/sigqueue.go:116 +0x157os/signal.loop()        
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22created by os/signal.init.1  
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41goroutine 22 [IO 
wait]:net.runtime_pollWait(0x7fe8bf73db60, 0x72, 0x3)       
/usr/local/go/src/runtime/netpoll.go:160 
+0x59net.(*pollDesc).wait(0xc42044afb0, 0x72, 0xc4200449d0, 0xc4200820a0)      
/usr/local/go/src/net/fd_poll_runtime.go:73 
+0x38net.(*pollDesc).waitRead(0xc42044afb0, 0x151a920, 0xc4200820a0)        
/usr/local/go/src/net/fd_poll_runtime.go:78 
+0x34net.(*netFD).Read(0xc42044af50, 0xc420470000, 0x1000, 0x1000, 0x0, 
0x151a920, 0xc4200820a0)    /usr/local/go/src/net/fd_unix.go:243 
+0x1a1net.(*conn).Read(0xc42008a610, 0xc420470000, 0x1000, 0x1000, 0x0, 0x0, 
0x0)  /usr/local/go/src/net/net.go:173 
+0x70net/http.(*persistConn).Read(0xc4202e1600, 0xc420470000, 0x1000, 0x1000, 
0x5e13e0, 0xc420044b58, 0x40ac1d)        
/usr/local/go/src/net/http/transport.go:1261 
+0x154bufio.(*Reader).fill(0xc420464780)   /usr/local/go/src/bufio/bufio.go:97 
+0x10cbufio.(*Reader).Peek(0xc420464780, 0x1, 0xc420044bbd, 0x1, 0x0, 
0xc4204647e0, 0x0)    /usr/local/go/src/bufio/bufio.go:129 
+0x62net/http.(*persistConn).readLoop(0xc4202e1600)        
/usr/local/go/src/net/http/transport.go:1418 +0x1a1created by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1062 
+0x4e9goroutine 23 [select]:net/http.(*persistConn).writeLoop(0xc4202e1600)     
   /usr/local/go/src/net/http/transport.go:1646 +0x3bdcreated by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1063 
+0x50erax    0x0rbx    0x6rcx    0x7fe8bee1bfffrdx    0x0rdi    0x2rsi    
0x7ffe98b63d40rbp    0xf1d11ersp    0x7ffe98b63db8r8     0x0r9     
0x7ffe98b63d40r10    0x8r11    0x246r12    0x218c050r13    0xf3r14    0x30r15   
 0x3rip    0x7fe8bee1bfffrflags 0x246cs     0x33fs     0x0gs     0x0
        at 
org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:179)
        at 
org.apache.beam.runners.fnexecution.environment.DockerCommand.runImage(DockerCommand.java:92)
        at 
org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory.createEnvironment(DockerEnvironmentFactory.java:152)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:178)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:161)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3628)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2336)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2295)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2208)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache.get(LocalCache.java:4053)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4992)
        ... 8 more
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint 
coordinator for job 3dadb5def6acdef61d3e304219ce4224.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - 
Shutting down
[flink-runner-job-invoker] INFO 
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini 
Cluster
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 
3dadb5def6acdef61d3e304219ce4224 reached globally terminal state FAILED.
[flink-runner-job-invoker] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest 
endpoint.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job 
BeamApp-root-0323181758-2b12ff0e(3dadb5def6acdef61d3e304219ce4224).
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor 
akka://flink/user/taskmanager_0.
[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.jobmaster.JobMaster - Close ResourceManager connection 
de9f6fc588afac0eec73174d06bdd58c: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-2] 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 b18f1e7ce1336ab9ef5cb0e6827c4d68@akka://flink/user/jobmanager_1 for 
job 3dadb5def6acdef61d3e304219ce4224 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-5] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 
3dadb5def6acdef61d3e304219ce4224 with leader id 
b18f1e7ce1336ab9ef5cb0e6827c4d68 lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher 
akka://flink/user/dispatcher2bef3a12-39b6-4c3b-b98f-030f885f6a6c.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all 
currently running jobs of dispatcher 
akka://flink/user/dispatcher2bef3a12-39b6-4c3b-b98f-030f885f6a6c.
[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-12f63629-9f8a-4904-9995-1d931f2ee25a
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the 
network environment and its components.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
 - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader 
service.
[flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher 
akka://flink/user/dispatcher2bef3a12-39b6-4c3b-b98f-030f885f6a6c.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor 
akka://flink/user/taskmanager_0.
[ForkJoinPool.commonPool-worker-2] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache 
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-2] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
[ForkJoinPool.commonPool-worker-2] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:38209
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-invoker] ERROR 
org.apache.beam.runners.fnexecution.jobsubmission.JobInvocation - Error during 
job invocation 
BeamApp-root-0323181758-2b12ff0e_edfa36b7-99d0-469d-b01f-8fc3bb5675ed.
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
        at 
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146)
        at 
org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:632)
        at 
org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:123)
        at 
org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator$StreamingTranslationContext.execute(FlinkStreamingPortablePipelineTranslator.java:166)
        at 
org.apache.beam.runners.flink.FlinkPipelineRunner.runPipelineWithTranslator(FlinkPipelineRunner.java:88)
        at 
org.apache.beam.runners.flink.FlinkPipelineRunner.run(FlinkPipelineRunner.java:64)
        at 
org.apache.beam.runners.fnexecution.jobsubmission.JobInvocation.runPipeline(JobInvocation.java:73)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:111)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:58)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:75)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Caused by: 
org.apache.beam.vendor.guava.v20_0.com.google.common.util.concurrent.UncheckedExecutionException:
 java.io.IOException: Received exit code 2 for command 'docker run -d 
--network=host --env=DOCKER_MAC_CONTAINER=null --rm 
jenkins-docker-apache.bintray.io/beam/python:latest --id=1 
--logging_endpoint=localhost:39843 --artifact_endpoint=localhost:45409 
--provision_endpoint=localhost:43973 --control_endpoint=localhost:46033'. 
stderr: runtime/cgo: pthread_create failed: Resource temporarily 
unavailableSIGABRT: abortPC=0x7fe8bee1bfff m=0goroutine 0 [idle]:goroutine 34 
[running]:runtime.systemstack_switch() 
/usr/local/go/src/runtime/asm_amd64.s:252 fp=0xc4204b2528 
sp=0xc4204b2520runtime.gcMarkTermination()    
/usr/local/go/src/runtime/mgc.go:1272 +0x380 fp=0xc4204b2720 
sp=0xc4204b2528runtime.gcMarkDone()        
/usr/local/go/src/runtime/mgc.go:1158 +0x21e fp=0xc4204b2748 
sp=0xc4204b2720runtime.gcBgMarkWorker(0xc42001aa00)        
/usr/local/go/src/runtime/mgc.go:1505 +0x2c2 fp=0xc4204b27b8 
sp=0xc4204b2748runtime.goexit()    /usr/local/go/src/runtime/asm_amd64.s:2086 
+0x1 fp=0xc4204b27c0 sp=0xc4204b27b8created by runtime.gcBgMarkStartWorkers  
/usr/local/go/src/runtime/mgc.go:1349 +0x98goroutine 1 
[select]:net/http.(*persistConn).roundTrip(0xc4202e1600, 0xc420015660, 0x0, 
0x0, 0x0)    /usr/local/go/src/net/http/transport.go:1840 
+0x93bnet/http.(*Transport).RoundTrip(0xc4200f6870, 0xc4204fe2d0, 0xc4200f6870, 
0x0, 0xc400000000) /usr/local/go/src/net/http/transport.go:380 
+0x4fanet/http.send(0xc4204fe2d0, 0x1516c20, 0xc4200f6870, 0x0, 0xc400000000, 
0x0, 0xc4204eee80, 0x416f5d, 0xc420038790)    
/usr/local/go/src/net/http/client.go:256 
+0x15fnet/http.(*Client).send(0xc42046d050, 0xc4204fe2d0, 0x0, 0x0, 0x0, 
0xc420038790, 0x0, 0x1)       /usr/local/go/src/net/http/client.go:146 
+0x102net/http.(*Client).doFollowingRedirects(0xc42046d050, 0xc4204fe2d0, 
0xee92f0, 0x4, 0xc4204fe101, 0x413cff)       
/usr/local/go/src/net/http/client.go:528 
+0x5e5net/http.(*Client).Do(0xc42046d050, 0xc4204fe2d0, 0xc420064100, 
0xc4204fe2d0, 0xc420064100)      /usr/local/go/src/net/http/client.go:187 
+0x11dgithub.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp.Do(0x7fe8bf6ec050,
 0xc420064100, 0xc42046d050, 0xc4204fe1e0, 0x0, 0x0, 0xd4f940)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp/ctxhttp.go:30
 +0x92github.com/docker/docker/client.(*Client).doRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc4204fe1e0, 0x18, 0x1514da0, 0xc420066150, 
0xc420011c80, 0xc4204fe1e0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:127 
+0x6egithub.com/docker/docker/client.(*Client).sendRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe44ce9, 0x4, 0xe552cf, 0x12, 0xc420010510, 
0x1514da0, 0xc420066150, ...)    
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:121 
+0xf4github.com/docker/docker/client.(*Client).post(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe552cf, 0x12, 0xc420010510, 0xda9140, 
0xc420014340, 0x0, 0x19, ...)        
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:45 
+0xfagithub.com/docker/docker/client.(*Client).ContainerCreate(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc42048e000, 0xc42003b400, 0xc420038010, 0x0, 
0x0, 0x0, 0x0, ...) 
/usr/src/docker/.gopath/src/github.com/docker/docker/client/container_create.go:45
 
+0x27fgithub.com/docker/docker/cli/command/container.createContainer(0x7fe8bf6ec050,
 0xc420064100, 0xc4203e5730, 0xc420014240, 0x0, 0x0, 0x0, 0x0, 0x0)      
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/create.go:188
 
+0x21fgithub.com/docker/docker/cli/command/container.runContainer(0xc4203e5730, 
0xc420395ce0, 0xc4203dd900, 0xc420014240, 0x0, 0x0)    
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:139
 +0x22fgithub.com/docker/docker/cli/command/container.runRun(0xc4203e5730, 
0xc4200ab3b0, 0xc420395ce0, 0xc4203dd900, 0x0, 0x0)     
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:93
 
+0x14agithub.com/docker/docker/cli/command/container.NewRunCommand.func1(0xc420404b40,
 0xc420463680, 0x6, 0xa, 0x0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:47
 
+0x10fgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).execute(0xc420404b40,
 0xc42008e020, 0xa, 0xa, 0xc420404b40, 0xc42008e020)  
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:646
 
+0x26dgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).ExecuteC(0xc4200b3d40,
 0xc4203e8240, 0xc420391e30, 0xc42008a4c8)      
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:742
 
+0x377github.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).Execute(0xc4200b3d40,
 0xc4200b3d40, 0x1517260)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:695
 +0x2bmain.main()      
/usr/src/docker/.gopath/src/github.com/docker/docker/cmd/docker/docker.go:169 
+0xcbgoroutine 17 [syscall, locked to thread]:runtime.goexit()    
/usr/local/go/src/runtime/asm_amd64.s:2086 +0x1goroutine 19 
[syscall]:os/signal.signal_recv(0x0)        
/usr/local/go/src/runtime/sigqueue.go:116 +0x157os/signal.loop()        
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22created by os/signal.init.1  
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41goroutine 22 [IO 
wait]:net.runtime_pollWait(0x7fe8bf73db60, 0x72, 0x3)       
/usr/local/go/src/runtime/netpoll.go:160 
+0x59net.(*pollDesc).wait(0xc42044afb0, 0x72, 0xc4200449d0, 0xc4200820a0)      
/usr/local/go/src/net/fd_poll_runtime.go:73 
+0x38net.(*pollDesc).waitRead(0xc42044afb0, 0x151a920, 0xc4200820a0)        
/usr/local/go/src/net/fd_poll_runtime.go:78 
+0x34net.(*netFD).Read(0xc42044af50, 0xc420470000, 0x1000, 0x1000, 0x0, 
0x151a920, 0xc4200820a0)    /usr/local/go/src/net/fd_unix.go:243 
+0x1a1net.(*conn).Read(0xc42008a610, 0xc420470000, 0x1000, 0x1000, 0x0, 0x0, 
0x0)  /usr/local/go/src/net/net.go:173 
+0x70net/http.(*persistConn).Read(0xc4202e1600, 0xc420470000, 0x1000, 0x1000, 
0x5e13e0, 0xc420044b58, 0x40ac1d)        
/usr/local/go/src/net/http/transport.go:1261 
+0x154bufio.(*Reader).fill(0xc420464780)   /usr/local/go/src/bufio/bufio.go:97 
+0x10cbufio.(*Reader).Peek(0xc420464780, 0x1, 0xc420044bbd, 0x1, 0x0, 
0xc4204647e0, 0x0)    /usr/local/go/src/bufio/bufio.go:129 
+0x62net/http.(*persistConn).readLoop(0xc4202e1600)        
/usr/local/go/src/net/http/transport.go:1418 +0x1a1created by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1062 
+0x4e9goroutine 23 [select]:net/http.(*persistConn).writeLoop(0xc4202e1600)     
   /usr/local/go/src/net/http/transport.go:1646 +0x3bdcreated by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1063 
+0x50erax    0x0rbx    0x6rcx    0x7fe8bee1bfffrdx    0x0rdi    0x2rsi    
0x7ffe98b63d40rbp    0xf1d11ersp    0x7ffe98b63db8r8     0x0r9     
0x7ffe98b63d40r10    0x8r11    0x246r12    0x218c050r13    0xf3r14    0x30r15   
 0x3rip    0x7fe8bee1bfffrflags 0x246cs     0x33fs     0x0gs     0x0
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4994)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:186)
        at 
org.apache.beam.runners.flink.translation.functions.FlinkDefaultExecutableStageContext.getStageBundleFactory(FlinkDefaultExecutableStageContext.java:49)
        at 
org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.getStageBundleFactory(ReferenceCountingFlinkExecutableStageContextFactory.java:203)
        at 
org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator.open(ExecutableStageDoFnOperator.java:187)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:420)
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:296)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:712)
        ... 1 more
Caused by: java.io.IOException: Received exit code 2 for command 'docker run -d 
--network=host --env=DOCKER_MAC_CONTAINER=null --rm 
jenkins-docker-apache.bintray.io/beam/python:latest --id=1 
--logging_endpoint=localhost:39843 --artifact_endpoint=localhost:45409 
--provision_endpoint=localhost:43973 --control_endpoint=localhost:46033'. 
stderr: runtime/cgo: pthread_create failed: Resource temporarily 
unavailableSIGABRT: abortPC=0x7fe8bee1bfff m=0goroutine 0 [idle]:goroutine 34 
[running]:runtime.systemstack_switch()   
/usr/local/go/src/runtime/asm_amd64.s:252 fp=0xc4204b2528 
sp=0xc4204b2520runtime.gcMarkTermination()    
/usr/local/go/src/runtime/mgc.go:1272 +0x380 fp=0xc4204b2720 
sp=0xc4204b2528runtime.gcMarkDone()        
/usr/local/go/src/runtime/mgc.go:1158 +0x21e fp=0xc4204b2748 
sp=0xc4204b2720runtime.gcBgMarkWorker(0xc42001aa00)        
/usr/local/go/src/runtime/mgc.go:1505 +0x2c2 fp=0xc4204b27b8 
sp=0xc4204b2748runtime.goexit()    /usr/local/go/src/runtime/asm_amd64.s:2086 
+0x1 fp=0xc4204b27c0 sp=0xc4204b27b8created by runtime.gcBgMarkStartWorkers  
/usr/local/go/src/runtime/mgc.go:1349 +0x98goroutine 1 
[select]:net/http.(*persistConn).roundTrip(0xc4202e1600, 0xc420015660, 0x0, 
0x0, 0x0)    /usr/local/go/src/net/http/transport.go:1840 
+0x93bnet/http.(*Transport).RoundTrip(0xc4200f6870, 0xc4204fe2d0, 0xc4200f6870, 
0x0, 0xc400000000) /usr/local/go/src/net/http/transport.go:380 
+0x4fanet/http.send(0xc4204fe2d0, 0x1516c20, 0xc4200f6870, 0x0, 0xc400000000, 
0x0, 0xc4204eee80, 0x416f5d, 0xc420038790)    
/usr/local/go/src/net/http/client.go:256 
+0x15fnet/http.(*Client).send(0xc42046d050, 0xc4204fe2d0, 0x0, 0x0, 0x0, 
0xc420038790, 0x0, 0x1)       /usr/local/go/src/net/http/client.go:146 
+0x102net/http.(*Client).doFollowingRedirects(0xc42046d050, 0xc4204fe2d0, 
0xee92f0, 0x4, 0xc4204fe101, 0x413cff)       
/usr/local/go/src/net/http/client.go:528 
+0x5e5net/http.(*Client).Do(0xc42046d050, 0xc4204fe2d0, 0xc420064100, 
0xc4204fe2d0, 0xc420064100)      /usr/local/go/src/net/http/client.go:187 
+0x11dgithub.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp.Do(0x7fe8bf6ec050,
 0xc420064100, 0xc42046d050, 0xc4204fe1e0, 0x0, 0x0, 0xd4f940)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp/ctxhttp.go:30
 +0x92github.com/docker/docker/client.(*Client).doRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc4204fe1e0, 0x18, 0x1514da0, 0xc420066150, 
0xc420011c80, 0xc4204fe1e0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:127 
+0x6egithub.com/docker/docker/client.(*Client).sendRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe44ce9, 0x4, 0xe552cf, 0x12, 0xc420010510, 
0x1514da0, 0xc420066150, ...)    
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:121 
+0xf4github.com/docker/docker/client.(*Client).post(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe552cf, 0x12, 0xc420010510, 0xda9140, 
0xc420014340, 0x0, 0x19, ...)        
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:45 
+0xfagithub.com/docker/docker/client.(*Client).ContainerCreate(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc42048e000, 0xc42003b400, 0xc420038010, 0x0, 
0x0, 0x0, 0x0, ...) 
/usr/src/docker/.gopath/src/github.com/docker/docker/client/container_create.go:45
 
+0x27fgithub.com/docker/docker/cli/command/container.createContainer(0x7fe8bf6ec050,
 0xc420064100, 0xc4203e5730, 0xc420014240, 0x0, 0x0, 0x0, 0x0, 0x0)      
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/create.go:188
 
+0x21fgithub.com/docker/docker/cli/command/container.runContainer(0xc4203e5730, 
0xc420395ce0, 0xc4203dd900, 0xc420014240, 0x0, 0x0)    
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:139
 +0x22fgithub.com/docker/docker/cli/command/container.runRun(0xc4203e5730, 
0xc4200ab3b0, 0xc420395ce0, 0xc4203dd900, 0x0, 0x0)     
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:93
 
+0x14agithub.com/docker/docker/cli/command/container.NewRunCommand.func1(0xc420404b40,
 0xc420463680, 0x6, 0xa, 0x0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:47
 
+0x10fgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).execute(0xc420404b40,
 0xc42008e020, 0xa, 0xa, 0xc420404b40, 0xc42008e020)  
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:646
 
+0x26dgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).ExecuteC(0xc4200b3d40,
 0xc4203e8240, 0xc420391e30, 0xc42008a4c8)      
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:742
 
+0x377github.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).Execute(0xc4200b3d40,
 0xc4200b3d40, 0x1517260)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:695
 +0x2bmain.main()      
/usr/src/docker/.gopath/src/github.com/docker/docker/cmd/docker/docker.go:169 
+0xcbgoroutine 17 [syscall, locked to thread]:runtime.goexit()    
/usr/local/go/src/runtime/asm_amd64.s:2086 +0x1goroutine 19 
[syscall]:os/signal.signal_recv(0x0)        
/usr/local/go/src/runtime/sigqueue.go:116 +0x157os/signal.loop()        
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22created by os/signal.init.1  
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41goroutine 22 [IO 
wait]:net.runtime_pollWait(0x7fe8bf73db60, 0x72, 0x3)       
/usr/local/go/src/runtime/netpoll.go:160 
+0x59net.(*pollDesc).wait(0xc42044afb0, 0x72, 0xc4200449d0, 0xc4200820a0)      
/usr/local/go/src/net/fd_poll_runtime.go:73 
+0x38net.(*pollDesc).waitRead(0xc42044afb0, 0x151a920, 0xc4200820a0)        
/usr/local/go/src/net/fd_poll_runtime.go:78 
+0x34net.(*netFD).Read(0xc42044af50, 0xc420470000, 0x1000, 0x1000, 0x0, 
0x151a920, 0xc4200820a0)    /usr/local/go/src/net/fd_unix.go:243 
+0x1a1net.(*conn).Read(0xc42008a610, 0xc420470000, 0x1000, 0x1000, 0x0, 0x0, 
0x0)  /usr/local/go/src/net/net.go:173 
+0x70net/http.(*persistConn).Read(0xc4202e1600, 0xc420470000, 0x1000, 0x1000, 
0x5e13e0, 0xc420044b58, 0x40ac1d)        
/usr/local/go/src/net/http/transport.go:1261 
+0x154bufio.(*Reader).fill(0xc420464780)   /usr/local/go/src/bufio/bufio.go:97 
+0x10cbufio.(*Reader).Peek(0xc420464780, 0x1, 0xc420044bbd, 0x1, 0x0, 
0xc4204647e0, 0x0)    /usr/local/go/src/bufio/bufio.go:129 
+0x62net/http.(*persistConn).readLoop(0xc4202e1600)        
/usr/local/go/src/net/http/transport.go:1418 +0x1a1created by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1062 
+0x4e9goroutine 23 [select]:net/http.(*persistConn).writeLoop(0xc4202e1600)     
   /usr/local/go/src/net/http/transport.go:1646 +0x3bdcreated by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1063 
+0x50erax    0x0rbx    0x6rcx    0x7fe8bee1bfffrdx    0x0rdi    0x2rsi    
0x7ffe98b63d40rbp    0xf1d11ersp    0x7ffe98b63db8r8     0x0r9     
0x7ffe98b63d40r10    0x8r11    0x246r12    0x218c050r13    0xf3r14    0x30r15   
 0x3rip    0x7fe8bee1bfffrflags 0x246cs     0x33fs     0x0gs     0x0
        at 
org.apache.beam.runners.fnexecution.environment.DockerCommand.runShortCommand(DockerCommand.java:179)
        at 
org.apache.beam.runners.fnexecution.environment.DockerCommand.runImage(DockerCommand.java:92)
        at 
org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory.createEnvironment(DockerEnvironmentFactory.java:152)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:178)
        at 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:161)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3628)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2336)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2295)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2208)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache.get(LocalCache.java:4053)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
        at 
org.apache.beam.vendor.guava.v20_0.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4992)
        ... 8 more
ERROR:root:java.io.IOException: Received exit code 2 for command 'docker run -d 
--network=host --env=DOCKER_MAC_CONTAINER=null --rm 
jenkins-docker-apache.bintray.io/beam/python:latest --id=1 
--logging_endpoint=localhost:39843 --artifact_endpoint=localhost:45409 
--provision_endpoint=localhost:43973 --control_endpoint=localhost:46033'. 
stderr: runtime/cgo: pthread_create failed: Resource temporarily 
unavailableSIGABRT: abortPC=0x7fe8bee1bfff m=0goroutine 0 [idle]:goroutine 34 
[running]:runtime.systemstack_switch()   
/usr/local/go/src/runtime/asm_amd64.s:252 fp=0xc4204b2528 
sp=0xc4204b2520runtime.gcMarkTermination()    
/usr/local/go/src/runtime/mgc.go:1272 +0x380 fp=0xc4204b2720 
sp=0xc4204b2528runtime.gcMarkDone()        
/usr/local/go/src/runtime/mgc.go:1158 +0x21e fp=0xc4204b2748 
sp=0xc4204b2720runtime.gcBgMarkWorker(0xc42001aa00)        
/usr/local/go/src/runtime/mgc.go:1505 +0x2c2 fp=0xc4204b27b8 
sp=0xc4204b2748runtime.goexit()    /usr/local/go/src/runtime/asm_amd64.s:2086 
+0x1 fp=0xc4204b27c0 sp=0xc4204b27b8created by runtime.gcBgMarkStartWorkers  
/usr/local/go/src/runtime/mgc.go:1349 +0x98goroutine 1 
[select]:net/http.(*persistConn).roundTrip(0xc4202e1600, 0xc420015660, 0x0, 
0x0, 0x0)    /usr/local/go/src/net/http/transport.go:1840 
+0x93bnet/http.(*Transport).RoundTrip(0xc4200f6870, 0xc4204fe2d0, 0xc4200f6870, 
0x0, 0xc400000000) /usr/local/go/src/net/http/transport.go:380 
+0x4fanet/http.send(0xc4204fe2d0, 0x1516c20, 0xc4200f6870, 0x0, 0xc400000000, 
0x0, 0xc4204eee80, 0x416f5d, 0xc420038790)    
/usr/local/go/src/net/http/client.go:256 
+0x15fnet/http.(*Client).send(0xc42046d050, 0xc4204fe2d0, 0x0, 0x0, 0x0, 
0xc420038790, 0x0, 0x1)       /usr/local/go/src/net/http/client.go:146 
+0x102net/http.(*Client).doFollowingRedirects(0xc42046d050, 0xc4204fe2d0, 
0xee92f0, 0x4, 0xc4204fe101, 0x413cff)       
/usr/local/go/src/net/http/client.go:528 
+0x5e5net/http.(*Client).Do(0xc42046d050, 0xc4204fe2d0, 0xc420064100, 
0xc4204fe2d0, 0xc420064100)      /usr/local/go/src/net/http/client.go:187 
+0x11dgithub.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp.Do(0x7fe8bf6ec050,
 0xc420064100, 0xc42046d050, 0xc4204fe1e0, 0x0, 0x0, 0xd4f940)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp/ctxhttp.go:30
 +0x92github.com/docker/docker/client.(*Client).doRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc4204fe1e0, 0x18, 0x1514da0, 0xc420066150, 
0xc420011c80, 0xc4204fe1e0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:127 
+0x6egithub.com/docker/docker/client.(*Client).sendRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe44ce9, 0x4, 0xe552cf, 0x12, 0xc420010510, 
0x1514da0, 0xc420066150, ...)    
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:121 
+0xf4github.com/docker/docker/client.(*Client).post(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe552cf, 0x12, 0xc420010510, 0xda9140, 
0xc420014340, 0x0, 0x19, ...)        
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:45 
+0xfagithub.com/docker/docker/client.(*Client).ContainerCreate(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc42048e000, 0xc42003b400, 0xc420038010, 0x0, 
0x0, 0x0, 0x0, ...) 
/usr/src/docker/.gopath/src/github.com/docker/docker/client/container_create.go:45
 
+0x27fgithub.com/docker/docker/cli/command/container.createContainer(0x7fe8bf6ec050,
 0xc420064100, 0xc4203e5730, 0xc420014240, 0x0, 0x0, 0x0, 0x0, 0x0)      
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/create.go:188
 
+0x21fgithub.com/docker/docker/cli/command/container.runContainer(0xc4203e5730, 
0xc420395ce0, 0xc4203dd900, 0xc420014240, 0x0, 0x0)    
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:139
 +0x22fgithub.com/docker/docker/cli/command/container.runRun(0xc4203e5730, 
0xc4200ab3b0, 0xc420395ce0, 0xc4203dd900, 0x0, 0x0)     
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:93
 
+0x14agithub.com/docker/docker/cli/command/container.NewRunCommand.func1(0xc420404b40,
 0xc420463680, 0x6, 0xa, 0x0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:47
 
+0x10fgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).execute(0xc420404b40,
 0xc42008e020, 0xa, 0xa, 0xc420404b40, 0xc42008e020)  
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:646
 
+0x26dgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).ExecuteC(0xc4200b3d40,
 0xc4203e8240, 0xc420391e30, 0xc42008a4c8)      
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:742
 
+0x377github.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).Execute(0xc4200b3d40,
 0xc4200b3d40, 0x1517260)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:695
 +0x2bmain.main()      
/usr/src/docker/.gopath/src/github.com/docker/docker/cmd/docker/docker.go:169 
+0xcbgoroutine 17 [syscall, locked to thread]:runtime.goexit()    
/usr/local/go/src/runtime/asm_amd64.s:2086 +0x1goroutine 19 
[syscall]:os/signal.signal_recv(0x0)        
/usr/local/go/src/runtime/sigqueue.go:116 +0x157os/signal.loop()        
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22created by os/signal.init.1  
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41goroutine 22 [IO 
wait]:net.runtime_pollWait(0x7fe8bf73db60, 0x72, 0x3)       
/usr/local/go/src/runtime/netpoll.go:160 
+0x59net.(*pollDesc).wait(0xc42044afb0, 0x72, 0xc4200449d0, 0xc4200820a0)      
/usr/local/go/src/net/fd_poll_runtime.go:73 
+0x38net.(*pollDesc).waitRead(0xc42044afb0, 0x151a920, 0xc4200820a0)        
/usr/local/go/src/net/fd_poll_runtime.go:78 
+0x34net.(*netFD).Read(0xc42044af50, 0xc420470000, 0x1000, 0x1000, 0x0, 
0x151a920, 0xc4200820a0)    /usr/local/go/src/net/fd_unix.go:243 
+0x1a1net.(*conn).Read(0xc42008a610, 0xc420470000, 0x1000, 0x1000, 0x0, 0x0, 
0x0)  /usr/local/go/src/net/net.go:173 
+0x70net/http.(*persistConn).Read(0xc4202e1600, 0xc420470000, 0x1000, 0x1000, 
0x5e13e0, 0xc420044b58, 0x40ac1d)        
/usr/local/go/src/net/http/transport.go:1261 
+0x154bufio.(*Reader).fill(0xc420464780)   /usr/local/go/src/bufio/bufio.go:97 
+0x10cbufio.(*Reader).Peek(0xc420464780, 0x1, 0xc420044bbd, 0x1, 0x0, 
0xc4204647e0, 0x0)    /usr/local/go/src/bufio/bufio.go:129 
+0x62net/http.(*persistConn).readLoop(0xc4202e1600)        
/usr/local/go/src/net/http/transport.go:1418 +0x1a1created by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1062 
+0x4e9goroutine 23 [select]:net/http.(*persistConn).writeLoop(0xc4202e1600)     
   /usr/local/go/src/net/http/transport.go:1646 +0x3bdcreated by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1063 
+0x50erax    0x0rbx    0x6rcx    0x7fe8bee1bfffrdx    0x0rdi    0x2rsi    
0x7ffe98b63d40rbp    0xf1d11ersp    0x7ffe98b63db8r8     0x0r9     
0x7ffe98b63d40r10    0x8r11    0x246r12    0x218c050r13    0xf3r14    0x30r15   
 0x3rip    0x7fe8bee1bfffrflags 0x246cs     0x33fs     0x0gs     0x0
INFO:root:Job state changed to FAILED
Traceback (most recent call last):
  File "/usr/lib/python2.7/runpy.py", line 174, in _run_module_as_main
    "__main__", fname, loader, pkg_name)
  File "/usr/lib/python2.7/runpy.py", line 72, in _run_code
    exec code in run_globals
  File 
"<https://builds.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/sdks/python/apache_beam/examples/wordcount.py";,>
 line 135, in <module>
    run()
  File 
"<https://builds.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/sdks/python/apache_beam/examples/wordcount.py";,>
 line 115, in run
    result.wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 428, in 
wait_until_finish
    self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline 
BeamApp-root-0323181758-2b12ff0e_edfa36b7-99d0-469d-b01f-8fc3bb5675ed failed in 
state FAILED: java.io.IOException: Received exit code 2 for command 'docker run 
-d --network=host --env=DOCKER_MAC_CONTAINER=null --rm 
jenkins-docker-apache.bintray.io/beam/python:latest --id=1 
--logging_endpoint=localhost:39843 --artifact_endpoint=localhost:45409 
--provision_endpoint=localhost:43973 --control_endpoint=localhost:46033'. 
stderr: runtime/cgo: pthread_create failed: Resource temporarily 
unavailableSIGABRT: abortPC=0x7fe8bee1bfff m=0goroutine 0 [idle]:goroutine 34 
[running]:runtime.systemstack_switch() 
/usr/local/go/src/runtime/asm_amd64.s:252 fp=0xc4204b2528 
sp=0xc4204b2520runtime.gcMarkTermination()    
/usr/local/go/src/runtime/mgc.go:1272 +0x380 fp=0xc4204b2720 
sp=0xc4204b2528runtime.gcMarkDone()        
/usr/local/go/src/runtime/mgc.go:1158 +0x21e fp=0xc4204b2748 
sp=0xc4204b2720runtime.gcBgMarkWorker(0xc42001aa00)        
/usr/local/go/src/runtime/mgc.go:1505 +0x2c2 fp=0xc4204b27b8 
sp=0xc4204b2748runtime.goexit()    /usr/local/go/src/runtime/asm_amd64.s:2086 
+0x1 fp=0xc4204b27c0 sp=0xc4204b27b8created by runtime.gcBgMarkStartWorkers  
/usr/local/go/src/runtime/mgc.go:1349 +0x98goroutine 1 
[select]:net/http.(*persistConn).roundTrip(0xc4202e1600, 0xc420015660, 0x0, 
0x0, 0x0)    /usr/local/go/src/net/http/transport.go:1840 
+0x93bnet/http.(*Transport).RoundTrip(0xc4200f6870, 0xc4204fe2d0, 0xc4200f6870, 
0x0, 0xc400000000) /usr/local/go/src/net/http/transport.go:380 
+0x4fanet/http.send(0xc4204fe2d0, 0x1516c20, 0xc4200f6870, 0x0, 0xc400000000, 
0x0, 0xc4204eee80, 0x416f5d, 0xc420038790)    
/usr/local/go/src/net/http/client.go:256 
+0x15fnet/http.(*Client).send(0xc42046d050, 0xc4204fe2d0, 0x0, 0x0, 0x0, 
0xc420038790, 0x0, 0x1)       /usr/local/go/src/net/http/client.go:146 
+0x102net/http.(*Client).doFollowingRedirects(0xc42046d050, 0xc4204fe2d0, 
0xee92f0, 0x4, 0xc4204fe101, 0x413cff)       
/usr/local/go/src/net/http/client.go:528 
+0x5e5net/http.(*Client).Do(0xc42046d050, 0xc4204fe2d0, 0xc420064100, 
0xc4204fe2d0, 0xc420064100)      /usr/local/go/src/net/http/client.go:187 
+0x11dgithub.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp.Do(0x7fe8bf6ec050,
 0xc420064100, 0xc42046d050, 0xc4204fe1e0, 0x0, 0x0, 0xd4f940)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/golang.org/x/net/context/ctxhttp/ctxhttp.go:30
 +0x92github.com/docker/docker/client.(*Client).doRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc4204fe1e0, 0x18, 0x1514da0, 0xc420066150, 
0xc420011c80, 0xc4204fe1e0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:127 
+0x6egithub.com/docker/docker/client.(*Client).sendRequest(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe44ce9, 0x4, 0xe552cf, 0x12, 0xc420010510, 
0x1514da0, 0xc420066150, ...)    
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:121 
+0xf4github.com/docker/docker/client.(*Client).post(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xe552cf, 0x12, 0xc420010510, 0xda9140, 
0xc420014340, 0x0, 0x19, ...)        
/usr/src/docker/.gopath/src/github.com/docker/docker/client/request.go:45 
+0xfagithub.com/docker/docker/client.(*Client).ContainerCreate(0xc4203ca780, 
0x7fe8bf6ec050, 0xc420064100, 0xc42048e000, 0xc42003b400, 0xc420038010, 0x0, 
0x0, 0x0, 0x0, ...) 
/usr/src/docker/.gopath/src/github.com/docker/docker/client/container_create.go:45
 
+0x27fgithub.com/docker/docker/cli/command/container.createContainer(0x7fe8bf6ec050,
 0xc420064100, 0xc4203e5730, 0xc420014240, 0x0, 0x0, 0x0, 0x0, 0x0)      
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/create.go:188
 
+0x21fgithub.com/docker/docker/cli/command/container.runContainer(0xc4203e5730, 
0xc420395ce0, 0xc4203dd900, 0xc420014240, 0x0, 0x0)    
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:139
 +0x22fgithub.com/docker/docker/cli/command/container.runRun(0xc4203e5730, 
0xc4200ab3b0, 0xc420395ce0, 0xc4203dd900, 0x0, 0x0)     
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:93
 
+0x14agithub.com/docker/docker/cli/command/container.NewRunCommand.func1(0xc420404b40,
 0xc420463680, 0x6, 0xa, 0x0, 0x0)   
/usr/src/docker/.gopath/src/github.com/docker/docker/cli/command/container/run.go:47
 
+0x10fgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).execute(0xc420404b40,
 0xc42008e020, 0xa, 0xa, 0xc420404b40, 0xc42008e020)  
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:646
 
+0x26dgithub.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).ExecuteC(0xc4200b3d40,
 0xc4203e8240, 0xc420391e30, 0xc42008a4c8)      
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:742
 
+0x377github.com/docker/docker/vendor/github.com/spf13/cobra.(*Command).Execute(0xc4200b3d40,
 0xc4200b3d40, 0x1517260)        
/usr/src/docker/.gopath/src/github.com/docker/docker/vendor/github.com/spf13/cobra/command.go:695
 +0x2bmain.main()      
/usr/src/docker/.gopath/src/github.com/docker/docker/cmd/docker/docker.go:169 
+0xcbgoroutine 17 [syscall, locked to thread]:runtime.goexit()    
/usr/local/go/src/runtime/asm_amd64.s:2086 +0x1goroutine 19 
[syscall]:os/signal.signal_recv(0x0)        
/usr/local/go/src/runtime/sigqueue.go:116 +0x157os/signal.loop()        
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22created by os/signal.init.1  
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41goroutine 22 [IO 
wait]:net.runtime_pollWait(0x7fe8bf73db60, 0x72, 0x3)       
/usr/local/go/src/runtime/netpoll.go:160 
+0x59net.(*pollDesc).wait(0xc42044afb0, 0x72, 0xc4200449d0, 0xc4200820a0)      
/usr/local/go/src/net/fd_poll_runtime.go:73 
+0x38net.(*pollDesc).waitRead(0xc42044afb0, 0x151a920, 0xc4200820a0)        
/usr/local/go/src/net/fd_poll_runtime.go:78 
+0x34net.(*netFD).Read(0xc42044af50, 0xc420470000, 0x1000, 0x1000, 0x0, 
0x151a920, 0xc4200820a0)    /usr/local/go/src/net/fd_unix.go:243 
+0x1a1net.(*conn).Read(0xc42008a610, 0xc420470000, 0x1000, 0x1000, 0x0, 0x0, 
0x0)  /usr/local/go/src/net/net.go:173 
+0x70net/http.(*persistConn).Read(0xc4202e1600, 0xc420470000, 0x1000, 0x1000, 
0x5e13e0, 0xc420044b58, 0x40ac1d)        
/usr/local/go/src/net/http/transport.go:1261 
+0x154bufio.(*Reader).fill(0xc420464780)   /usr/local/go/src/bufio/bufio.go:97 
+0x10cbufio.(*Reader).Peek(0xc420464780, 0x1, 0xc420044bbd, 0x1, 0x0, 
0xc4204647e0, 0x0)    /usr/local/go/src/bufio/bufio.go:129 
+0x62net/http.(*persistConn).readLoop(0xc4202e1600)        
/usr/local/go/src/net/http/transport.go:1418 +0x1a1created by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1062 
+0x4e9goroutine 23 [select]:net/http.(*persistConn).writeLoop(0xc4202e1600)     
   /usr/local/go/src/net/http/transport.go:1646 +0x3bdcreated by 
net/http.(*Transport).dialConn    /usr/local/go/src/net/http/transport.go:1063 
+0x50erax    0x0rbx    0x6rcx    0x7fe8bee1bfffrdx    0x0rdi    0x2rsi    
0x7ffe98b63d40rbp    0xf1d11ersp    0x7ffe98b63db8r8     0x0r9     
0x7ffe98b63d40r10    0x8r11    0x246r12    0x218c050r13    0xf3r14    0x30r15   
 0x3rip    0x7fe8bee1bfffrflags 0x246cs     0x33fs     0x0gs     0x0

> Task :beam-sdks-python:portableWordCountStreaming FAILED

FAILURE: Build failed with an exception.

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

* What went wrong:
Execution failed for task ':beam-sdks-python:portableWordCountStreaming'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --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 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See 
https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 7m 6s
69 actionable tasks: 53 executed, 14 from cache, 2 up-to-date

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

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

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Build failed in Jenkins: beam_PreCommit_Portable_Python_Cron #449

Reply via email to