Build failed in Jenkins: beam_PreCommit_Portable_Python_Cron #804

Apache Jenkins Server Thu, 20 Jun 2019 06:11:53 -0700

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


Changes:

[github] [BEAM-7603] Adding support for ValueProvider in Custom GCS Temp 
Location

[github] Add link to gRPC.io on website portability page

[agoos] [BEAM7597] Fix Typo on website

------------------------------------------
[...truncated 988.25 KB...]
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) 
(f0773a2555875d8e785e72e771d5f462) [FINISHED]
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (1/2) 
(af92aa4525ef3de7098c4200591a56c8) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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_43-side0 -> Map 
2d228bce30df28207ec95bed3c182e4d.
[flink-akka.actor.default-dispatcher-7] 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_42-side0 -> Map 
f0773a2555875d8e785e72e771d5f462.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[2]write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2254>), 
Map(decode)} -> [1]write/Write/WriteImpl/InitializeWrite -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
(01a12755abacacec8b91a95e22697548) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] 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_34-side0 -> Map 
af92aa4525ef3de7098c4200591a56c8.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (1/2) 
(2d228bce30df28207ec95bed3c182e4d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (1/2) 
(f0773a2555875d8e785e72e771d5f462) switched from RUNNING to FINISHED.
[[3]{read, split, pair_with_one} -> ToKeyedWorkItem (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - [3]{read, split, pair_with_one} -> 
ToKeyedWorkItem (1/2) (a9233dd99caad9b78dad7ff9445f9f1c) switched from RUNNING 
to FINISHED.
[[3]{read, split, pair_with_one} -> ToKeyedWorkItem (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
[3]{read, split, pair_with_one} -> ToKeyedWorkItem (1/2) 
(a9233dd99caad9b78dad7ff9445f9f1c).
[[3]{read, split, pair_with_one} -> ToKeyedWorkItem (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are 
closed for task [3]{read, split, pair_with_one} -> ToKeyedWorkItem (1/2) 
(a9233dd99caad9b78dad7ff9445f9f1c) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (1/2) 
(af92aa4525ef3de7098c4200591a56c8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task [3]{read, split, 
pair_with_one} -> ToKeyedWorkItem a9233dd99caad9b78dad7ff9445f9f1c.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - [3]{read, split, 
pair_with_one} -> ToKeyedWorkItem (1/2) (a9233dd99caad9b78dad7ff9445f9f1c) 
switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (2/2) 
(a7f93b247a5b3216c9c47039dbab73d7) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(2/2) (a7f93b247a5b3216c9c47039dbab73d7).
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(dd714ec27cd0cac461fa4095c43e93ca) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(dd714ec27cd0cac461fa4095c43e93ca).
[ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (2/2) 
(a7f93b247a5b3216c9c47039dbab73d7) [FINISHED]
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(dd714ec27cd0cac461fa4095c43e93ca) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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_34-side0 -> Map 
a7f93b247a5b3216c9c47039dbab73d7.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) 
(c564efb48ad3f60ae24ed140b135c0c1) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2) (c564efb48ad3f60ae24ed140b135c0c1).
[flink-akka.actor.default-dispatcher-7] 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_42-side0 -> Map 
dd714ec27cd0cac461fa4095c43e93ca.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) 
(c564efb48ad3f60ae24ed140b135c0c1) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34-side0 -> Map (2/2) 
(a7f93b247a5b3216c9c47039dbab73d7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] 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_43-side0 -> Map 
c564efb48ad3f60ae24ed140b135c0c1.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side0 -> Map (2/2) 
(dd714ec27cd0cac461fa4095c43e93ca) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side0 -> Map (2/2) 
(c564efb48ad3f60ae24ed140b135c0c1) switched from RUNNING to FINISHED.
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/write/ref_PCollection_PCollection_24:0 
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/write/ref_PCollection_PCollection_24:0 
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:element_count:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/FinalizeWrite, 0]
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:ptransform_execution_time:total_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/FinalizeWrite, 0]
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 
'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/FinalizeWrite, 0]
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/FinalizeWrite, 0]
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/FinalizeWrite, 0]
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:sampled_byte_size:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/FinalizeWrite, 0]
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/write/ref_PCollection_PCollection_17:0 
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/write/ref_PCollection_PCollection_17:0 
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/read/ref_PCollection_PCollection_17:0 
[[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:ptransform_execution_time:total_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/PreFinalize, 0]
[[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/PreFinalize, 0]
[[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/PreFinalize, 0]
[[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 
'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/PreFinalize, 0]
[[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:element_count:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/PreFinalize, 0]
[[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:sampled_byte_size:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/PreFinalize, 0]
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/read/ref_PCollection_PCollection_17:0 
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/read/ref_PCollection_PCollection_15:0 
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/read/ref_PCollection_PCollection_15:0 
[group -> [2]{count, format} (2/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 1]
[group -> [2]{count, format} (2/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 1]
[group -> [2]{count, format} (2/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:ptransform_execution_time:total_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 1]
[group -> [2]{count, format} (2/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 1]
[group -> [2]{count, format} (2/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:element_count:v1'. Metric will not be reported.[localhost, 
taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 1]
[group -> [2]{count, format} (2/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:sampled_byte_size:v1'. Metric will not be reported.[localhost, 
taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 1]
[group -> [2]{count, format} (1/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 0]
[group -> [2]{count, format} (1/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 0]
[group -> [2]{count, format} (1/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:ptransform_execution_time:total_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 0]
[group -> [2]{count, format} (1/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 0]
[group -> [2]{count, format} (1/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:element_count:v1'. Metric will not be reported.[localhost, 
taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 0]
[group -> [2]{count, format} (1/2)] WARN org.apache.flink.metrics.MetricGroup - 
Name collision: Group already contains a Metric with the name 
'beam.metric:sampled_byte_size:v1'. Metric will not be reported.[localhost, 
taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [2]{count, format}, 0]
[group -> [2]{count, format} (2/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - group -> [2]{count, format} (2/2) 
(0f9d6b0a5f8f2099cec8fc7b53652e17) switched from RUNNING to FINISHED.
[group -> [2]{count, format} (2/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for group -> 
[2]{count, format} (2/2) (0f9d6b0a5f8f2099cec8fc7b53652e17).
[group -> [2]{count, format} (2/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are 
closed for task group -> [2]{count, format} (2/2) 
(0f9d6b0a5f8f2099cec8fc7b53652e17) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task group -> 
[2]{count, format} 0f9d6b0a5f8f2099cec8fc7b53652e17.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - group -> [2]{count, 
format} (2/2) (0f9d6b0a5f8f2099cec8fc7b53652e17) switched from RUNNING to 
FINISHED.
[group -> [2]{count, format} (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - group -> [2]{count, format} (1/2) 
(5036aa20e6e9e9c03a67b3e04d2c16ef) switched from RUNNING to FINISHED.
[group -> [2]{count, format} (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for group -> 
[2]{count, format} (1/2) (5036aa20e6e9e9c03a67b3e04d2c16ef).
[group -> [2]{count, format} (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are 
closed for task group -> [2]{count, format} (1/2) 
(5036aa20e6e9e9c03a67b3e04d2c16ef) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task group -> 
[2]{count, format} 5036aa20e6e9e9c03a67b3e04d2c16ef.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - group -> [2]{count, 
format} (1/2) (5036aa20e6e9e9c03a67b3e04d2c16ef) switched from RUNNING to 
FINISHED.
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:element_count:v1'. Metric will not be reported.[localhost, 
taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 1]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 1]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 1]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:ptransform_execution_time:total_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 1]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 1]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:sampled_byte_size:v1'. Metric will not be reported.[localhost, 
taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 1]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:element_count:v1'. Metric will not be reported.[localhost, 
taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 0]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 0]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 0]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:ptransform_execution_time:total_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 0]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 0]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] WARN org.apache.flink.metrics.MetricGroup - Name 
collision: Group already contains a Metric with the name 
'beam.metric:sampled_byte_size:v1'. Metric will not be reported.[localhost, 
taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)}, 0]
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2) (f6b54e0a6ff8e4d87adb7ab1ad5522cf) switched from RUNNING 
to FINISHED.
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing 
task resources for [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)} -> ToKeyedWorkItem (2/2) 
(f6b54e0a6ff8e4d87adb7ab1ad5522cf).
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task 
[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2) (f6b54e0a6ff8e4d87adb7ab1ad5522cf) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem f6b54e0a6ff8e4d87adb7ab1ad5522cf.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (2/2) (f6b54e0a6ff8e4d87adb7ab1ad5522cf) switched from RUNNING 
to FINISHED.
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2) (713f53252c32afe28d81ccc5dc03fabc) switched from RUNNING 
to FINISHED.
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing 
task resources for [3]write/Write/WriteImpl/{WriteBundles, Pair, 
WindowInto(WindowIntoFn)} -> ToKeyedWorkItem (1/2) 
(713f53252c32afe28d81ccc5dc03fabc).
[[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task 
[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2) (713f53252c32afe28d81ccc5dc03fabc) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem 713f53252c32afe28d81ccc5dc03fabc.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[3]write/Write/WriteImpl/{WriteBundles, Pair, WindowInto(WindowIntoFn)} -> 
ToKeyedWorkItem (1/2) (713f53252c32afe28d81ccc5dc03fabc) switched from RUNNING 
to FINISHED.
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/write/ref_PCollection_PCollection_28:0 
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/write/ref_PCollection_PCollection_28:0 
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique 
name set for transform fn/read/ref_PCollection_PCollection_27:0 
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique 
name set for transform fn/read/ref_PCollection_PCollection_27:0 
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/Extract, 1]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:ptransform_execution_time:total_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/Extract, 1]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:element_count:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/Extract, 1]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 
'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/Extract, 1]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/Extract, 1]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:sampled_byte_size:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/Extract, 1]
[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) (fbc79aeb04df3667497485f705def584) switched from RUNNING 
to FINISHED.
[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) 
(fbc79aeb04df3667497485f705def584).
[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) (fbc79aeb04df3667497485f705def584) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) fbc79aeb04df3667497485f705def584.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2) 
(fbc79aeb04df3667497485f705def584) switched from RUNNING to FINISHED.
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:pardo_execution_time:finish_bundle_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/Extract, 0]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:ptransform_execution_time:total_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/Extract, 0]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:element_count:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/Extract, 0]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 
'beam.metric:pardo_execution_time:process_bundle_msecs:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/Extract, 0]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:pardo_execution_time:start_bundle_msecs:v1'. 
Metric will not be reported.[localhost, taskmanager, 
fab779ce-67b6-4b29-afff-fd9c7bde8e88, BeamApp-root-0620131131-ace8fae8, 
[1]write/Write/WriteImpl/Extract, 0]
[write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map 
-> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)] WARN 
org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a 
Metric with the name 'beam.metric:sampled_byte_size:v1'. Metric will not be 
reported.[localhost, taskmanager, fab779ce-67b6-4b29-afff-fd9c7bde8e88, 
BeamApp-root-0620131131-ace8fae8, [1]write/Write/WriteImpl/Extract, 0]
[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) (cd84185765eeda4b32cf45c98c981546) switched from RUNNING 
to FINISHED.
[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) 
(cd84185765eeda4b32cf45c98c981546).
[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) (cd84185765eeda4b32cf45c98c981546) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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) cd84185765eeda4b32cf45c98c981546.
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) 
(4877f42f4a7b0a9cd1541db681be653d) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) 
(4877f42f4a7b0a9cd1541db681be653d).
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) 
(4877f42f4a7b0a9cd1541db681be653d) [FINISHED]
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) 
(0190a772a63784ebc9dbffd56af2d7e2) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) 
(0190a772a63784ebc9dbffd56af2d7e2).
[ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2)] 
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) 
(0190a772a63784ebc9dbffd56af2d7e2) [FINISHED]
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) 
(1a3cd53fc7a7d90025c64d4169d83557) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2) (1a3cd53fc7a7d90025c64d4169d83557).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) 
(1a3cd53fc7a7d90025c64d4169d83557) [FINISHED]
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (1/2) 
(139b4750185a3cd986bf3df55c8eab7f) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(1/2) (139b4750185a3cd986bf3df55c8eab7f).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (1/2) 
(139b4750185a3cd986bf3df55c8eab7f) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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_42-side1 -> Map 
4877f42f4a7b0a9cd1541db681be653d.
[flink-akka.actor.default-dispatcher-7] 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_42-side1 -> Map 
0190a772a63784ebc9dbffd56af2d7e2.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
write/Write/WriteImpl/GroupByKey -> [1]write/Write/WriteImpl/Extract -> (Map -> 
ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2) 
(cd84185765eeda4b32cf45c98c981546) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] 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_43-side1 -> Map 
1a3cd53fc7a7d90025c64d4169d83557.
[flink-akka.actor.default-dispatcher-7] 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_43-side1 -> Map 
139b4750185a3cd986bf3df55c8eab7f.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (1/2) 
(4877f42f4a7b0a9cd1541db681be653d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/PreFinalize_42-side1 -> Map (2/2) 
(0190a772a63784ebc9dbffd56af2d7e2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (2/2) 
(1a3cd53fc7a7d90025c64d4169d83557) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side1 -> Map (1/2) 
(139b4750185a3cd986bf3df55c8eab7f) switched from RUNNING to FINISHED.
[[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) 
(b1a6bcaacfcd3393f2ebf46c9286bc5e) switched from RUNNING to FINISHED.
[[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) 
(b1a6bcaacfcd3393f2ebf46c9286bc5e).
[[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) (b1a6bcaacfcd3393f2ebf46c9286bc5e) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem 
b1a6bcaacfcd3393f2ebf46c9286bc5e.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (2/2) 
(b1a6bcaacfcd3393f2ebf46c9286bc5e) switched from RUNNING to FINISHED.
[[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) 
(5207744047610b786e5521055276bd6d) switched from RUNNING to FINISHED.
[[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) 
(5207744047610b786e5521055276bd6d).
[[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) (5207744047610b786e5521055276bd6d) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem 
5207744047610b786e5521055276bd6d.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) 
(5d0555ebe544fe0cbf9f5b9ccb9a0b7a) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) 
(af34a37315cf0e94673cbd0a4d31ef64) switched from RUNNING to FINISHED.
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2) (5d0555ebe544fe0cbf9f5b9ccb9a0b7a).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2) (af34a37315cf0e94673cbd0a4d31ef64).
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) 
(5d0555ebe544fe0cbf9f5b9ccb9a0b7a) [FINISHED]
[ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem 
streams are closed for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) 
(af34a37315cf0e94673cbd0a4d31ef64) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map 
5d0555ebe544fe0cbf9f5b9ccb9a0b7a.
[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_43-side2 -> Map 
af34a37315cf0e94673cbd0a4d31ef64.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[1]write/Write/WriteImpl/PreFinalize -> Map -> ToKeyedWorkItem (1/2) 
(5207744047610b786e5521055276bd6d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (2/2) 
(5d0555ebe544fe0cbf9f5b9ccb9a0b7a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
ref_AppliedPTransform_write/Write/WriteImpl/FinalizeWrite_43-side2 -> Map (1/2) 
(af34a37315cf0e94673cbd0a4d31ef64) switched from RUNNING to FINISHED.
[grpc-default-executor-0] INFO filebasedsink.finalize_write - Starting 
finalize_write threads with num_shards: 2 (skipped: 0), batches: 2, 
num_threads: 2
[[1]write/Write/WriteImpl/FinalizeWrite (2/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - 
[1]write/Write/WriteImpl/FinalizeWrite (2/2) (b92217a19735e29806b242e6d0ef296d) 
switched from RUNNING to FINISHED.
[[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) (b92217a19735e29806b242e6d0ef296d).
[[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) 
(b92217a19735e29806b242e6d0ef296d) [FINISHED]
[flink-akka.actor.default-dispatcher-6] 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 b92217a19735e29806b242e6d0ef296d.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[1]write/Write/WriteImpl/FinalizeWrite (2/2) (b92217a19735e29806b242e6d0ef296d) 
switched from RUNNING to FINISHED.
[grpc-default-executor-0] INFO filebasedsink.finalize_write - Renamed 2 shards 
in 0.12 seconds.
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] INFO 
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory - Closing 
environment urn: "beam:env:docker:v1"
payload: "\n3jenkins-docker-apache.bintray.io/beam/python:latest"

[grpc-default-executor-0] INFO sdk_worker.run - No more requests from control 
plane
[grpc-default-executor-0] INFO sdk_worker.run - SDK Harness waiting for 
in-flight requests to complete
[grpc-default-executor-0] INFO data_plane.close - Closing all cached grpc data 
channels.
[grpc-default-executor-0] WARN 
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown 
endpoint.
[grpc-default-executor-0] INFO sdk_worker.close - Closing all cached gRPC state 
handlers.
[grpc-default-executor-0] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-0] INFO sdk_worker_main.main - Python sdk harness 
exiting.
[grpc-default-executor-0] INFO 
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client 
hanged up.
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] WARN 
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown 
endpoint.
[[1]write/Write/WriteImpl/FinalizeWrite (1/2)] INFO 
org.apache.flink.runtime.taskmanager.Task - 
[1]write/Write/WriteImpl/FinalizeWrite (1/2) (d073081884dffcd7891efa425f47b5d8) 
switched from RUNNING to FINISHED.
[[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) (d073081884dffcd7891efa425f47b5d8).
[[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) 
(d073081884dffcd7891efa425f47b5d8) [FINISHED]
[flink-akka.actor.default-dispatcher-6] 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 d073081884dffcd7891efa425f47b5d8.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
[1]write/Write/WriteImpl/FinalizeWrite (1/2) (d073081884dffcd7891efa425f47b5d8) 
switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
BeamApp-root-0620131131-ace8fae8 (d2af17b4f919815c6c1b46496cb0ebd6) switched 
from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint 
coordinator for job d2af17b4f919815c6c1b46496cb0ebd6.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - 
Shutting down
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 
d2af17b4f919815c6c1b46496cb0ebd6 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job 
BeamApp-root-0620131131-ace8fae8(d2af17b4f919815c6c1b46496cb0ebd6).
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager 
connection for job d2af17b4f919815c6c1b46496cb0ebd6.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 
49d632c845d689363e9e273568f6e714: JobManager is shutting down..
[flink-runner-job-invoker] INFO 
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini 
Cluster
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-invoker] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest 
endpoint.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect 
job manager b050a9f6d294faa96c820396b9f84c24@akka://flink/user/jobmanager_1 for 
job d2af17b4f919815c6c1b46496cb0ebd6 from the resource manager.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher 
akka://flink/user/dispatcher1272b6b4-adda-4373-bae0-df077f718e7e.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all 
currently running jobs of dispatcher 
akka://flink/user/dispatcher1272b6b4-adda-4373-bae0-df077f718e7e.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 
d2af17b4f919815c6c1b46496cb0ebd6 with leader id 
b050a9f6d294faa96c820396b9f84c24 lost leadership.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot 
TaskSlot(index:0, state:ALLOCATED, resource profile: 
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, 
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: 
AllocationID{1c491f4c9eee56bbc7071ac6f0215f17}, jobId: 
d2af17b4f919815c6c1b46496cb0ebd6).
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot 
TaskSlot(index:1, state:ALLOCATED, resource profile: 
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, 
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: 
AllocationID{cca361c866b85d67a0f218a77be2ce8a}, jobId: 
d2af17b4f919815c6c1b46496cb0ebd6).
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 
d2af17b4f919815c6c1b46496cb0ebd6 from job leader monitoring.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager 
connection for job d2af17b4f919815c6c1b46496cb0ebd6.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor 
akka://flink/user/taskmanager_0.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
 - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting 
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher 
akka://flink/user/dispatcher1272b6b4-adda-4373-bae0-df077f718e7e.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed 
spill file directory /tmp/flink-io-ad059297-3808-443e-a111-c701794678ee
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the 
network environment and its components.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the 
SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending 
the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader 
service.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor 
akka://flink/user/taskmanager_0.
[ForkJoinPool.commonPool-worker-2] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache 
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-2] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
[ForkJoinPool.commonPool-worker-2] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41965
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-invoker] INFO org.apache.beam.runners.flink.FlinkRunner - 
Execution finished in 5088 msecs
[flink-runner-job-invoker] INFO org.apache.beam.runners.flink.FlinkRunner - 
Final accumulator values:
[flink-runner-job-invoker] INFO org.apache.beam.runners.flink.FlinkRunner - 
__metricscontainers : 
MetricQueryResults(Counters(17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_2:0}: 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_20:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:user
 {NAMESPACE=__main__.WordExtractingDoFn, 
PTRANSFORM=ref_AppliedPTransform_split_17, NAME=empty_lines}: 3, 
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_20:0}: 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_42}: 1001, 
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_20:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: 1, 
6format.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_36}:
 238, 
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_42}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_format_24}: 6, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Pair_35}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: 1, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_21}: 1, 
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_20:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Pair_35}: 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_20:0}: 0, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_read/Read/Split_5}: 15, 
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)_32}: 
6, 
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_33}: 
0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_30}: 2, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_2: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_43}: 
1075, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:user
 {NAMESPACE=__main__.WordExtractingDoFn, 
PTRANSFORM=ref_AppliedPTransform_split_17, NAME=word_lengths}: 418, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_19}: 1, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_18}: 1, 
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_29:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_29}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Pair_35}: 0, 
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_43}: 
111, 
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_29:0}: 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_27:0}: 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_27:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_read/Read/Split_5}: 17, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_28}: 2, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_read/Read/ReadSplits_16}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_read/Read/ReadSplits_16}: 0, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_27}: 1, 
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:2254>)_30}: 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_33}: 
22, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_read/Read/ReadSplits_16}: 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:2254>)_30}: 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:2254>)_30}: 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_20: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_27:0}: 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_20:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_36}:
 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_43}: 0, 
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_20: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_20:0}: 0, 
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_20:0}: 0, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: 1, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_17:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_17: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)_32}: 
0, 
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_21:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_36}:
 238, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/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_20}: 1, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 
{PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WindowInto(WindowIntoFn)_36}:
 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_27:0}: 0, 
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_21:0}: 0, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_2:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_9: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_28:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_9:0}: 0, 
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_42}: 7, 
6format.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34}: 25, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_9:0}: 0, 
17read/Read/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, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0, 
17read/Read/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, 
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)_32}: 
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_28:0}: 0, 
17read/Read/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, 
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_33}: 
0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_10}: 34, 
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_28:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_15:0}: 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_43}: 
1186, 6format.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_24}: 2, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_11}: 131, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_split_17}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_count_23}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: 131, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_split_17}: 26, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_read/Read/Split_5}: 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_28:0}: 0, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_read/Read/Split_5}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_count_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_18:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_split_17}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/WriteBundles_34}: 25, 
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_18:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_17}: 50, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_read/Read/ReadSplits_16}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_count_23}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.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:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_17:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_16}: 50, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_15}: 50, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_count_23}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_17}: 50, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_format_24}: 2, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_split_17}: 26, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_17:0}: 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_20:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/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=fn/read/ref_PCollection_PCollection_18:0}: 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_29: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_20: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_21:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_pair_with_one_18}: 4, 
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_18: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_41}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_pair_with_one_18}: 0, 
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_42}: 1008, 
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_20:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:start_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_pair_with_one_18}: 4, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_1: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_20:0}: 0, 
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)_32}: 
6, 
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_20: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_41}: 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_41}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:element_count:v1
 {PCOLLECTION=ref_PCollection_PCollection_9}: 1, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_pair_with_one_18}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_format_24}: 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_29:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_9: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_15: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_15:0}: 0, 
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:2254>)_30}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_format_24}: 4, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_2: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_21:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_23}: 2, 
6format.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_22}: 2, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_2}: 1, 
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_33}: 
22, 
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_20:0}: 0, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:user
 {NAMESPACE=__main__.WordExtractingDoFn, 
PTRANSFORM=ref_AppliedPTransform_split_17, NAME=words}: 131, 
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_41}: 0, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:element_count:v1 
{PCOLLECTION=ref_PCollection_PCollection_1}: 1, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/write/ref_PCollection_PCollection_17:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0, 
6format.None/beam:env:docker:v1:0:beam:metric:ptransform_execution_time:total_msecs:v1
 {PTRANSFORM=ref_AppliedPTransform_write/Write/WriteImpl/Pair_35}: 0, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:pardo_execution_time:process_bundle_msecs:v1
 {PTRANSFORM=fn/read/ref_PCollection_PCollection_15:0}: 
