See
<https://builds.apache.org/job/beam_PostCommit_Python_Verify/8306/display/redirect?page=changes>
Changes:
[chamikara] [BEAM-7203] Signal Dataflow workers to use fastavro library on
Python 3.
------------------------------------------
[...truncated 597.52 KB...]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at
[3]{ExternalTransform(pytest:beam:transforms:filter_less_than),
ExternalTransform(pytest:beam:transforms:count)}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine:
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group) ->
Map (Key Extractor) 6b2be74493ab25b78adfe95310e3712a.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at
[3]{ExternalTransform(pytest:beam:transforms:filter_less_than),
ExternalTransform(pytest:beam:transforms:count)}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine:
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group) ->
Map (Key Extractor) bf80af86423f8be576d995de2158df57.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
[3]{ExternalTransform(pytest:beam:transforms:filter_less_than),
ExternalTransform(pytest:beam:transforms:count)}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine:
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group) ->
Map (Key Extractor) (2/2) (6b2be74493ab25b78adfe95310e3712a) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at
[3]{ExternalTransform(pytest:beam:transforms:filter_less_than),
ExternalTransform(pytest:beam:transforms:count)}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine:
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group) ->
Map (Key Extractor) (1/2) (bf80af86423f8be576d995de2158df57) switched from
RUNNING to FINISHED.
[jobmanager-future-thread-6] 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)
(d245dcc86bec011b3e7687469d93372e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] 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)
(d245dcc86bec011b3e7687469d93372e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (attempt #0)
to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2).
[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)
(d245dcc86bec011b3e7687469d93372e) switched from CREATED to DEPLOYING.
[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 - Creating FileSystem stream leak
safety net for task CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(d245dcc86bec011b3e7687469d93372e) [DEPLOYING]
[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 - Loading JAR files for task CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(d245dcc86bec011b3e7687469d93372e) [DEPLOYING].
[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 - Registering task at network: CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(d245dcc86bec011b3e7687469d93372e) [DEPLOYING].
[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)
(d245dcc86bec011b3e7687469d93372e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] 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)
(d245dcc86bec011b3e7687469d93372e) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] WARN
org.apache.flink.metrics.MetricGroup - The operator name MapPartition
(MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) exceeded the 80 characters length limit and was truncated.
[jobmanager-future-thread-14] 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)
(eae242d036da0e9df53c2efae3a80b65) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] 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)
(eae242d036da0e9df53c2efae3a80b65) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (attempt #0)
to localhost
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2).
[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)
(eae242d036da0e9df53c2efae3a80b65) switched from CREATED to DEPLOYING.
[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 - Creating FileSystem stream leak
safety net for task CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(eae242d036da0e9df53c2efae3a80b65) [DEPLOYING]
[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 - Loading JAR files for task CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(eae242d036da0e9df53c2efae3a80b65) [DEPLOYING].
[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 - Registering task at network: CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(eae242d036da0e9df53c2efae3a80b65) [DEPLOYING].
[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)
(eae242d036da0e9df53c2efae3a80b65) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] 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)
(eae242d036da0e9df53c2efae3a80b65) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] WARN
org.apache.flink.metrics.MetricGroup - The operator name MapPartition
(MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) exceeded the 80 characters length limit and was truncated.
[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) (6e61be6e6b962379b31ee7b7a2fd4cee) 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) (6e61be6e6b962379b31ee7b7a2fd4cee).
[GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2) (199a41eef0f4e218e60a1e2e21c5ac59) switched from RUNNING to FINISHED.
[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) (199a41eef0f4e218e60a1e2e21c5ac59).
[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) (6e61be6e6b962379b31ee7b7a2fd4cee) [FINISHED]
[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) (199a41eef0f4e218e60a1e2e21c5ac59) [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 GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
6e61be6e6b962379b31ee7b7a2fd4cee.
[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 GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
199a41eef0f4e218e60a1e2e21c5ac59.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2) (6e61be6e6b962379b31ee7b7a2fd4cee) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2) (199a41eef0f4e218e60a1e2e21c5ac59) switched from RUNNING to FINISHED.
[jobmanager-future-thread-11] 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) (aed9c174f5f385aaf4db368a7353563f) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] 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) (aed9c174f5f385aaf4db368a7353563f) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] 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-8] 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) (aed9c174f5f385aaf4db368a7353563f) 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) (aed9c174f5f385aaf4db368a7353563f) [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)
(aed9c174f5f385aaf4db368a7353563f) [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) (aed9c174f5f385aaf4db368a7353563f) [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) (aed9c174f5f385aaf4db368a7353563f) 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])
(2/2) (aed9c174f5f385aaf4db368a7353563f) 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.
[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)
(d245dcc86bec011b3e7687469d93372e) 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)
(d245dcc86bec011b3e7687469d93372e).
[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)
(d245dcc86bec011b3e7687469d93372e) [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
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0])
d245dcc86bec011b3e7687469d93372e.
[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)
(eae242d036da0e9df53c2efae3a80b65) 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])
(1/2) (8818922aebce57e09a42b2aeb734212f) switched from CREATED to SCHEDULED.
[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)
(eae242d036da0e9df53c2efae3a80b65).
[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)
(eae242d036da0e9df53c2efae3a80b65) [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
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0])
eae242d036da0e9df53c2efae3a80b65.
[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)
(d245dcc86bec011b3e7687469d93372e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-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])
(1/2) (8818922aebce57e09a42b2aeb734212f) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] 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-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)
(eae242d036da0e9df53c2efae3a80b65) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] 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) (8818922aebce57e09a42b2aeb734212f) 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) (8818922aebce57e09a42b2aeb734212f) [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)
(8818922aebce57e09a42b2aeb734212f) [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) (8818922aebce57e09a42b2aeb734212f) [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) (8818922aebce57e09a42b2aeb734212f) 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) (8818922aebce57e09a42b2aeb734212f) 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.
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique
name set for transform fn/write/ref_PCollection_PCollection_24:1:0
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique
name set for transform fn/write/ref_PCollection_PCollection_24:1:0
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique
name set for transform fn/read/ref_PCollection_PCollection_14:0
[grpc-default-executor-1] 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]) (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) (aed9c174f5f385aaf4db368a7353563f) 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)
(aed9c174f5f385aaf4db368a7353563f).
[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) (aed9c174f5f385aaf4db368a7353563f) [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 [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) aed9c174f5f385aaf4db368a7353563f.
[jobmanager-future-thread-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(b230b79417b57493d47d69adb49f4812) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-1] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(07481d88b397c2019872938acedc5867) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(07481d88b397c2019872938acedc5867) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] 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-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(b230b79417b57493d47d69adb49f4812) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] 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-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2).
[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) (aed9c174f5f385aaf4db368a7353563f) switched from RUNNING to FINISHED.
[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) (07481d88b397c2019872938acedc5867) 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) (07481d88b397c2019872938acedc5867) [DEPLOYING]
[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)
(07481d88b397c2019872938acedc5867) [DEPLOYING].
[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)
(07481d88b397c2019872938acedc5867) [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) (07481d88b397c2019872938acedc5867) switched
from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2).
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(07481d88b397c2019872938acedc5867) 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) (b230b79417b57493d47d69adb49f4812) switched
from CREATED to DEPLOYING.
[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) (b230b79417b57493d47d69adb49f4812) [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)
(b230b79417b57493d47d69adb49f4812) [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)
(b230b79417b57493d47d69adb49f4812) [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) (b230b79417b57493d47d69adb49f4812) switched
from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(b230b79417b57493d47d69adb49f4812) 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)] 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) (8818922aebce57e09a42b2aeb734212f) 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)
(8818922aebce57e09a42b2aeb734212f).
[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)
(1a70f5d55c175572fa4e1847dd460fb6) 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 - Freeing task
resources for CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (2/2) (1a70f5d55c175572fa4e1847dd460fb6).
[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)
(d62912426773798e7d13fff1e3f4a9ac) 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 -
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) (8818922aebce57e09a42b2aeb734212f) [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) (d62912426773798e7d13fff1e3f4a9ac).
[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]) 8818922aebce57e09a42b2aeb734212f.
[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) (8818922aebce57e09a42b2aeb734212f) 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)
(d62912426773798e7d13fff1e3f4a9ac) [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 Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor)
d62912426773798e7d13fff1e3f4a9ac.
[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) (1/2)
(d62912426773798e7d13fff1e3f4a9ac) 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)
(1a70f5d55c175572fa4e1847dd460fb6) [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)
1a70f5d55c175572fa4e1847dd460fb6.
[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) (2/2)
(1a70f5d55c175572fa4e1847dd460fb6) switched from RUNNING to FINISHED.
[jobmanager-future-thread-1] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(f5000672b6509a23d8a7e39cca320469) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(f5000672b6509a23d8a7e39cca320469) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] 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) (b230b79417b57493d47d69adb49f4812) 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)
(b230b79417b57493d47d69adb49f4812).
[jobmanager-future-thread-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(a4e698e308e65f1e16dacf0b609cd6d4) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(a4e698e308e65f1e16dacf0b609cd6d4) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] 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-7] 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) (f5000672b6509a23d8a7e39cca320469)
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) (f5000672b6509a23d8a7e39cca320469) [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)
(f5000672b6509a23d8a7e39cca320469) [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)
(f5000672b6509a23d8a7e39cca320469) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] 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}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/2) (a4e698e308e65f1e16dacf0b609cd6d4)
switched from CREATED to DEPLOYING.
[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) (f5000672b6509a23d8a7e39cca320469)
switched from DEPLOYING to RUNNING.
[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) (a4e698e308e65f1e16dacf0b609cd6d4) [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)
(a4e698e308e65f1e16dacf0b609cd6d4) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(f5000672b6509a23d8a7e39cca320469) switched from DEPLOYING to RUNNING.
[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)
(a4e698e308e65f1e16dacf0b609cd6d4) [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) (a4e698e308e65f1e16dacf0b609cd6d4)
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}) (1/2)
(a4e698e308e65f1e16dacf0b609cd6d4) 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) (07481d88b397c2019872938acedc5867) switched
from RUNNING to FINISHED.
[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)
(b230b79417b57493d47d69adb49f4812) [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)
(07481d88b397c2019872938acedc5867).
[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)
(07481d88b397c2019872938acedc5867) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) b230b79417b57493d47d69adb49f4812.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) 07481d88b397c2019872938acedc5867.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(b230b79417b57493d47d69adb49f4812) 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)
(07481d88b397c2019872938acedc5867) 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}) (1/2)]
INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[3]assert_that/{Group, Unkey, Match}) (1/2) (a4e698e308e65f1e16dacf0b609cd6d4)
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)
(a4e698e308e65f1e16dacf0b609cd6d4).
[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) (a4e698e308e65f1e16dacf0b609cd6d4)
[FINISHED]
[jobmanager-future-thread-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (3c23cbdb4a570286b70ef60d46fb01a7) switched from
CREATED to SCHEDULED.
[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 MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match})
a4e698e308e65f1e16dacf0b609cd6d4.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (3c23cbdb4a570286b70ef60d46fb01a7) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (1/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(a4e698e308e65f1e16dacf0b609cd6d4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (1/2).
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(3c23cbdb4a570286b70ef60d46fb01a7) 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)
(3c23cbdb4a570286b70ef60d46fb01a7) [DEPLOYING]
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (1/2) (3c23cbdb4a570286b70ef60d46fb01a7) [DEPLOYING].
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (1/2) (3c23cbdb4a570286b70ef60d46fb01a7)
[DEPLOYING].
[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) (f5000672b6509a23d8a7e39cca320469)
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)
(f5000672b6509a23d8a7e39cca320469).
[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) (f5000672b6509a23d8a7e39cca320469)
[FINISHED]
[jobmanager-future-thread-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (8268ff2fec6e349c87d22b72a845b7a9) switched from
CREATED to SCHEDULED.
[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 MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match})
f5000672b6509a23d8a7e39cca320469.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(3c23cbdb4a570286b70ef60d46fb01a7) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (3c23cbdb4a570286b70ef60d46fb01a7) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(3c23cbdb4a570286b70ef60d46fb01a7) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (1/2) (3c23cbdb4a570286b70ef60d46fb01a7).
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (1/2)
(3c23cbdb4a570286b70ef60d46fb01a7) [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 DataSink
(DiscardingOutput) 3c23cbdb4a570286b70ef60d46fb01a7.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(f5000672b6509a23d8a7e39cca320469) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (8268ff2fec6e349c87d22b72a845b7a9) 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-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (3c23cbdb4a570286b70ef60d46fb01a7) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] 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)
(8268ff2fec6e349c87d22b72a845b7a9) 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)
(8268ff2fec6e349c87d22b72a845b7a9) [DEPLOYING]
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (2/2) (8268ff2fec6e349c87d22b72a845b7a9) [DEPLOYING].
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (2/2) (8268ff2fec6e349c87d22b72a845b7a9)
[DEPLOYING].
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(8268ff2fec6e349c87d22b72a845b7a9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (8268ff2fec6e349c87d22b72a845b7a9) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(8268ff2fec6e349c87d22b72a845b7a9) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (2/2) (8268ff2fec6e349c87d22b72a845b7a9).
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (2/2)
(8268ff2fec6e349c87d22b72a845b7a9) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 8268ff2fec6e349c87d22b72a845b7a9.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (8268ff2fec6e349c87d22b72a845b7a9) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
BeamApp-root-0523215510-1eb11bb7 (8af6d84e69ca7fceb9a261fdac04e50e) switched
from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
8af6d84e69ca7fceb9a261fdac04e50e reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
BeamApp-root-0523215510-1eb11bb7(8af6d84e69ca7fceb9a261fdac04e50e).
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 8af6d84e69ca7fceb9a261fdac04e50e.
[flink-runner-job-invoker] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
dbd54785ecf2fd2e6977d7e4e9eac2a6: JobManager is shutting down..
[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 - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherc1c9f6a9-65cb-4e49-8045-6c19443f3d7c.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherc1c9f6a9-65cb-4e49-8045-6c19443f3d7c.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-8] 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{13a4928479abf635b92b9a61dc1d2cee}, jobId:
8af6d84e69ca7fceb9a261fdac04e50e).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 9c4ef6e1bcd6aa3a1d29172817d349cf@akka://flink/user/jobmanager_1 for
job 8af6d84e69ca7fceb9a261fdac04e50e from the resource manager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
8af6d84e69ca7fceb9a261fdac04e50e with leader id
9c4ef6e1bcd6aa3a1d29172817d349cf lost leadership.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_0.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherc1c9f6a9-65cb-4e49-8045-6c19443f3d7c.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-66ab683f-a6d4-4346-b08b-c61c1964f986
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[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.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_0.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:45357
[flink-akka.actor.default-dispatcher-8] 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 15281 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:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2254>)_26}: 0,
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,
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}: 0,
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_1:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2254>)_4}:
7,
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_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2254>)_26}: 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_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}: 4,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(unicode)_17}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2254>)_4}:
0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2254>)_4}:
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_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_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_1_33}: 4,
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:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2254>)_26}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2254>)_4}:
7, 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}:
2,
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_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}: 4,
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_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:208>)_18}:
2,
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}: 4,
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}: 0,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_20}: 3,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2254>)_26}: 0,
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=180,
count=12, 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_2f83c912-e64a-4c07-b806-ed5f4d9ac05d/MANIFEST
has 0 artifact locations
[flink-runner-job-invoker] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/job_2f83c912-e64a-4c07-b806-ed5f4d9ac05d/
> Task :sdks:python:crossLanguageTests
FAILURE: Build failed with an exception.
* Where:
Build file
'<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/src/sdks/python/build.gradle'>
line: 256
* What went wrong:
Execution failed for task ':sdks:python:hdfsIntegrationTest'.
> Process 'command 'sh'' finished with non-zero exit value 255
* 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 56m 50s
104 actionable tasks: 80 executed, 21 from cache, 3 up-to-date
Publishing build scan...
https://gradle.com/s/sj7m56ut7hulm
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]
