Build failed in Jenkins: beam_PreCommit_Portable_Python_Cron #2047

Apache Jenkins Server Thu, 30 Apr 2020 05:22:15 -0700

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


Changes:


------------------------------------------
[...truncated 1.56 MB...]
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0 
-> Map (1/2) (8e219ab35cb36f62942ffa902eb346a9).'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25-python_side_input0
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25-python_side_input0 
-> Map (1/2) (b259bd94864ca4edbf5dec8c60f5cd82) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25-python_side_input0 
-> Map (1/2) b259bd94864ca4edbf5dec8c60f5cd82.'
INFO:apache_beam.utils.subprocess_server:b'[[2]write/Write/WriteImpl/DoOnce/{FlatMap(<lambda
 at core.py:2714>), Map(decode)} -> [1]write/Write/WriteImpl/InitializeWrite -> 
(Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task [2]write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at 
core.py:2714>), Map(decode)} -> [1]write/Write/WriteImpl/InitializeWrite -> 
(Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
(2feea5cff1d5ae705cbbf05e18cb389d) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0 
-> Map (1/2) (cc7a951c50ad1db721e21e671f49052b) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0 
-> Map (1/2) (8e219ab35cb36f62942ffa902eb346a9) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
[2]write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2714>), 
Map(decode)} -> [1]write/Write/WriteImpl/InitializeWrite -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
2feea5cff1d5ae705cbbf05e18cb389d.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25-python_side_input0
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25-python_side_input0 
-> Map (2/2) (cac3eaf817859c523800b7c19ec295ae) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0 
-> Map (2/2) (8980289af8a4fdb7f3e8b10becd9f259) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25-python_side_input0 
-> Map (1/2) (b259bd94864ca4edbf5dec8c60f5cd82) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0 
-> Map (2/2) (86907c762507c2fe93a53c250d82d48a) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0 
-> Map (2/2) (86907c762507c2fe93a53c250d82d48a).'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0 
-> Map (1/2) cc7a951c50ad1db721e21e671f49052b.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0 
-> Map (2/2) (86907c762507c2fe93a53c250d82d48a) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0 
-> Map (1/2) 8e219ab35cb36f62942ffa902eb346a9.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25-python_side_input0 
-> Map (2/2) cac3eaf817859c523800b7c19ec295ae.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[2]write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2714>), 
Map(decode)} -> [1]write/Write/WriteImpl/InitializeWrite -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
(2feea5cff1d5ae705cbbf05e18cb389d) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0 
-> Map (2/2) 8980289af8a4fdb7f3e8b10becd9f259.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0 
-> Map (2/2) 86907c762507c2fe93a53c250d82d48a.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0 
-> Map (1/2) (cc7a951c50ad1db721e21e671f49052b) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0 
-> Map (1/2) (8e219ab35cb36f62942ffa902eb346a9) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25-python_side_input0 
-> Map (2/2) (cac3eaf817859c523800b7c19ec295ae) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input0 
-> Map (2/2) (8980289af8a4fdb7f3e8b10becd9f259) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input0 
-> Map (2/2) (86907c762507c2fe93a53c250d82d48a) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-1] INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - 
getProcessBundleDescriptor request with id 1-8'
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-1] INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - 
getProcessBundleDescriptor request with id 1-10'
INFO:apache_beam.utils.subprocess_server:b'[group -> [3]{count, format, write} 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - group -> [3]{count, 
format, write} (1/2) (3563a0723fbb72fe796f81e26075cc7c) switched from RUNNING 
to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[group -> [3]{count, format, write} 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for group -> [3]{count, format, write} (1/2) 
(3563a0723fbb72fe796f81e26075cc7c).'
INFO:apache_beam.utils.subprocess_server:b'[group -> [3]{count, format, write} 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task group -> [3]{count, format, write} (1/2) 
(3563a0723fbb72fe796f81e26075cc7c) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task group -> 
[3]{count, format, write} (1/2) 3563a0723fbb72fe796f81e26075cc7c.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - group -> 
[3]{count, format, write} (1/2) (3563a0723fbb72fe796f81e26075cc7c) switched 
from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-0] INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - 
getProcessBundleDescriptor request with id 1-2'
INFO:apache_beam.utils.subprocess_server:b'[group -> [3]{count, format, write} 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - group -> [3]{count, 
format, write} (2/2) (79d5ef28b88fe59009aa42d2b428d013) switched from RUNNING 
to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[group -> [3]{count, format, write} 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for group -> [3]{count, format, write} (2/2) 
(79d5ef28b88fe59009aa42d2b428d013).'
INFO:apache_beam.utils.subprocess_server:b'[group -> [3]{count, format, write} 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task group -> [3]{count, format, write} (2/2) 
(79d5ef28b88fe59009aa42d2b428d013) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task group -> 
[3]{count, format, write} (2/2) 79d5ef28b88fe59009aa42d2b428d013.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - group -> 
[3]{count, format, write} (2/2) (79d5ef28b88fe59009aa42d2b428d013) switched 
from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-0] INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - 
getProcessBundleDescriptor request with id 1-14'
INFO:apache_beam.utils.subprocess_server:b'[[2]write/Write/WriteImpl/{WriteBundles,
 Pair} -> ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task 