0)Distributions(46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_27}: DistributionResult{sum=271, 
count=1, min=271, max=271}, 
46write/Write/WriteImpl/GroupByKey/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_28}: DistributionResult{sum=276, 
count=2, min=138, max=138}, 
6format.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 
{PCOLLECTION=ref_PCollection_PCollection_24}: DistributionResult{sum=278, 
count=2, min=139, max=139}, 
6format.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 
{PCOLLECTION=ref_PCollection_PCollection_22}: DistributionResult{sum=276, 
count=2, min=138, max=138}, 
6format.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 
{PCOLLECTION=ref_PCollection_PCollection_23}: DistributionResult{sum=278, 
count=2, min=139, max=139}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_30}: DistributionResult{sum=106, 
count=2, min=53, max=53}, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: DistributionResult{sum=14, 
count=1, min=14, max=14}, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:user_distribution
 {NAMESPACE=__main__.WordExtractingDoFn, 
PTRANSFORM=ref_AppliedPTransform_split_17, NAME=word_len_dist}: 
DistributionResult{sum=418, count=131, min=0, max=10}, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_17}: DistributionResult{sum=776, 
count=38, min=18, max=24}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: DistributionResult{sum=15, 
count=1, min=15, max=15}, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_16}: DistributionResult{sum=752, 
count=38, min=17, max=26}, 
19group/GroupByWindow.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_15}: DistributionResult{sum=958, 
count=39, 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_18}: DistributionResult{sum=13, 
count=1, min=13, max=13}, 
36write/Write/WriteImpl/DoOnce/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_19}: DistributionResult{sum=15, 
count=1, min=15, max=15}, 
17read/Read/Impulse.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 
{PCOLLECTION=ref_PCollection_PCollection_2}: DistributionResult{sum=685, 
count=1, min=685, max=685}, 
17read/Read/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}, 
6format.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1 
{PCOLLECTION=ref_PCollection_PCollection_17}: DistributionResult{sum=750, 
count=35, min=19, max=25}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_21}: DistributionResult{sum=81, 
count=1, min=81, max=81}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:1:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: DistributionResult{sum=15, 
count=1, min=15, max=15}, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_10}: DistributionResult{sum=924, 
count=24, min=14, max=84}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_29}: DistributionResult{sum=0, 
count=0, min=9223372036854775807, max=-9223372036854775808}, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_11}: DistributionResult{sum=749, 
count=46, min=14, max=23}, 
40write/Write/WriteImpl/DoOnce/Map(decode).None/beam:env:docker:v1:2:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_20}: DistributionResult{sum=15, 
count=1, min=15, max=15}, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_12}: DistributionResult{sum=833, 
count=45, min=16, max=25}, 
36read/Read/Reshuffle/RemoveRandomKeys.None/beam:env:docker:v1:0:beam:metric:sampled_byte_size:v1
 {PCOLLECTION=ref_PCollection_PCollection_9}: DistributionResult{sum=685, 
count=1, min=685, max=685}))
[flink-runner-job-invoker] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - Manifest at 
/tmp/beam-artifact-staging/job_fda6e3fd-6e47-4d31-a58f-79cfbd9ec379/MANIFEST 
has 1 artifact locations
[flink-runner-job-invoker] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
 - Removed dir 
/tmp/beam-artifact-staging/job_fda6e3fd-6e47-4d31-a58f-79cfbd9ec379/
INFO:root:Job state changed to DONE

FAILURE: Build failed with an exception.

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

* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug 
option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See 
https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 7m 26s
79 actionable tasks: 61 executed, 15 from cache, 3 up-to-date

Publishing build scan...
https://gradle.com/s/6zdk6bulzdxs4

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

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

Build failed in Jenkins: beam_PreCommit_Portable_Python_Cron #804

Reply via email to