Build failed in Jenkins: beam_PreCommit_Portable_Python_Cron #2047

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

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: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org

Jenkins build is back to normal : beam_PreCommit_Portable_Python_Cron #2048

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

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


---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org