- [2]write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (1/2) 
(694f757fc681b500ce8d93ec4d98b2a3) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[2]write/Write/WriteImpl/{WriteBundles,
 Pair} -> ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for [2]write/Write/WriteImpl/{WriteBundles, Pair} -> 
ToKeyedWorkItem (1/2) (694f757fc681b500ce8d93ec4d98b2a3).'
INFO:apache_beam.utils.subprocess_server:b'[[2]write/Write/WriteImpl/{WriteBundles,
 Pair} -> ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task 
- [2]write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (2/2) 
(a918ee86d1fd7e3b36f58f6f3503a02e) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[2]write/Write/WriteImpl/{WriteBundles,
 Pair} -> ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for [2]write/Write/WriteImpl/{WriteBundles, Pair} -> 
ToKeyedWorkItem (2/2) (a918ee86d1fd7e3b36f58f6f3503a02e).'
INFO:apache_beam.utils.subprocess_server:b'[[2]write/Write/WriteImpl/{WriteBundles,
 Pair} -> ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task 
[2]write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (1/2) 
(694f757fc681b500ce8d93ec4d98b2a3) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[[2]write/Write/WriteImpl/{WriteBundles,
 Pair} -> ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task 
[2]write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (2/2) 
(a918ee86d1fd7e3b36f58f6f3503a02e) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
[2]write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (1/2) 
694f757fc681b500ce8d93ec4d98b2a3.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
[2]write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (2/2) 
a918ee86d1fd7e3b36f58f6f3503a02e.'
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-1] INFO 
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - 
getProcessBundleDescriptor request with id 1-3'
INFO:apache_beam.utils.subprocess_server:b'[write/Write/WriteImpl/GroupByKey -> 
[1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> 
ToKeyedWorkItem) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2) 
(618be85e5b2be72052cde5bb52f82579) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[write/Write/WriteImpl/GroupByKey -> 
[1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> 
ToKeyedWorkItem) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for write/Write/WriteImpl/GroupByKey -> 
[1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> 
ToKeyedWorkItem) (2/2) (618be85e5b2be72052cde5bb52f82579).'
INFO:apache_beam.utils.subprocess_server:b'[write/Write/WriteImpl/GroupByKey -> 
[1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> 
ToKeyedWorkItem) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2) 
(618be85e5b2be72052cde5bb52f82579) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[2]write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (1/2) 
(694f757fc681b500ce8d93ec4d98b2a3) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2) 
618be85e5b2be72052cde5bb52f82579.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[2]write/Write/WriteImpl/{WriteBundles, Pair} -> ToKeyedWorkItem (2/2) 
(a918ee86d1fd7e3b36f58f6f3503a02e) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2) 
(618be85e5b2be72052cde5bb52f82579) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[write/Write/WriteImpl/GroupByKey -> 
[1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> 
ToKeyedWorkItem) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
(81e40c170a7e0e1d48da824cb6db2542) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[write/Write/WriteImpl/GroupByKey -> 
[1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> 
ToKeyedWorkItem) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for write/Write/WriteImpl/GroupByKey -> 
[1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> 
ToKeyedWorkItem) (1/2) (81e40c170a7e0e1d48da824cb6db2542).'
INFO:apache_beam.utils.subprocess_server:b'[write/Write/WriteImpl/GroupByKey -> 
[1]write/Write/WriteImpl/Extract -> (Map -> ToKeyedWorkItem, Map -> 
ToKeyedWorkItem) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
(81e40c170a7e0e1d48da824cb6db2542) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
81e40c170a7e0e1d48da824cb6db2542.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (1/2) (9c531388ffe4e74ad20a1ede0a6c39a1) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (1/2) (9c531388ffe4e74ad20a1ede0a6c39a1).'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (1/2) (9c531388ffe4e74ad20a1ede0a6c39a1) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (2/2) (edf06975b8898590af40572e0e281df7) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (2/2) (edf06975b8898590af40572e0e281df7).'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (1/2) (a7a9c21eba921259199e5063b2b0b103) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (1/2) (a7a9c21eba921259199e5063b2b0b103).'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (2/2) (edf06975b8898590af40572e0e281df7) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (1/2) (a7a9c21eba921259199e5063b2b0b103) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (1/2) 9c531388ffe4e74ad20a1ede0a6c39a1.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (2/2) edf06975b8898590af40572e0e281df7.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (1/2) a7a9c21eba921259199e5063b2b0b103.'
INFO:apache_beam.utils.subprocess_server:b'[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) 
(81e40c170a7e0e1d48da824cb6db2542) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (1/2) (9c531388ffe4e74ad20a1ede0a6c39a1) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input1 
-> Map (2/2) (edf06975b8898590af40572e0e281df7) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (2/2) (4bb022724580b6a8466f091b76f99e38) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (2/2) (4bb022724580b6a8466f091b76f99e38).'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (2/2) (4bb022724580b6a8466f091b76f99e38) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (1/2) (a7a9c21eba921259199e5063b2b0b103) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (2/2) 4bb022724580b6a8466f091b76f99e38.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32-python_side_input1 
-> Map (2/2) (4bb022724580b6a8466f091b76f99e38) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/PreFinalize
 -> Map -> ToKeyedWorkItem (2/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2) 
(0577f950f753fa38d1dd700eb8581c44) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/PreFinalize
 -> Map -> ToKeyedWorkItem (2/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2) 
(0577f950f753fa38d1dd700eb8581c44).'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/PreFinalize
 -> Map -> ToKeyedWorkItem (2/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are 
closed for task [1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem 
(2/2) (0577f950f753fa38d1dd700eb8581c44) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2) 
0577f950f753fa38d1dd700eb8581c44.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2) 
(0577f950f753fa38d1dd700eb8581c44) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/PreFinalize
 -> Map -> ToKeyedWorkItem (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2) 
(c15e97ee3ca2d31e50fe6eb0ccb8555f) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/PreFinalize
 -> Map -> ToKeyedWorkItem (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2) 
(c15e97ee3ca2d31e50fe6eb0ccb8555f).'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/PreFinalize
 -> Map -> ToKeyedWorkItem (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are 
closed for task [1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem 
(1/2) (c15e97ee3ca2d31e50fe6eb0ccb8555f) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2) 
c15e97ee3ca2d31e50fe6eb0ccb8555f.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (2/2) (277db34a312857712af0f5cf41f19fde) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (2/2) (277db34a312857712af0f5cf41f19fde).'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2
 -> Map (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (2/2) (277db34a312857712af0f5cf41f19fde) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (1/2) (a3d801cc7797543b87f146bae68bbe49) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (1/2) (a3d801cc7797543b87f146bae68bbe49).'
INFO:apache_beam.utils.subprocess_server:b'[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2
 -> Map (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (1/2) (a3d801cc7797543b87f146bae68bbe49) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (2/2) 277db34a312857712af0f5cf41f19fde.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (1/2) a3d801cc7797543b87f146bae68bbe49.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2) 
(c15e97ee3ca2d31e50fe6eb0ccb8555f) switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (2/2) (277db34a312857712af0f5cf41f19fde) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33-python_side_input2 
-> Map (1/2) (a3d801cc7797543b87f146bae68bbe49) switched from RUNNING to 
FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
[1]write/Write/WriteImpl/FinalizeWrite (2/2) (558fe4f1650513cee11cf1acad38290a) 
switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for [1]write/Write/WriteImpl/FinalizeWrite (2/2) 
(558fe4f1650513cee11cf1acad38290a).'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task [1]write/Write/WriteImpl/FinalizeWrite 
(2/2) (558fe4f1650513cee11cf1acad38290a) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
[1]write/Write/WriteImpl/FinalizeWrite (2/2) 558fe4f1650513cee11cf1acad38290a.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[1]write/Write/WriteImpl/FinalizeWrite (2/2) (558fe4f1650513cee11cf1acad38290a) 
switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-1] INFO 
/usr/local/lib/python3.5/site-packages/apache_beam/io/filebasedsink.py:310 - 
Starting finalize_write threads with num_shards: 2 (skipped: 0), batches: 2, 
num_threads: 2'
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-1] INFO 
/usr/local/lib/python3.5/site-packages/apache_beam/io/filebasedsink.py:355 - 
Renamed 2 shards in 0.11 seconds.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (1/2)] INFO 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory - Closing 
environment urn: "beam:env:docker:v1"'
INFO:apache_beam.utils.subprocess_server:b'payload: 
"\\n$apache/beam_python3.5_sdk:2.22.0.dev"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:coder:global_window:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: "beam:coder:kv:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: "beam:coder:bool:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:coder:string_utf8:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: "beam:coder:double:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: "beam:coder:bytes:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:coder:param_windowed_value:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:coder:interval_window:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: "beam:coder:varint:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: "beam:coder:timer:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: "beam:coder:row:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:coder:windowed_value:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:coder:length_prefix:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:coder:state_backed_iterable:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:coder:iterable:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:protocol:progress_reporting:v0"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:protocol:worker_status:v1"'
INFO:apache_beam.utils.subprocess_server:b'capabilities: 
"beam:version:sdk_base:apache/beam_python3.5_sdk:2.22.0.dev"'
INFO:apache_beam.utils.subprocess_server:b'dependencies {'
INFO:apache_beam.utils.subprocess_server:b'  type_urn: 
"beam:artifact:type:file:v1"'
INFO:apache_beam.utils.subprocess_server:b'  type_payload: 
"\\n%/tmp/tmpf2c6_e77/pickled_main_session"'
INFO:apache_beam.utils.subprocess_server:b'  role_urn: 
"beam:artifact:role:staging_to:v1"'
INFO:apache_beam.utils.subprocess_server:b'  role_payload: 
"\\n\\024pickled_main_session"'
INFO:apache_beam.utils.subprocess_server:b'}'
INFO:apache_beam.utils.subprocess_server:b''
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (1/2)] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - 1 
Beam Fn Logging clients still connected during shutdown.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (1/2)] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up 
for unknown endpoint.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (1/2)] INFO 
org.apache.beam.runners.fnexecution.environment.DockerContainerEnvironment - 
Closing Docker container 
184d922d392f42e25d2dd7a08a125743589463bdf5f02d9a2523721ccb2589c7. Logs:'
INFO:apache_beam.utils.subprocess_server:b'2020/04/30 12:21:30 Provision info:'
INFO:apache_beam.utils.subprocess_server:b'pipeline_options:<fields:<key:"beam:option:allow_non_restored_state:v1"
 value:<bool_value:false > > fields:<key:"beam:option:app_name:v1" 
