See
<https://builds.apache.org/job/beam_PostCommit_Python_Verify/8017/display/redirect?page=changes>
Changes:
[github] Fix small bug in top documentation
------------------------------------------
[...truncated 755.84 KB...]
[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)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed 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) (2/2) (307150f26831991c8293828082631870) [FINISHED]
[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)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed 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) (1/2) (32371053a7e7b03f7aa87f6ea92aeb92) [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
[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) 307150f26831991c8293828082631870.
[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
[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) 32371053a7e7b03f7aa87f6ea92aeb92.
[flink-akka.actor.default-dispatcher-7] 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) (307150f26831991c8293828082631870) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] 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) (32371053a7e7b03f7aa87f6ea92aeb92) switched from
RUNNING to FINISHED.
[jobmanager-future-thread-9] 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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) 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]) (2/2)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) 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]) (2/2) (attempt #0)
to localhost
[flink-akka.actor.default-dispatcher-5] 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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) 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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) [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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) [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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) [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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) 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.
[flink-akka.actor.default-dispatcher-5] 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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-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)
(124595aab2e9000ed83b344c20852f89) switched from CREATED to SCHEDULED.
[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)
(124595aab2e9000ed83b344c20852f89) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] 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-8] 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)
(124595aab2e9000ed83b344c20852f89) 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)
(124595aab2e9000ed83b344c20852f89) [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)
(124595aab2e9000ed83b344c20852f89) [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)
(124595aab2e9000ed83b344c20852f89) [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)
(124595aab2e9000ed83b344c20852f89) switched from DEPLOYING to RUNNING.
[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)
(124595aab2e9000ed83b344c20852f89) 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) (16cea7ae38b8023ca117bb672fccb380) 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) (16cea7ae38b8023ca117bb672fccb380).
[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) (82ec36991222121958886e83db4409a2) 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 - Ensuring all FileSystem
streams are closed for task GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2) (16cea7ae38b8023ca117bb672fccb380) [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) (82ec36991222121958886e83db4409a2).
[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) (82ec36991222121958886e83db4409a2) [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 GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
16cea7ae38b8023ca117bb672fccb380.
[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 GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
82ec36991222121958886e83db4409a2.
[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) (16cea7ae38b8023ca117bb672fccb380) 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)
(1/2) (82ec36991222121958886e83db4409a2) switched from RUNNING to FINISHED.
[jobmanager-future-thread-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (d8a9827fe4b34c367106caf351a8b72e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (d8a9827fe4b34c367106caf351a8b72e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> 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 [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2).
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (d8a9827fe4b34c367106caf351a8b72e) switched from
CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (d8a9827fe4b34c367106caf351a8b72e) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at external_test.py:166>), assert_that})
-> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(d8a9827fe4b34c367106caf351a8b72e) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (d8a9827fe4b34c367106caf351a8b72e) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (d8a9827fe4b34c367106caf351a8b72e) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (d8a9827fe4b34c367106caf351a8b72e) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at external_test.py:166>), 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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) 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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf).
[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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) [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])
bc0acb9dab8e3e1dfbb1aa0aebe8bcdf.
[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)
(bc0acb9dab8e3e1dfbb1aa0aebe8bcdf) 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:0:0
[jobmanager-future-thread-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (66870ca884528778c12e75ae7ddf50c8) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (66870ca884528778c12e75ae7ddf50c8) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/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:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2).
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2) (66870ca884528778c12e75ae7ddf50c8) switched from
CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (66870ca884528778c12e75ae7ddf50c8) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at external_test.py:166>), assert_that})
-> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(66870ca884528778c12e75ae7ddf50c8) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (66870ca884528778c12e75ae7ddf50c8) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2) (66870ca884528778c12e75ae7ddf50c8) 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:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (66870ca884528778c12e75ae7ddf50c8) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at external_test.py:166>), 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)
(124595aab2e9000ed83b344c20852f89) 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)
(124595aab2e9000ed83b344c20852f89).
[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)
(124595aab2e9000ed83b344c20852f89) [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])
124595aab2e9000ed83b344c20852f89.
[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)
(124595aab2e9000ed83b344c20852f89) 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:0: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-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:165>),
Map(<lambda at external_test.py:166>), 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:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (d8a9827fe4b34c367106caf351a8b72e) switched from
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at external_test.py:166>), assert_that})
-> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(d8a9827fe4b34c367106caf351a8b72e).
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (d8a9827fe4b34c367106caf351a8b72e) [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:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) d8a9827fe4b34c367106caf351a8b72e.
[jobmanager-future-thread-16] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(d68dab041d9d17a973eca11a56a5bd5f) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(af095cef30caf250da42a131ad327fc9) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(af095cef30caf250da42a131ad327fc9) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(d68dab041d9d17a973eca11a56a5bd5f) switched from SCHEDULED to DEPLOYING.
[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-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-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (d8a9827fe4b34c367106caf351a8b72e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] 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) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (1/2) (d68dab041d9d17a973eca11a56a5bd5f) 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) (d68dab041d9d17a973eca11a56a5bd5f) [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)
(d68dab041d9d17a973eca11a56a5bd5f) [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)
(d68dab041d9d17a973eca11a56a5bd5f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] 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) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - GroupReduce (GroupReduce at
assert_that/Group/GroupByKey) (1/2) (d68dab041d9d17a973eca11a56a5bd5f) 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)
(d68dab041d9d17a973eca11a56a5bd5f) 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) (af095cef30caf250da42a131ad327fc9) 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) (af095cef30caf250da42a131ad327fc9) [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)
(af095cef30caf250da42a131ad327fc9) [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)
(af095cef30caf250da42a131ad327fc9) [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) (af095cef30caf250da42a131ad327fc9) 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) (2/2)
(af095cef30caf250da42a131ad327fc9) switched from DEPLOYING to RUNNING.
[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)
(ffcf1e4a84187e3761e6bde166eb2c62) 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) (ffcf1e4a84187e3761e6bde166eb2c62).
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2) (66870ca884528778c12e75ae7ddf50c8) switched from
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at external_test.py:166>), assert_that})
-> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(66870ca884528778c12e75ae7ddf50c8).
[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)
(8b96951854b2514c79a75f0f9656ce92) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), 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:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (66870ca884528778c12e75ae7ddf50c8) [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)
(ffcf1e4a84187e3761e6bde166eb2c62) [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) (8b96951854b2514c79a75f0f9656ce92).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:165>),
Map(<lambda at external_test.py:166>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) 66870ca884528778c12e75ae7ddf50c8.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor)
ffcf1e4a84187e3761e6bde166eb2c62.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:165>), Map(<lambda at
external_test.py:166>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (66870ca884528778c12e75ae7ddf50c8) switched from RUNNING to FINISHED.
[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)
(ffcf1e4a84187e3761e6bde166eb2c62) 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)
(8b96951854b2514c79a75f0f9656ce92) [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)
8b96951854b2514c79a75f0f9656ce92.
[flink-akka.actor.default-dispatcher-5] 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)
(8b96951854b2514c79a75f0f9656ce92) switched from RUNNING to FINISHED.
[jobmanager-future-thread-12] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(48a281f7d325f9064d9a7958fff19524) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(48a281f7d325f9064d9a7958fff19524) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2) (attempt #0) to
localhost
[flink-akka.actor.default-dispatcher-5] 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) (48a281f7d325f9064d9a7958fff19524)
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) (48a281f7d325f9064d9a7958fff19524) [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)
(48a281f7d325f9064d9a7958fff19524) [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)
(48a281f7d325f9064d9a7958fff19524) [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) (48a281f7d325f9064d9a7958fff19524)
switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(48a281f7d325f9064d9a7958fff19524) 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) (af095cef30caf250da42a131ad327fc9) 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)
(af095cef30caf250da42a131ad327fc9).
[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)
(af095cef30caf250da42a131ad327fc9) [FINISHED]
[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) (d68dab041d9d17a973eca11a56a5bd5f) switched
from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) af095cef30caf250da42a131ad327fc9.
[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)
(d68dab041d9d17a973eca11a56a5bd5f).
[jobmanager-future-thread-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(01c081ce3c849f5d3cdc32d24c16ec07) switched from CREATED to SCHEDULED.
[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)
(d68dab041d9d17a973eca11a56a5bd5f) [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 GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) d68dab041d9d17a973eca11a56a5bd5f.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(af095cef30caf250da42a131ad327fc9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(01c081ce3c849f5d3cdc32d24c16ec07) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] 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-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(d68dab041d9d17a973eca11a56a5bd5f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] 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) (01c081ce3c849f5d3cdc32d24c16ec07)
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) (01c081ce3c849f5d3cdc32d24c16ec07) [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)
(01c081ce3c849f5d3cdc32d24c16ec07) [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)
(01c081ce3c849f5d3cdc32d24c16ec07) [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) (01c081ce3c849f5d3cdc32d24c16ec07)
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)
(01c081ce3c849f5d3cdc32d24c16ec07) switched from DEPLOYING to RUNNING.
[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) (48a281f7d325f9064d9a7958fff19524)
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)
(48a281f7d325f9064d9a7958fff19524).
[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) (48a281f7d325f9064d9a7958fff19524)
[FINISHED]
[jobmanager-future-thread-15] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (30191ed5679abf03b187e95b30dd594d) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match})
48a281f7d325f9064d9a7958fff19524.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (30191ed5679abf03b187e95b30dd594d) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] 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.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (2/2).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(48a281f7d325f9064d9a7958fff19524) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(30191ed5679abf03b187e95b30dd594d) 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)
(30191ed5679abf03b187e95b30dd594d) [DEPLOYING]
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (2/2) (30191ed5679abf03b187e95b30dd594d) [DEPLOYING].
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (2/2) (30191ed5679abf03b187e95b30dd594d)
[DEPLOYING].
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/read/ref_PCollection_PCollection_27:0
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(30191ed5679abf03b187e95b30dd594d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (30191ed5679abf03b187e95b30dd594d) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(30191ed5679abf03b187e95b30dd594d) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (2/2) (30191ed5679abf03b187e95b30dd594d).
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (2/2)
(30191ed5679abf03b187e95b30dd594d) [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 DataSink
(DiscardingOutput) 30191ed5679abf03b187e95b30dd594d.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (30191ed5679abf03b187e95b30dd594d) switched from
RUNNING to FINISHED.
[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) (01c081ce3c849f5d3cdc32d24c16ec07)
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)
(01c081ce3c849f5d3cdc32d24c16ec07).
[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) (01c081ce3c849f5d3cdc32d24c16ec07)
[FINISHED]
[jobmanager-future-thread-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (4512f86524b46dec416e4f7fc8944b3d) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match})
01c081ce3c849f5d3cdc32d24c16ec07.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (4512f86524b46dec416e4f7fc8944b3d) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (1/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}) (1/2)
(01c081ce3c849f5d3cdc32d24c16ec07) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] 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)
(4512f86524b46dec416e4f7fc8944b3d) 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)
(4512f86524b46dec416e4f7fc8944b3d) [DEPLOYING]
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (1/2) (4512f86524b46dec416e4f7fc8944b3d) [DEPLOYING].
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (1/2) (4512f86524b46dec416e4f7fc8944b3d)
[DEPLOYING].
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(4512f86524b46dec416e4f7fc8944b3d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (4512f86524b46dec416e4f7fc8944b3d) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(4512f86524b46dec416e4f7fc8944b3d) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (1/2) (4512f86524b46dec416e4f7fc8944b3d).
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (1/2)
(4512f86524b46dec416e4f7fc8944b3d) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 4512f86524b46dec416e4f7fc8944b3d.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (4512f86524b46dec416e4f7fc8944b3d) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
BeamApp-root-0425155619-55ae0451 (7ab1faac15b1f417c13866a6f07c4c59) switched
from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
7ab1faac15b1f417c13866a6f07c4c59 reached globally terminal state FINISHED.
[flink-runner-job-invoker] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
BeamApp-root-0425155619-55ae0451(7ab1faac15b1f417c13866a6f07c4c59).
[flink-runner-job-invoker] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-4] 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.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherb8cacb77-dd18-469d-ba00-42986cdce4fc.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherb8cacb77-dd18-469d-ba00-42986cdce4fc.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
63521fcab54e992453b6acde993fea05: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-ec37db54-58c7-4ce2-b8b8-8341a4dc7098
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
7ab1faac15b1f417c13866a6f07c4c59 with leader id
a1ad24e6a800efded40640a0f0844bed lost leadership.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager a1ad24e6a800efded40640a0f0844bed@akka://flink/user/jobmanager_1 for
job 7ab1faac15b1f417c13866a6f07c4c59 from the resource manager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherb8cacb77-dd18-469d-ba00-42986cdce4fc.
[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-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.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_0.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41791
[flink-akka.actor.default-dispatcher-4] 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 14342 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_14: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=fn/write/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_1:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2172>)_4}:
4, 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_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:166>)_22}:
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_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:161>)_18}:
2,
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: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_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_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0:0}: 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_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0:0}: 0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=external_2root/Init/Map/ParMultiDo(Anonymous)}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:166>)_22}:
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_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_17:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_24:1}: 1,
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_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_30}: 1,
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_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:1:0}: 0,
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,
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_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_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:166>)_22}:
0,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2172>)_26}: 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}: 0,
ref_PCollection_PCollection_17:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_22}: 1,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2172>)_4}:
4,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2172>)_4}:
0, ref_PCollection_PCollection_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_28}: 1,
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,
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_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2172>)_4}:
0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(unicode)_17}: 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_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:165>)_21}:
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_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:1:0}: 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_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:1: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_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/Map(decode)_16}: 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_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_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:165>)_21}:
0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:161>)_18}:
0, ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_16}: 3,
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_9:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:161>)_18}:
0,
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_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_27:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Unkey_40}: 0,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_24:0}: 3,
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_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2172>)_26}: 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_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2172>)_26}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:166>)_22}:
0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_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=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:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:161>)_18}:
2,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_24:0:0}: 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/Create/FlatMap(<lambda at
core.py:2172>)_26}: 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}: 0,
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_14:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:165>)_21}:
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,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_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=ref_AppliedPTransform_Map(<lambda at external_test.py:165>)_21}:
0))
[flink-runner-job-invoker] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/job_7d6f63e0-4fcd-4720-a3c5-d25b2a23e4be/MANIFEST
has 0 artifact locations
[flink-runner-job-invoker] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/job_7d6f63e0-4fcd-4720-a3c5-d25b2a23e4be/
> Task :beam-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: 111
* What went wrong:
Execution failed for task ':beam-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.
* 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 1m 21s
104 actionable tasks: 81 executed, 20 from cache, 3 up-to-date
Publishing build scan...
https://gradle.com/s/kiqeewmguzddm
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]
