See
<https://builds.apache.org/job/beam_PostCommit_Python2/23/display/redirect?page=changes>
Changes:
[github] Update Python 3 entry in Python SDK roadmap.
------------------------------------------
[...truncated 826.74 KB...]
[GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2) (1d254cfa7d3f332052317c9217dac864).
[GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2) (5b3e27af43dce77a4e1ff8ca5a2a3825) switched from RUNNING to FINISHED.
[GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2) (5b3e27af43dce77a4e1ff8ca5a2a3825).
[GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2) (1d254cfa7d3f332052317c9217dac864) [FINISHED]
[GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2) (5b3e27af43dce77a4e1ff8ca5a2a3825) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
1d254cfa7d3f332052317c9217dac864.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
5b3e27af43dce77a4e1ff8ca5a2a3825.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2) (1d254cfa7d3f332052317c9217dac864) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2) (5b3e27af43dce77a4e1ff8ca5a2a3825) switched from RUNNING to FINISHED.
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (c2e700e240f079dd6fa1712981461e2f) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (c2e700e240f079dd6fa1712981461e2f) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2).
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2) (c2e700e240f079dd6fa1712981461e2f) switched from
CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (c2e700e240f079dd6fa1712981461e2f) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task CHAIN MapPartition (MapPartition at [6]{Map(<lambda
at external_test.py:212>), Map(<lambda at external_test.py:213>), assert_that})
-> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(c2e700e240f079dd6fa1712981461e2f) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: CHAIN MapPartition (MapPartition at
[6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (c2e700e240f079dd6fa1712981461e2f) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2) (c2e700e240f079dd6fa1712981461e2f) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (c2e700e240f079dd6fa1712981461e2f) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] WARN org.apache.flink.metrics.MetricGroup - The
operator name MapPartition (MapPartition at [6]{Map(<lambda at
external_test.py:212>), Map(<lambda at external_test.py:213>), assert_that})
exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(bd182bf2e04f99d139c7f6366a540f8d) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(bd182bf2e04f99d139c7f6366a540f8d).
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(bd182bf2e04f99d139c7f6366a540f8d) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0])
bd182bf2e04f99d139c7f6366a540f8d.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(bd182bf2e04f99d139c7f6366a540f8d) switched from RUNNING to FINISHED.
[jobmanager-future-thread-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (5da02cdba751bbd092a57ab46a241172) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (5da02cdba751bbd092a57ab46a241172) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2).
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (5da02cdba751bbd092a57ab46a241172) switched from
CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (5da02cdba751bbd092a57ab46a241172) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task CHAIN MapPartition (MapPartition at [6]{Map(<lambda
at external_test.py:212>), Map(<lambda at external_test.py:213>), assert_that})
-> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(5da02cdba751bbd092a57ab46a241172) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: CHAIN MapPartition (MapPartition at
[6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (5da02cdba751bbd092a57ab46a241172) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (5da02cdba751bbd092a57ab46a241172) switched from
DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] WARN org.apache.flink.metrics.MetricGroup - The
operator name MapPartition (MapPartition at [6]{Map(<lambda at
external_test.py:212>), Map(<lambda at external_test.py:213>), assert_that})
exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (5da02cdba751bbd092a57ab46a241172) switched from DEPLOYING to RUNNING.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/write/ref_PCollection_PCollection_24:1:0
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(677cbece8abd74feb1d2460889985cea) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(677cbece8abd74feb1d2460889985cea).
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(677cbece8abd74feb1d2460889985cea) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0])
677cbece8abd74feb1d2460889985cea.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(677cbece8abd74feb1d2460889985cea) switched from RUNNING to FINISHED.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/write/ref_PCollection_PCollection_24:1:0
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/read/ref_PCollection_PCollection_14:0
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/read/ref_PCollection_PCollection_14:0
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2) (c2e700e240f079dd6fa1712981461e2f) switched from
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for CHAIN MapPartition (MapPartition at [6]{Map(<lambda
at external_test.py:212>), Map(<lambda at external_test.py:213>), assert_that})
-> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(c2e700e240f079dd6fa1712981461e2f).
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (c2e700e240f079dd6fa1712981461e2f) [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 CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) c2e700e240f079dd6fa1712981461e2f.
[jobmanager-future-thread-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(7cad7ed737d97e25142aca58f55ba0a4) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(e6bb127087b8ae021cc1101dd0bccd0a) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(7cad7ed737d97e25142aca58f55ba0a4) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(e6bb127087b8ae021cc1101dd0bccd0a) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2).
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (2/2) (e6bb127087b8ae021cc1101dd0bccd0a) switched
from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task GroupReduce (GroupReduce at assert_that/Group/GroupByKey)
(2/2) (e6bb127087b8ae021cc1101dd0bccd0a) [DEPLOYING]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (c2e700e240f079dd6fa1712981461e2f) switched from RUNNING to FINISHED.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)
(e6bb127087b8ae021cc1101dd0bccd0a) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2).
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)
(e6bb127087b8ae021cc1101dd0bccd0a) [DEPLOYING].
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (2/2) (e6bb127087b8ae021cc1101dd0bccd0a) switched
from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (1/2) (7cad7ed737d97e25142aca58f55ba0a4) switched
from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(e6bb127087b8ae021cc1101dd0bccd0a) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task GroupReduce (GroupReduce at assert_that/Group/GroupByKey)
(1/2) (7cad7ed737d97e25142aca58f55ba0a4) [DEPLOYING]
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)
(7cad7ed737d97e25142aca58f55ba0a4) [DEPLOYING].
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)
(7cad7ed737d97e25142aca58f55ba0a4) [DEPLOYING].
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (1/2) (7cad7ed737d97e25142aca58f55ba0a4) switched
from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(7cad7ed737d97e25142aca58f55ba0a4) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (5da02cdba751bbd092a57ab46a241172) switched from
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for CHAIN MapPartition (MapPartition at [6]{Map(<lambda
at external_test.py:212>), Map(<lambda at external_test.py:213>), assert_that})
-> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(5da02cdba751bbd092a57ab46a241172).
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (1/2)
(d8994604525fad3bb67572741cf3156c) switched from RUNNING to FINISHED.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (1/2) (d8994604525fad3bb67572741cf3156c).
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (2/2)
(5b5c16b346f17c095a98d76e1fac19fc) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (5da02cdba751bbd092a57ab46a241172) [FINISHED]
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (2/2) (5b5c16b346f17c095a98d76e1fac19fc).
[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 CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) 5da02cdba751bbd092a57ab46a241172.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (5da02cdba751bbd092a57ab46a241172) switched from RUNNING to FINISHED.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (2/2)
(5b5c16b346f17c095a98d76e1fac19fc) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor)
5b5c16b346f17c095a98d76e1fac19fc.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (2/2)
(5b5c16b346f17c095a98d76e1fac19fc) switched from RUNNING to FINISHED.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task CHAIN Filter (UnionFixFilter) -> Map
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
assert_that/Group/GroupByKey) -> Map (Key Extractor) (1/2)
(d8994604525fad3bb67572741cf3156c) [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 CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor)
d8994604525fad3bb67572741cf3156c.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (1/2)
(d8994604525fad3bb67572741cf3156c) switched from RUNNING to FINISHED.
[jobmanager-future-thread-16] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(02bd77732f0612553e8b9be6f219235d) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(02bd77732f0612553e8b9be6f219235d) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2) (attempt #0) to
localhost
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (1/2) (7cad7ed737d97e25142aca58f55ba0a4) switched
from RUNNING to FINISHED.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)
(7cad7ed737d97e25142aca58f55ba0a4).
[jobmanager-future-thread-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(3eee08175e1537141540e45ccbf60579) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(3eee08175e1537141540e45ccbf60579) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2) (attempt #0) to
localhost
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2).
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (2/2) (02bd77732f0612553e8b9be6f219235d)
switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream
leak safety net for task MapPartition (MapPartition at [3]assert_that/{Group,
Unkey, Match}) (2/2) (02bd77732f0612553e8b9be6f219235d) [DEPLOYING]
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(02bd77732f0612553e8b9be6f219235d) [DEPLOYING].
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(02bd77732f0612553e8b9be6f219235d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2).
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (2/2) (02bd77732f0612553e8b9be6f219235d)
switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(02bd77732f0612553e8b9be6f219235d) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/2) (3eee08175e1537141540e45ccbf60579)
switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream
leak safety net for task MapPartition (MapPartition at [3]assert_that/{Group,
Unkey, Match}) (1/2) (3eee08175e1537141540e45ccbf60579) [DEPLOYING]
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(3eee08175e1537141540e45ccbf60579) [DEPLOYING].
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network:
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(3eee08175e1537141540e45ccbf60579) [DEPLOYING].
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/2) (3eee08175e1537141540e45ccbf60579)
switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(3eee08175e1537141540e45ccbf60579) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (2/2) (e6bb127087b8ae021cc1101dd0bccd0a) switched
from RUNNING to FINISHED.
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)
(e6bb127087b8ae021cc1101dd0bccd0a).
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (1/2)
(7cad7ed737d97e25142aca58f55ba0a4) [FINISHED]
[GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task GroupReduce (GroupReduce at assert_that/Group/GroupByKey) (2/2)
(e6bb127087b8ae021cc1101dd0bccd0a) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) 7cad7ed737d97e25142aca58f55ba0a4.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) e6bb127087b8ae021cc1101dd0bccd0a.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(7cad7ed737d97e25142aca58f55ba0a4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(e6bb127087b8ae021cc1101dd0bccd0a) switched from RUNNING to FINISHED.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/read/ref_PCollection_PCollection_27:0
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/read/ref_PCollection_PCollection_27:0
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (2/2) (02bd77732f0612553e8b9be6f219235d)
switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(02bd77732f0612553e8b9be6f219235d).
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (2/2) (02bd77732f0612553e8b9be6f219235d)
[FINISHED]
[jobmanager-future-thread-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (1c19e7c0ed05b2c1fd2d1744994933cb) switched from
CREATED to SCHEDULED.
[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 MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match})
02bd77732f0612553e8b9be6f219235d.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (1c19e7c0ed05b2c1fd2d1744994933cb) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (2/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(02bd77732f0612553e8b9be6f219235d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (2/2).
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(1c19e7c0ed05b2c1fd2d1744994933cb) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (2/2)
(1c19e7c0ed05b2c1fd2d1744994933cb) [DEPLOYING]
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (2/2) (1c19e7c0ed05b2c1fd2d1744994933cb) [DEPLOYING].
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (2/2) (1c19e7c0ed05b2c1fd2d1744994933cb)
[DEPLOYING].
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(1c19e7c0ed05b2c1fd2d1744994933cb) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (1c19e7c0ed05b2c1fd2d1744994933cb) switched from
DEPLOYING to RUNNING.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/2) (3eee08175e1537141540e45ccbf60579)
switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(3eee08175e1537141540e45ccbf60579).
[MapPartition (MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/2) (3eee08175e1537141540e45ccbf60579)
[FINISHED]
[jobmanager-future-thread-12] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (74e12f230fd517662525413893df5c36) switched from
CREATED to SCHEDULED.
[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 MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match})
3eee08175e1537141540e45ccbf60579.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (74e12f230fd517662525413893df5c36) switched from
SCHEDULED to DEPLOYING.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(1c19e7c0ed05b2c1fd2d1744994933cb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (1/2) (attempt #0) to localhost
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (2/2) (1c19e7c0ed05b2c1fd2d1744994933cb).
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (2/2)
(1c19e7c0ed05b2c1fd2d1744994933cb) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (1/2).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 1c19e7c0ed05b2c1fd2d1744994933cb.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(74e12f230fd517662525413893df5c36) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (1/2)
(74e12f230fd517662525413893df5c36) [DEPLOYING]
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (1/2) (74e12f230fd517662525413893df5c36) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(3eee08175e1537141540e45ccbf60579) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (1/2) (74e12f230fd517662525413893df5c36)
[DEPLOYING].
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(74e12f230fd517662525413893df5c36) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (1c19e7c0ed05b2c1fd2d1744994933cb) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (74e12f230fd517662525413893df5c36) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(74e12f230fd517662525413893df5c36) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (1/2) (74e12f230fd517662525413893df5c36).
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (1/2)
(74e12f230fd517662525413893df5c36) [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 DataSink
(DiscardingOutput) 74e12f230fd517662525413893df5c36.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (74e12f230fd517662525413893df5c36) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
BeamApp-root-0723000305-955ded4a (29aec124410d5f4837cab797950097aa) switched
from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
29aec124410d5f4837cab797950097aa reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
BeamApp-root-0723000305-955ded4a(29aec124410d5f4837cab797950097aa).
[flink-runner-job-invoker] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-invoker] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 29aec124410d5f4837cab797950097aa.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
10762e8992395f4516248aade8677a93: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherf9ba579c-cc32-41ec-b5fd-950b317db4b4.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherf9ba579c-cc32-41ec-b5fd-950b317db4b4.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager bc5e26b0f60f27dfaa523eb2dddf477e@akka://flink/user/jobmanager_1 for
job 29aec124410d5f4837cab797950097aa from the resource manager.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
29aec124410d5f4837cab797950097aa with leader id
bc5e26b0f60f27dfaa523eb2dddf477e lost leadership.
[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{0116e722b70187d05d868ab545fdfb2f}, jobId:
29aec124410d5f4837cab797950097aa).
[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-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-c21ae141-735d-46dc-a016-ef04e2593283
[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-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherf9ba579c-cc32-41ec-b5fd-950b317db4b4.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
[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.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:37589
[flink-akka.actor.default-dispatcher-7] 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 16419 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(ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_27:0}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Precombine}:
0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_9:0}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_9:0}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_27:0}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_9:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/ToVoidKey_30}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=external_2root/Init/Map/ParMultiDo(Anonymous)}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_12:beam:metric:element_count:v1
{PCOLLECTION=pcollection}: 5,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Precombine}:
0,
ref_PCollection_PCollection_1:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/ToVoidKey_30}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:1:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:1:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Precombine}:
0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:213>)_22}:
0,
ref_PCollection_PCollection_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/Map(decode)_16}: 0,
ref_PCollection_PCollection_17:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_18}: 1,
ref_PCollection_PCollection_17:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_19}: 1,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/Map(decode)_28}: 0,
ref_PCollection_PCollection_17:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_17}: 1,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=external_2root/Init/Map/ParMultiDo(Anonymous)}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2257>)_26}: 0,
pcollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0,
pcollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Match_41}: 2,
pcollection_1:beam:metric:element_count:v1 {PCOLLECTION=pcollection_1}: 3,
ref_PCollection_PCollection_17:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_24:0}: 1,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_2:0}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Match_41}: 0,
ref_PCollection_PCollection_1:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_1}: 1,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_29}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/ToVoidKey_30}: 0,
ref_PCollection_PCollection_1:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_2}: 12,
pcollection_1:beam:metric:element_count:v1 {PCOLLECTION=pcollection_2}: 3,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2257>)_26}: 0,
ref_PCollection_PCollection_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_30}: 1,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:213>)_22}:
0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:213>)_22}:
0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_29}: 0,
pcollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/pcollection_1:0}: 0,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_0_32}: 2,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(unicode)_17}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Unkey_40}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:213>)_22}:
0, pcollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Merge}:
0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=external_2root/Init/Map/ParMultiDo(Anonymous)}: 0,
ref_PCollection_PCollection_1:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2257>)_4}:
9,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_39}:
0,
ref_PCollection_PCollection_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(unicode)_17}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_29}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0:0}: 0,
ref_PCollection_PCollection_27:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_27:0}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/ToVoidKey_30}: 0,
ref_PCollection_PCollection_27:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Unkey_40}: 0,
pcollection_1:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_14}: 3,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_27:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2257>)_26}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_1_33}: 2,
ref_PCollection_PCollection_17:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_22}: 1,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:212>)_21}:
0, ref_PCollection_PCollection_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_28}: 1,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:1:0}: 0,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0,
ref_PCollection_PCollection_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_29}: 1,
ref_PCollection_PCollection_12:beam:metric:element_count:v1
{PCOLLECTION=external_2root/Init/Map/ParMultiDo(Anonymous).output}: 6,
ref_PCollection_PCollection_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_27}: 1,
pcollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/pcollection_1:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2257>)_26}: 0,
pcollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/ExtractOutputs}:
0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(unicode)_17}: 0,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0:0}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:208>)_18}:
0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/Map(decode)_16}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_39}:
0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_39}:
0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/pcollection:0}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/pcollection:0}: 0,
ref_PCollection_PCollection_12:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_13}: 6,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:212>)_21}:
0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/Map(decode)_16}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:212>)_21}:
0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/write/pcollection:0}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(unicode)_17}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:208>)_18}:
6,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Unkey_40}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_0_32}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_0_32}: 0,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_14}: 3,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_9:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_9}: 12,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0:0}: 0,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_16}: 3,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0:0}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_15}: 3,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_1:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_2:0}: 0,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_12:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_12}: 12,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:212>)_21}:
0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0,
ref_PCollection_PCollection_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_9:0}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2257>)_4}:
0, ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_24:1}: 3,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Unkey_40}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:208>)_18}:
0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_1_33}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:1:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_1_33}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/Map(decode)_28}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/Map(decode)_28}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_1_33}: 2,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Match_41}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2257>)_4}:
9,
ref_PCollection_PCollection_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:208>)_18}:
6,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2257>)_4}:
0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_2:0}: 0,
ref_PCollection_PCollection_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/Map(decode)_28}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_0_32}: 2,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_23}: 3,
ref_PCollection_PCollection_27:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Match_41}: 2,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_20}: 3,
pcollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_21}: 3,
ref_PCollection_PCollection_9:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_11}: 12,
ref_PCollection_PCollection_9:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_12}: 12,
ref_PCollection_PCollection_9:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_10}: 12,
ref_PCollection_PCollection_27:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_39}:
0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_2:0}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_29}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=external_1root/ParDo(Anonymous)/ParMultiDo(Anonymous)}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=external_1root/ParDo(Anonymous)/ParMultiDo(Anonymous)}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=external_1root/ParDo(Anonymous)/ParMultiDo(Anonymous)}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/Map(decode)_16}:
0)Distributions(ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_16}: DistributionResult{sum=54,
count=3, min=18, max=18},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_15}: DistributionResult{sum=51,
count=3, min=17, max=17},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_14}: DistributionResult{sum=45,
count=3, min=15, max=15},
ref_PCollection_PCollection_27:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_30}: DistributionResult{sum=14,
count=1, min=14, max=14},
ref_PCollection_PCollection_17:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_24:0}: DistributionResult{sum=19,
count=1, min=19, max=19},
ref_PCollection_PCollection_17:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_17}: DistributionResult{sum=13,
count=1, min=13, max=13},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_24:1}: DistributionResult{sum=72,
count=3, min=24, max=24},
ref_PCollection_PCollection_17:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_18}: DistributionResult{sum=16,
count=1, min=16, max=16},
ref_PCollection_PCollection_17:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_19}: DistributionResult{sum=15,
count=1, min=15, max=15},
ref_PCollection_PCollection_9:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_9}: DistributionResult{sum=192,
count=12, min=16, max=16},
ref_PCollection_PCollection_17:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_22}: DistributionResult{sum=17,
count=1, min=17, max=17},
ref_PCollection_PCollection_9:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_10}: DistributionResult{sum=168,
count=12, min=14, max=14},
ref_PCollection_PCollection_9:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_12}: DistributionResult{sum=168,
count=12, min=14, max=14},
ref_PCollection_PCollection_9:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_11}: DistributionResult{sum=168,
count=12, min=14, max=14},
ref_PCollection_PCollection_1:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_1}: DistributionResult{sum=13,
count=1, min=13, max=13},
ref_PCollection_PCollection_27:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_27}: DistributionResult{sum=58,
count=1, min=58, max=58},
ref_PCollection_PCollection_27:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_28}: DistributionResult{sum=41,
count=1, min=41, max=41},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_23}: DistributionResult{sum=63,
count=3, min=21, max=21},
ref_PCollection_PCollection_27:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_29}: DistributionResult{sum=33,
count=1, min=33, max=33},
ref_PCollection_PCollection_1:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_2}: DistributionResult{sum=165,
count=11, min=15, max=15},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_21}: DistributionResult{sum=57,
count=3, min=19, max=19},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_20}: DistributionResult{sum=54,
count=3, min=18, max=18}))
[flink-runner-job-invoker] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/job_3298b374-a30f-474d-b11e-05d549492b2c/MANIFEST
has 0 artifact locations
[flink-runner-job-invoker] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/job_3298b374-a30f-474d-b11e-05d549492b2c/
FAILURE: Build completed with 3 failures.
1: Task failed with an exception.
-----------
* Where:
Build file
'<https://builds.apache.org/job/beam_PostCommit_Python2/ws/src/sdks/python/build.gradle'>
line: 115
* What went wrong:
Execution failed for task ':sdks:python:directRunnerIT'.
> 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.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Build file
'<https://builds.apache.org/job/beam_PostCommit_Python2/ws/src/sdks/python/build.gradle'>
line: 184
* What went wrong:
Execution failed for task ':sdks:python:postCommitIT'.
> 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.
==============================================================================
3: Task failed with an exception.
-----------
* Where:
Build file
'<https://builds.apache.org/job/beam_PostCommit_Python2/ws/src/sdks/python/build.gradle'>
line: 427
* What went wrong:
Execution failed for task ':sdks:python:crossLanguagePortableWordCount'.
> 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 1h 4m 49s
105 actionable tasks: 81 executed, 21 from cache, 3 up-to-date
Publishing build scan...
https://gradle.com/s/gxaq47onznfw2
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]