value:<null_value:NULL_VALUE > > fields:<key:"beam:option:artifact_port:v1" 
value:<string_value:"0" > > 
fields:<key:"beam:option:auto_balance_write_files_sharding_enabled:v1" 
value:<bool_value:false > > fields:<key:"beam:option:beam_services:v1" 
value:<struct_value:<> > > fields:<key:"beam:option:dataflow_endpoint:v1" 
value:<string_value:"https://dataflow.googleapis.com"; > > 
fields:<key:"beam:option:direct_num_workers:v1" value:<string_value:"1" > > 
fields:<key:"beam:option:direct_runner_bundle_repeat:v1" 
value:<string_value:"0" > > 
fields:<key:"beam:option:direct_runner_use_stacked_bundle:v1" 
value:<bool_value:true > > fields:<key:"beam:option:direct_running_mode:v1" 
value:<string_value:"in_memory" > > 
fields:<key:"beam:option:disable_metrics:v1" value:<bool_value:false > > 
fields:<key:"beam:option:dry_run:v1" value:<bool_value:false > > 
fields:<key:"beam:option:enable_streaming_engine:v1" value:<bool_value:false > 
> fields:<key:"beam:option:environment_cache_millis:v1" value:<string_value:"0" 
> > fields:<key:"beam:option:expansion_port:v1" value:<string_value:"0" > > 
fields:<key:"beam:option:experiments:v1" 
value:<list_value:<values:<string_value:"beam_fn_api" > > > > 
fields:<key:"beam:option:externalized_checkpoints_enabled:v1" 
value:<bool_value:false > > 
fields:<key:"beam:option:fail_on_checkpointing_errors:v1" 
value:<bool_value:true > > fields:<key:"beam:option:flink_job_server_jar:v1" 
value:<string_value:"<https://builds.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/runners/flink/1.10/job-server/build/libs/beam-runners-flink-1.10-job-server-2.22.0-SNAPSHOT.jar";>
 > > fields:<key:"beam:option:flink_master:v1" value:<string_value:"[auto]" > > 
fields:<key:"beam:option:flink_submit_uber_jar:v1" value:<bool_value:false > > 
fields:<key:"beam:option:flink_version:v1" value:<string_value:"1.10" > > 
fields:<key:"beam:option:gcs_performance_metrics:v1" value:<bool_value:false > 
> fields:<key:"beam:option:hdfs_full_urls:v1" value:<bool_value:false > > 
fields:<key:"beam:option:job_name:v1" 
value:<string_value:"BeamApp-root-0430122124-ef28d500" > > 
fields:<key:"beam:option:job_port:v1" value:<string_value:"0" > > 
fields:<key:"beam:option:job_server_timeout:v1" value:<string_value:"60" > > 
fields:<key:"beam:option:load_balance_bundles:v1" value:<bool_value:false > > 
fields:<key:"beam:option:no_auth:v1" value:<bool_value:false > > 
fields:<key:"beam:option:object_reuse:v1" value:<bool_value:false > > 
fields:<key:"beam:option:options_id:v1" value:<number_value:1 > > 
fields:<key:"beam:option:output_executable_path:v1" 
value:<null_value:NULL_VALUE > > fields:<key:"beam:option:parallelism:v1" 
value:<string_value:"2" > > fields:<key:"beam:option:pipeline_type_check:v1" 
value:<bool_value:true > > fields:<key:"beam:option:profile_cpu:v1" 
value:<bool_value:false > > fields:<key:"beam:option:profile_memory:v1" 
value:<bool_value:false > > fields:<key:"beam:option:profile_sample_rate:v1" 
value:<number_value:1 > > fields:<key:"beam:option:retain_docker_containers:v1" 
value:<bool_value:false > > 
fields:<key:"beam:option:retain_externalized_checkpoints_on_cancellation:v1" 
value:<bool_value:false > > fields:<key:"beam:option:runner:v1" 
value:<null_value:NULL_VALUE > > 
fields:<key:"beam:option:runtime_type_check:v1" value:<bool_value:false > > 
fields:<key:"beam:option:save_main_session:v1" value:<bool_value:true > > 
fields:<key:"beam:option:sdk_location:v1" value:<string_value:"container" > > 
fields:<key:"beam:option:sdk_worker_parallelism:v1" value:<string_value:"1" > > 
fields:<key:"beam:option:shutdown_sources_on_final_watermark:v1" 
value:<bool_value:true > > fields:<key:"beam:option:spark_job_server_jar:v1" 
value:<string_value:"<https://builds.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/runners/spark/job-server/build/libs/beam-runners-spark-job-server-2.22.0-SNAPSHOT.jar";>
 > > fields:<key:"beam:option:spark_master_url:v1" 
value:<string_value:"local[4]" > > 
fields:<key:"beam:option:spark_submit_uber_jar:v1" value:<bool_value:false > > 
fields:<key:"beam:option:streaming:v1" value:<bool_value:true > > 
fields:<key:"beam:option:type_check_strictness:v1" 
value:<string_value:"DEFAULT_TO_ANY" > > fields:<key:"beam:option:update:v1" 
value:<bool_value:false > > > 
retrieval_token:"/tmp/beam-artifact-staging/job_5c433fff-590a-402f-a6ec-16bef69e1d0b/MANIFEST"
 logging_endpoint:<url:"localhost:38449" > 
artifact_endpoint:<url:"localhost:45359" > 
control_endpoint:<url:"localhost:44587" >'
INFO:apache_beam.utils.subprocess_server:b'2020/04/30 12:21:30 Initializing 
python harness: /opt/apache/beam/boot --id=1-1 
--provision_endpoint=localhost:35897'
INFO:apache_beam.utils.subprocess_server:b'2020/04/30 12:21:30 Installing setup 
packages ...'
INFO:apache_beam.utils.subprocess_server:b'2020/04/30 12:21:30 Found artifact: 
pickled_main_session'
INFO:apache_beam.utils.subprocess_server:b'2020/04/30 12:21:30 Executing: 
python -m apache_beam.runners.worker.sdk_worker_main'
INFO:apache_beam.utils.subprocess_server:b'Exception in thread 
read_grpc_client_inputs:'
INFO:apache_beam.utils.subprocess_server:b'Traceback (most recent call last):'
INFO:apache_beam.utils.subprocess_server:b'  File 
"/usr/local/lib/python3.5/threading.py", line 914, in _bootstrap_inner'
INFO:apache_beam.utils.subprocess_server:b'    self.run()'
INFO:apache_beam.utils.subprocess_server:b'  File 
"/usr/local/lib/python3.5/threading.py", line 862, in run'
INFO:apache_beam.utils.subprocess_server:b'    self._target(*self._args, 
**self._kwargs)'
INFO:apache_beam.utils.subprocess_server:b'  File 
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/data_plane.py",
 line 545, in <lambda>'
INFO:apache_beam.utils.subprocess_server:b'    target=lambda: 
self._read_inputs(elements_iterator),'
INFO:apache_beam.utils.subprocess_server:b'  File 
"/usr/local/lib/python3.5/site-packages/apache_beam/runners/worker/data_plane.py",
 line 528, in _read_inputs'
INFO:apache_beam.utils.subprocess_server:b'    for elements in 
elements_iterator:'
INFO:apache_beam.utils.subprocess_server:b'  File 
"/usr/local/lib/python3.5/site-packages/grpc/_channel.py", line 388, in 
__next__'
INFO:apache_beam.utils.subprocess_server:b'    return self._next()'
INFO:apache_beam.utils.subprocess_server:b'  File 
"/usr/local/lib/python3.5/site-packages/grpc/_channel.py", line 365, in _next'
INFO:apache_beam.utils.subprocess_server:b'    raise self'
INFO:apache_beam.utils.subprocess_server:b'grpc._channel._Rendezvous: 
<_Rendezvous of RPC that terminated with:'
INFO:apache_beam.utils.subprocess_server:b'\tstatus = StatusCode.UNAVAILABLE'
INFO:apache_beam.utils.subprocess_server:b'\tdetails = "DNS resolution failed"'
INFO:apache_beam.utils.subprocess_server:b'\tdebug_error_string = 
"{"created":"@1588249291.564934569","description":"Failed to pick 
subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3876,"referenced_errors":[{"created":"@1588249291.564930139","description":"Resolver
 transient 
failure","file":"src/core/ext/filters/client_channel/resolving_lb_policy.cc","file_line":263,"referenced_errors":[{"created":"@1588249291.564928711","description":"DNS
 resolution 
failed","file":"src/core/ext/filters/client_channel/resolver/dns/c_ares/dns_resolver_ares.cc","file_line":357,"grpc_status":14,"referenced_errors":[{"created":"@1588249291.564922160","description":"C-ares
 status is not ARES_SUCCESS: Misformatted domain 
name","file":"src/core/ext/filters/client_channel/resolver/dns/c_ares/grpc_ares_wrapper.cc","file_line":244,"referenced_errors":[{"created":"@1588249291.564905352","description":"C-ares
 status is not ARES_SUCCESS: Misformatted domain 
name","file":"src/core/ext/filters/client_channel/resolver/dns/c_ares/grpc_ares_wrapper.cc","file_line":244}]}]}]}]}"'
INFO:apache_beam.utils.subprocess_server:b'>'
INFO:apache_beam.utils.subprocess_server:b''
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
[1]write/Write/WriteImpl/FinalizeWrite (1/2) (6afdb4371424f9def3f2fa53f58fdc20) 
switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for [1]write/Write/WriteImpl/FinalizeWrite (1/2) 
(6afdb4371424f9def3f2fa53f58fdc20).'
INFO:apache_beam.utils.subprocess_server:b'[[1]write/Write/WriteImpl/FinalizeWrite
 (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task [1]write/Write/WriteImpl/FinalizeWrite 
(1/2) (6afdb4371424f9def3f2fa53f58fdc20) [FINISHED]'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task 
and sending final execution state FINISHED to JobManager for task 
[1]write/Write/WriteImpl/FinalizeWrite (1/2) 6afdb4371424f9def3f2fa53f58fdc20.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[1]write/Write/WriteImpl/FinalizeWrite (1/2) (6afdb4371424f9def3f2fa53f58fdc20) 
switched from RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
BeamApp-root-0430122124-ef28d500 (215ef8b75f32a5beac19958e5d362d9e) switched 
from state RUNNING to FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping 
checkpoint coordinator for job 215ef8b75f32a5beac19958e5d362d9e.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - 
Shutting down'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-6]
 INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink 
Mini Cluster'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-6]
 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting 
down rest endpoint.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 
215ef8b75f32a5beac19958e5d362d9e reached globally terminal state FINISHED.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping 
TaskExecutor akka://flink/user/taskmanager_0.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close 
ResourceManager connection 089759b3095a9d76ba2df985232238b9.'
INFO:apache_beam.utils.subprocess_server:b'[flink-runner-job-invoker] INFO 
org.apache.beam.runners.flink.FlinkPipelineRunner - Execution finished in 4519 
msecs'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - 
Closing TaskExecutor connection ca31670c-eb1b-4d8e-b374-165cbd009e20 because: 
The TaskExecutor is shutting down.'
INFO:apache_beam.utils.subprocess_server:b'[flink-runner-job-invoker] INFO 
org.apache.beam.runners.flink.FlinkPipelineRunner - Final accumulator values:'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for 
job BeamApp-root-0430122124-ef28d500(215ef8b75f32a5beac19958e5d362d9e).'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Suspending 
SlotPool.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager 
connection 089759b3095a9d76ba2df985232238b9: JobManager is shutting down..'
INFO:apache_beam.utils.subprocess_server:b'[flink-runner-job-invoker] INFO 
org.apache.beam.runners.flink.FlinkPipelineRunner - __metricscontainers : 
MetricQueryResults(Counters(36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_11}: 1, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_format_14}: 2, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_1/SplitAndSize0:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: 1, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_10}: 1, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:user:sum_int64:v1
 {NAMESPACE=__main__.WordExtractingDoFn, 
PTRANSFORM=ref_AppliedPTransform_split_7, NAME=words}: 131, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_22}: 2, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_pair_with_one_8}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_24}:
 4, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_24}:
 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:user:sum_int64:v1
 {NAMESPACE=__main__.WordExtractingDoFn, 
PTRANSFORM=ref_AppliedPTransform_split_7, NAME=word_lengths}: 418, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_split_7}: 2, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_split_7}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_19:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_1/SplitAndSize0:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_13:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1/SplitAndSize0:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_pair_with_one_8}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_19:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/SplitAndSize0}:
 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: 2, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33}: 99, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_format_14}: 2, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_24}:
 4, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Extract_31}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/SplitAndSize0}:
 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_21:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_19:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_24}:
 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_split_7}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_21:0}: 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: 1, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/DoOnce/Map(decode)_22}: 
0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_19:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/SplitAndSize0}:
 2, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_13:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/DoOnce/FlatMap(<lambda 
at core.py:2714>)_20}: 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_16:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_13}: 1, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_7:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/DoOnce/FlatMap(<lambda 
at core.py:2714>)_20}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/PairWithRestriction0}:
 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_1}: 1, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32}: 4, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_13:0}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_20:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/ProcessSizedElementsAndRestrictions0}:
 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_16:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1/SplitAndSize0:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/DoOnce/Map(decode)_22}: 
0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Pair_26}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:user:sum_int64:v1
 {NAMESPACE=__main__.WordExtractingDoFn, 
PTRANSFORM=ref_AppliedPTransform_split_7, NAME=empty_lines}: 3, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Pair_26}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_21}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33}: 
339, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/PairWithRestriction0}:
 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: 1, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32}: 330, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/ProcessSizedElementsAndRestrictions0}:
 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: 1, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_19}: 1, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1/SplitAndSize0:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_count_13}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/InitializeWrite_23}: 
0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/DoOnce/Map(decode)_22}: 
11, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1/SplitAndSize0:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_1/SplitAndSize0}: 1, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/DoOnce/FlatMap(<lambda 
at core.py:2714>)_20}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/ProcessSizedElementsAndRestrictions0}:
 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Pair_26}: 7, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25}: 51, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/PairWithRestriction0}:
 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_20:0}: 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_14}: 50, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_count_13}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_count_13}: 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_15}: 2, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_20:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_format_14}: 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_16}: 2, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_20:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_13:0}: 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_16:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_10:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_4:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_count_13}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/ProcessSizedElementsAndRestrictions0}:
 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_33}: 
438, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_3}: 131, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/InitializeWrite_23}: 
0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_10:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_2}: 34, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_4}: 131, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_32}: 334, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_1/SplitAndSize0}: 1, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/PairWithRestriction0}:
 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_14}: 50, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)_6/SplitAndSize0}:
 2, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/DoOnce/Map(decode)_22}: 
11, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/DoOnce/FlatMap(<lambda 
at core.py:2714>)_20}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Extract_31}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_21:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_split_7}: 2, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_16:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_10:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_pair_with_one_8}: 2, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_10:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/InitializeWrite_23}: 
11, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_9}: 50, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_8}: 50, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25}: 51, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_4:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_1/PairWithRestriction0}: 1, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_pair_with_one_8}: 2, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_7:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_1/SplitAndSize0:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_7:0}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_7:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_1/SplitAndSize0:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_21:0}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Extract_31}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_4:0}: 0, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_4:0}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Extract_31}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_25}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_7}: 50, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_format_14}: 0, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Pair_26}: 7, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/InitializeWrite_23}: 
11)Distributions(40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: DistributionResult{sum=15, 
count=1, min=15, max=15}, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_14}: DistributionResult{sum=740, 
count=35, min=19, max=25}, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_1/PairWithRestriction0}: 
DistributionResult{sum=916, count=1, min=916, max=916}, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_16}: DistributionResult{sum=322, 
count=2, min=161, max=161}, 
46write/Write/WriteImpl/WindowInto(WindowIntoFn).None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_15}: DistributionResult{sum=320, 
count=2, min=160, max=160}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_13}: DistributionResult{sum=115, 
count=1, min=115, max=115}, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_1}: DistributionResult{sum=13, 
count=1, min=13, max=13}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: DistributionResult{sum=15, 
count=1, min=15, max=15}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: DistributionResult{sum=15, 
count=1, min=15, max=15}, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_3}: DistributionResult{sum=577, 
count=35, min=14, max=20}, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_2}: DistributionResult{sum=623, 
count=15, min=14, max=84}, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: DistributionResult{sum=320, 
count=2, min=160, max=160}, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_4}: DistributionResult{sum=735, 
count=40, min=16, max=22}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_21}: DistributionResult{sum=0, 
count=0, min=9223372036854775807, max=-9223372036854775808}, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:user:distribution_int64:v1
 {NAMESPACE=__main__.WordExtractingDoFn, 
PTRANSFORM=ref_AppliedPTransform_split_7, NAME=word_len_dist}: 
DistributionResult{sum=418, count=131, min=1, max=10}, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_19}: DistributionResult{sum=317, 
count=1, min=317, max=317}, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_14}: DistributionResult{sum=737, 
count=36, min=18, max=27}, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/SplitAndSize0/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_1/SplitAndSize0}: 
DistributionResult{sum=760, count=1, min=760, max=760}, 
42read/Read/_SDFBoundedSourceWrapper/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_1/SplitAndSize0}: 
DistributionResult{sum=759, count=1, min=759, max=759}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_22}: DistributionResult{sum=174, 
count=2, min=87, max=87}, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_7}: DistributionResult{sum=801, 
count=33, min=20, max=29}, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_10}: DistributionResult{sum=13, 
count=1, min=13, max=13}, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_8}: DistributionResult{sum=838, 
count=43, min=17, max=26}, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_11}: DistributionResult{sum=14, 
count=1, min=14, max=14}, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_9}: DistributionResult{sum=759, 
count=37, min=18, max=27}, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: DistributionResult{sum=14, 
count=1, min=14, max=14}))'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Free slot 
TaskSlot(index:1, state:ACTIVE, resource profile: 
ResourceProfile{managedMemory=64.000mb (67108864 bytes), networkMemory=32.000mb 
(33554432 bytes)}, allocationId: b0375659e6998ffcae5d0c98bd83236d, jobId: 
215ef8b75f32a5beac19958e5d362d9e).'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - 
Disconnect job manager 
99d0b878c55f6fab0f5a41a5003940e9@akka://flink/user/jobmanager_1 for job 
215ef8b75f32a5beac19958e5d362d9e from the resource manager.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Stopping 
SlotPool.'
INFO:apache_beam.utils.subprocess_server:b'[mini-cluster-io-thread-16] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 
215ef8b75f32a5beac19958e5d362d9e with leader id 
99d0b878c55f6fab0f5a41a5003940e9 lost leadership.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Free slot 
TaskSlot(index:0, state:ACTIVE, resource profile: 
ResourceProfile{managedMemory=64.000mb (67108864 bytes), networkMemory=32.000mb 
(33554432 bytes)}, allocationId: a4440b19c8a2d2acb09feebd68fecfb9, jobId: 
215ef8b75f32a5beac19958e5d362d9e).'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager 
connection for job 215ef8b75f32a5beac19958e5d362d9e.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager 
connection for job 215ef8b75f32a5beac19958e5d362d9e.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader 
service.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - 
Shutting down TaskExecutorLocalStateStoresManager.'
INFO:apache_beam.utils.subprocess_server:b'[ForkJoinPool.commonPool-worker-9] 
INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing 
cache directory /tmp/flink-web-ui'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl - 
FileChannelManager removed spill file directory 
/tmp/flink-io-eff97e32-8b23-4c34-8071-eaeb7f330dd5'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.io.network.NettyShuffleEnvironment - Shutting 
down the network environment and its components.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-6]
 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down 
complete.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Shut 
down cluster because application is in CANCELED, diagnostics 
DispatcherResourceManagerComponent has been closed..'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl - 
FileChannelManager removed spill file directory 
/tmp/flink-netty-shuffle-2ddaa3f7-e319-4839-9562-e24acd3b836f'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.KvStateService - Shutting down the 
kvState service and its components.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader 
service.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-6]
 INFO 
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
 - Closing components.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.filecache.FileCache - removed file cache 
directory /tmp/flink-dist-cache-b15e946f-f397-4051-a684-7b7900d0d217'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-4]
 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor 
akka://flink/user/taskmanager_0.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-6]
 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess 
- Stopping SessionDispatcherLeaderProcess.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping 
dispatcher akka://flink/user/dispatcher.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all 
currently running jobs of dispatcher akka://flink/user/dispatcher.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - 
Closing the SlotManager.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - 
Suspending the SlotManager.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO 
org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator
 - Shutting down back pressure request coordinator.'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-3]
 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped 
dispatcher akka://flink/user/dispatcher.'
INFO:apache_beam.utils.subprocess_server:b'[mini-cluster-io-thread-2] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.'
INFO:apache_beam.utils.subprocess_server:b'[flink-metrics-2] INFO 
akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote 
daemon.'
INFO:apache_beam.utils.subprocess_server:b'[flink-metrics-2] INFO 
akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut 
down; proceeding with flushing remote transports.'
INFO:apache_beam.utils.subprocess_server:b'[flink-metrics-2] INFO 
akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.'
INFO:apache_beam.utils.subprocess_server:b'[flink-metrics-2] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.'
INFO:apache_beam.utils.subprocess_server:b'[flink-metrics-2] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.'
INFO:apache_beam.utils.subprocess_server:b'[flink-runner-job-invoker] INFO 
org.apache.beam.runners.fnexecution.artifact.AbstractLegacyArtifactRetrievalService
 - Manifest at 
/tmp/beam-artifact-staging/job_5c433fff-590a-402f-a6ec-16bef69e1d0b/MANIFEST 
has 1 artifact locations'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB 
cache'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB 
cache'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 
0.0.0.0:35689'
INFO:apache_beam.utils.subprocess_server:b'[flink-akka.actor.default-dispatcher-2]
 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC 
service.'
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-1] INFO 
org.apache.beam.runners.fnexecution.jobsubmission.InMemoryJobService - Getting 
job metrics for 
BeamApp-root-0430122124-ef28d500_09d8da48-7158-43ef-aea6-6ec6ca20bcdf'
INFO:apache_beam.utils.subprocess_server:b'[grpc-default-executor-1] INFO 
org.apache.beam.runners.fnexecution.jobsubmission.InMemoryJobService - Finished 
getting job metrics for 
BeamApp-root-0430122124-ef28d500_09d8da48-7158-43ef-aea6-6ec6ca20bcdf'
INFO:root:number of empty lines: 3
INFO:root:average word length: 3

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':sdks:python:container:py35:docker'.
> Process 'command 'docker'' finished with non-zero exit value 2

* 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 1m 48s
85 actionable tasks: 22 executed, 63 up-to-date

Publishing build scan...
https://gradle.com/s/5yzfdivwumnye

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

Reply via email to