See
<https://builds.apache.org/job/beam_PostCommit_Python_Verify/8659/display/redirect>
------------------------------------------
[...truncated 693.96 KB...]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at
[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) f9269005112815785bdc050241c5f938.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at
[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) 7390a2dc304e2e6c820e94abd9938916.
[flink-akka.actor.default-dispatcher-9] 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) (f9269005112815785bdc050241c5f938) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-9] 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) (7390a2dc304e2e6c820e94abd9938916) switched from
RUNNING to FINISHED.
[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)
(415e5c6fb86c6ef276b3e3fac16b34bd) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] 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)
(415e5c6fb86c6ef276b3e3fac16b34bd) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] 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-9] 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)
(415e5c6fb86c6ef276b3e3fac16b34bd) 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)
(415e5c6fb86c6ef276b3e3fac16b34bd) [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)
(415e5c6fb86c6ef276b3e3fac16b34bd) [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)
(415e5c6fb86c6ef276b3e3fac16b34bd) [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)
(415e5c6fb86c6ef276b3e3fac16b34bd) 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]) (1/2)
(415e5c6fb86c6ef276b3e3fac16b34bd) 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.
[jobmanager-future-thread-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)
(f1b8a120fee90b492216060d913270bf) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-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)
(f1b8a120fee90b492216060d913270bf) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-9] 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)
(f1b8a120fee90b492216060d913270bf) 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)
(f1b8a120fee90b492216060d913270bf) [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)
(f1b8a120fee90b492216060d913270bf) [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)
(f1b8a120fee90b492216060d913270bf) [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)
(f1b8a120fee90b492216060d913270bf) 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)
(f1b8a120fee90b492216060d913270bf) 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.
[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) (fa5cc59cdf66ff76f101d875103ae6c7) 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) (fa5cc59cdf66ff76f101d875103ae6c7).
[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) (2894d6d83291d4c360b1830d5c5752d2) 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 - Ensuring all FileSystem
streams are closed for task GroupReduce (GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2) (fa5cc59cdf66ff76f101d875103ae6c7) [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) (2894d6d83291d4c360b1830d5c5752d2).
[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) (2894d6d83291d4c360b1830d5c5752d2) [FINISHED]
[flink-akka.actor.default-dispatcher-9] 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)
fa5cc59cdf66ff76f101d875103ae6c7.
[flink-akka.actor.default-dispatcher-9] 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)
2894d6d83291d4c360b1830d5c5752d2.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(1/2) (fa5cc59cdf66ff76f101d875103ae6c7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at
ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Group)
(2/2) (2894d6d83291d4c360b1830d5c5752d2) switched from RUNNING to FINISHED.
[jobmanager-future-thread-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])
(1/2) (5a2d5e2c7ee58d445f7d703e900e1e65) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (5a2d5e2c7ee58d445f7d703e900e1e65) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] 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-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) (5a2d5e2c7ee58d445f7d703e900e1e65) 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) (5a2d5e2c7ee58d445f7d703e900e1e65) [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)
(5a2d5e2c7ee58d445f7d703e900e1e65) [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) (5a2d5e2c7ee58d445f7d703e900e1e65) [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) (5a2d5e2c7ee58d445f7d703e900e1e65) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (5a2d5e2c7ee58d445f7d703e900e1e65) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] WARN org.apache.flink.metrics.MetricGroup - The
operator name MapPartition (MapPartition at [6]{Map(<lambda at
external_test.py:212>), Map(<lambda at external_test.py:213>), assert_that})
exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)
(415e5c6fb86c6ef276b3e3fac16b34bd) 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)
(415e5c6fb86c6ef276b3e3fac16b34bd).
[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)
(415e5c6fb86c6ef276b3e3fac16b34bd) [FINISHED]
[flink-akka.actor.default-dispatcher-9] 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])
415e5c6fb86c6ef276b3e3fac16b34bd.
[flink-akka.actor.default-dispatcher-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]) (1/2)
(415e5c6fb86c6ef276b3e3fac16b34bd) switched from RUNNING to FINISHED.
[jobmanager-future-thread-3] 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) (6fd687d7a75e9111ee8606257bb01f0d) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-9] 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) (6fd687d7a75e9111ee8606257bb01f0d) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2).
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (6fd687d7a75e9111ee8606257bb01f0d) 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) (6fd687d7a75e9111ee8606257bb01f0d) [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)
(6fd687d7a75e9111ee8606257bb01f0d) [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) (6fd687d7a75e9111ee8606257bb01f0d) [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) (6fd687d7a75e9111ee8606257bb01f0d) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-9] 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) (6fd687d7a75e9111ee8606257bb01f0d) 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.
[grpc-default-executor-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/write/ref_PCollection_PCollection_24:0:0
[CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)
(f1b8a120fee90b492216060d913270bf) 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)
(f1b8a120fee90b492216060d913270bf).
[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)
(f1b8a120fee90b492216060d913270bf) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task CHAIN
MapPartition (MapPartition at
[2]ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/{Merge,
ExtractOutputs}) -> FlatMap (FlatMap at ExtractOutput[0])
f1b8a120fee90b492216060d913270bf.
[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)
(f1b8a120fee90b492216060d913270bf) 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-0] WARN bundle_processor.create_operation - No unique
name set for transform fn/read/ref_PCollection_PCollection_14:0
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/2) (5a2d5e2c7ee58d445f7d703e900e1e65) 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)
(5a2d5e2c7ee58d445f7d703e900e1e65).
[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) (5a2d5e2c7ee58d445f7d703e900e1e65) [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 [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) 5a2d5e2c7ee58d445f7d703e900e1e65.
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(b8d5051a5fa2d5f86bf09548499fb28b) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(172114106e5ff6e444e85ffad1d21b7d) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(b8d5051a5fa2d5f86bf09548499fb28b) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-9] 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 - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(172114106e5ff6e444e85ffad1d21b7d) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] 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) (b8d5051a5fa2d5f86bf09548499fb28b) 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) (b8d5051a5fa2d5f86bf09548499fb28b) [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)
(b8d5051a5fa2d5f86bf09548499fb28b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(1/2) (5a2d5e2c7ee58d445f7d703e900e1e65) switched from RUNNING to FINISHED.
[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)
(b8d5051a5fa2d5f86bf09548499fb28b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] 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) (b8d5051a5fa2d5f86bf09548499fb28b) 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) (172114106e5ff6e444e85ffad1d21b7d) 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) (172114106e5ff6e444e85ffad1d21b7d) [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)
(172114106e5ff6e444e85ffad1d21b7d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(b8d5051a5fa2d5f86bf09548499fb28b) switched from DEPLOYING to RUNNING.
[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)
(172114106e5ff6e444e85ffad1d21b7d) [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) (172114106e5ff6e444e85ffad1d21b7d) switched
from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(172114106e5ff6e444e85ffad1d21b7d) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN
MapPartition (MapPartition at [6]{Map(<lambda at external_test.py:212>),
Map(<lambda at external_test.py:213>), assert_that}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/2) (6fd687d7a75e9111ee8606257bb01f0d) 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)
(6fd687d7a75e9111ee8606257bb01f0d).
[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)
(247b1708cb9ad843aab44a43cee6ccbf) switched from RUNNING to FINISHED.
[CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine: assert_that/Group/GroupByKey) -> Map (Key
Extractor) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for CHAIN Filter (UnionFixFilter) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: assert_that/Group/GroupByKey) ->
Map (Key Extractor) (1/2) (247b1708cb9ad843aab44a43cee6ccbf).
[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)
(305c8fb6f9d372ba4face15b3e63bf3f) 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) (305c8fb6f9d372ba4face15b3e63bf3f).
[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) (6fd687d7a75e9111ee8606257bb01f0d) [FINISHED]
[flink-akka.actor.default-dispatcher-9] 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]) 6fd687d7a75e9111ee8606257bb01f0d.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition
(MapPartition at [6]{Map(<lambda at external_test.py:212>), Map(<lambda at
external_test.py:213>), assert_that}) -> FlatMap (FlatMap at ExtractOutput[0])
(2/2) (6fd687d7a75e9111ee8606257bb01f0d) 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)
(305c8fb6f9d372ba4face15b3e63bf3f) [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)
(247b1708cb9ad843aab44a43cee6ccbf) [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)
305c8fb6f9d372ba4face15b3e63bf3f.
[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)
247b1708cb9ad843aab44a43cee6ccbf.
[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)
(305c8fb6f9d372ba4face15b3e63bf3f) switched from RUNNING to FINISHED.
[jobmanager-future-thread-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(323d9b3d7333bae4e332c2b5e0937ccf) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN Filter
(UnionFixFilter) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: assert_that/Group/GroupByKey) -> Map (Key Extractor) (1/2)
(247b1708cb9ad843aab44a43cee6ccbf) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(323d9b3d7333bae4e332c2b5e0937ccf) 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-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) (323d9b3d7333bae4e332c2b5e0937ccf)
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) (323d9b3d7333bae4e332c2b5e0937ccf) [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)
(323d9b3d7333bae4e332c2b5e0937ccf) [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)
(323d9b3d7333bae4e332c2b5e0937ccf) [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) (323d9b3d7333bae4e332c2b5e0937ccf)
switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(323d9b3d7333bae4e332c2b5e0937ccf) switched from DEPLOYING to RUNNING.
[grpc-default-executor-1] WARN bundle_processor.create_operation - No unique
name set for transform fn/read/ref_PCollection_PCollection_27:0
[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) (172114106e5ff6e444e85ffad1d21b7d) 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)
(172114106e5ff6e444e85ffad1d21b7d).
[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)
(172114106e5ff6e444e85ffad1d21b7d) [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 assert_that/Group/GroupByKey) 172114106e5ff6e444e85ffad1d21b7d.
[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) (b8d5051a5fa2d5f86bf09548499fb28b) 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)
(b8d5051a5fa2d5f86bf09548499fb28b).
[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)
(b8d5051a5fa2d5f86bf09548499fb28b) [FINISHED]
[jobmanager-future-thread-14] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(7453ebfa6710c49982387b8d203d163e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) b8d5051a5fa2d5f86bf09548499fb28b.
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (2/2)
(172114106e5ff6e444e85ffad1d21b7d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(7453ebfa6710c49982387b8d203d163e) 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-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce
(GroupReduce at assert_that/Group/GroupByKey) (1/2)
(b8d5051a5fa2d5f86bf09548499fb28b) switched from RUNNING to FINISHED.
[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) (7453ebfa6710c49982387b8d203d163e)
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) (7453ebfa6710c49982387b8d203d163e) [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)
(7453ebfa6710c49982387b8d203d163e) [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)
(7453ebfa6710c49982387b8d203d163e) [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) (7453ebfa6710c49982387b8d203d163e)
switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(7453ebfa6710c49982387b8d203d163e) switched from DEPLOYING to RUNNING.
[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) (323d9b3d7333bae4e332c2b5e0937ccf)
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)
(323d9b3d7333bae4e332c2b5e0937ccf).
[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) (323d9b3d7333bae4e332c2b5e0937ccf)
[FINISHED]
[jobmanager-future-thread-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (091e6bc0b53944c91f04a154909b4d83) 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})
323d9b3d7333bae4e332c2b5e0937ccf.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (091e6bc0b53944c91f04a154909b4d83) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (2/2) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (2/2).
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (2/2)
(323d9b3d7333bae4e332c2b5e0937ccf) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(091e6bc0b53944c91f04a154909b4d83) 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)
(091e6bc0b53944c91f04a154909b4d83) [DEPLOYING]
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (2/2) (091e6bc0b53944c91f04a154909b4d83) [DEPLOYING].
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (2/2) (091e6bc0b53944c91f04a154909b4d83)
[DEPLOYING].
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(091e6bc0b53944c91f04a154909b4d83) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (091e6bc0b53944c91f04a154909b4d83) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/2)
(091e6bc0b53944c91f04a154909b4d83) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (2/2) (091e6bc0b53944c91f04a154909b4d83).
[DataSink (DiscardingOutput) (2/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (2/2)
(091e6bc0b53944c91f04a154909b4d83) [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) 091e6bc0b53944c91f04a154909b4d83.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/2) (091e6bc0b53944c91f04a154909b4d83) switched from
RUNNING to FINISHED.
[grpc-default-executor-1] 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) (7453ebfa6710c49982387b8d203d163e)
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)
(7453ebfa6710c49982387b8d203d163e).
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (a2f6fb8a560b14e68d364ba5f6d08363) switched from
CREATED to SCHEDULED.
[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) (7453ebfa6710c49982387b8d203d163e)
[FINISHED]
[flink-akka.actor.default-dispatcher-9] 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})
7453ebfa6710c49982387b8d203d163e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (a2f6fb8a560b14e68d364ba5f6d08363) 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-9] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (1/2).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [3]assert_that/{Group, Unkey, Match}) (1/2)
(7453ebfa6710c49982387b8d203d163e) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(a2f6fb8a560b14e68d364ba5f6d08363) 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)
(a2f6fb8a560b14e68d364ba5f6d08363) [DEPLOYING]
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (1/2) (a2f6fb8a560b14e68d364ba5f6d08363) [DEPLOYING].
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (1/2) (a2f6fb8a560b14e68d364ba5f6d08363)
[DEPLOYING].
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(a2f6fb8a560b14e68d364ba5f6d08363) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (a2f6fb8a560b14e68d364ba5f6d08363) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/2)
(a2f6fb8a560b14e68d364ba5f6d08363) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (1/2) (a2f6fb8a560b14e68d364ba5f6d08363).
[DataSink (DiscardingOutput) (1/2)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (1/2)
(a2f6fb8a560b14e68d364ba5f6d08363) [FINISHED]
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) a2f6fb8a560b14e68d364ba5f6d08363.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/2) (a2f6fb8a560b14e68d364ba5f6d08363) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
BeamApp-root-0705190646-92c7c60d (937fd5418215624d57ae999c7046900d) switched
from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
937fd5418215624d57ae999c7046900d reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
BeamApp-root-0705190646-92c7c60d(937fd5418215624d57ae999c7046900d).
[flink-runner-job-invoker] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 937fd5418215624d57ae999c7046900d.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
08b14f162f1df07398f8c26a5701d6e8: JobManager is shutting down..
[flink-runner-job-invoker] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher1e7b3ea4-7b6d-4c9c-8ef4-dae5adb3a292.
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher1e7b3ea4-7b6d-4c9c-8ef4-dae5adb3a292.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_0.
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager a8c4e6868c83e3f56ae6a7f05db847e2@akka://flink/user/jobmanager_1 for
job 937fd5418215624d57ae999c7046900d from the resource manager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Could not resolve
JobManager address akka://flink/user/jobmanager_1, retrying in 10000 ms: Could
not connect to rpc endpoint under address akka://flink/user/jobmanager_1..
[flink-akka.actor.default-dispatcher-9] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
937fd5418215624d57ae999c7046900d with leader id
a8c4e6868c83e3f56ae6a7f05db847e2 lost leadership.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-eee4eb44-44de-4021-b574-f6e0daa1b030
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] 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.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher1e7b3ea4-7b6d-4c9c-8ef4-dae5adb3a292.
[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-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_0.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:33241
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-invoker] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 16208 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_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: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_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_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_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2257>)_26}: 0,
pcollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0,
pcollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Match_41}: 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_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2257>)_26}: 0,
ref_PCollection_PCollection_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_30}: 1,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:213>)_22}:
0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:213>)_22}:
0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_14:0}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_29}: 0,
pcollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/pcollection_1:0}: 0,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_0_32}: 9,
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,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:213>)_22}:
0, pcollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/Merge}:
0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=external_2root/Init/Map/ParMultiDo(Anonymous)}: 0,
ref_PCollection_PCollection_1:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2257>)_4}:
14,
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_27:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Unkey_40}: 0,
pcollection_1:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_14}: 3,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_27:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2257>)_26}: 0,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_1_33}: 0,
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_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0,
ref_PCollection_PCollection_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_29}: 1,
ref_PCollection_PCollection_12:beam:metric:element_count:v1
{PCOLLECTION=external_2root/Init/Map/ParMultiDo(Anonymous).output}: 6,
ref_PCollection_PCollection_27:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_27}: 1,
pcollection_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/pcollection_1:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at
core.py:2257>)_26}: 0,
pcollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ExternalTransform(pytest:beam:transforms:count)/Combine.perKey(Count)/ExtractOutputs}:
0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(unicode)_17}: 0,
ref_PCollection_PCollection_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_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_14:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:212>)_21}:
0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/Map(decode)_16}: 0,
ref_PCollection_PCollection_14:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:212>)_21}:
0,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/write/pcollection:0}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(unicode)_17}: 0,
ref_PCollection_PCollection_9:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:208>)_18}:
6,
ref_PCollection_PCollection_27:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Unkey_40}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_0_32}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_0_32}: 0,
ref_PCollection_PCollection_14:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_14}: 3,
ref_PCollection_PCollection_12:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_9:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_9}: 12,
ref_PCollection_PCollection_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_17:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_1:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_2:0}: 0,
ref_PCollection_PCollection_17:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/Flatten_34}: 0,
ref_PCollection_PCollection_12:beam:metric:element_count:v1
{PCOLLECTION=ref_PCollection_PCollection_12}: 12,
ref_PCollection_PCollection_14:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:212>)_21}:
0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_1:0}: 0,
ref_PCollection_PCollection_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_9:0}: 0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:process_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2257>)_4}:
0,
ref_PCollection_PCollection_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_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: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}: 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_1:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2257>)_4}:
14,
ref_PCollection_PCollection_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_Map(<lambda at external_test.py:208>)_18}:
6,
ref_PCollection_PCollection_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=ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2257>)_4}:
0,
ref_PCollection_PCollection_1:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_2:0}: 0,
ref_PCollection_PCollection_9:beam:metric:ptransform_execution_time:total_msecs:v1
{PTRANSFORM=fn/write/ref_PCollection_PCollection_12:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=fn/read/ref_PCollection_PCollection_17:0}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:finish_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Create/Map(decode)_28}: 0,
ref_PCollection_PCollection_17:beam:metric:pardo_execution_time:start_bundle_msecs:v1
{PTRANSFORM=ref_AppliedPTransform_assert_that/Group/pair_with_0_32}: 9,
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_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)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:1}: 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_17:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_18}: DistributionResult{sum=16,
count=1, min=16, max=16},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_24:0}: DistributionResult{sum=72,
count=3, min=24, max=24},
ref_PCollection_PCollection_17:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_19}: DistributionResult{sum=15,
count=1, min=15, max=15},
ref_PCollection_PCollection_9:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_9}: DistributionResult{sum=192,
count=12, min=16, max=16},
ref_PCollection_PCollection_17:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_22}: DistributionResult{sum=17,
count=1, min=17, max=17},
ref_PCollection_PCollection_9:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_10}: DistributionResult{sum=168,
count=12, min=14, max=14},
ref_PCollection_PCollection_9:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_12}: DistributionResult{sum=168,
count=12, min=14, max=14},
ref_PCollection_PCollection_9:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_11}: DistributionResult{sum=168,
count=12, min=14, max=14},
ref_PCollection_PCollection_1:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_1}: DistributionResult{sum=13,
count=1, min=13, max=13},
ref_PCollection_PCollection_27:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_27}: DistributionResult{sum=58,
count=1, min=58, max=58},
ref_PCollection_PCollection_27:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_28}: DistributionResult{sum=41,
count=1, min=41, max=41},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_23}: DistributionResult{sum=63,
count=3, min=21, max=21},
ref_PCollection_PCollection_27:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_29}: DistributionResult{sum=33,
count=1, min=33, max=33},
ref_PCollection_PCollection_1:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_2}: DistributionResult{sum=165,
count=11, min=15, max=15},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_21}: DistributionResult{sum=57,
count=3, min=19, max=19},
ref_PCollection_PCollection_14:beam:metric:sampled_byte_size:v1
{PCOLLECTION=ref_PCollection_PCollection_20}: DistributionResult{sum=54,
count=3, min=18, max=18}))
[flink-runner-job-invoker] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/job_7ae67b55-79a9-47d4-af08-0d14f6c863eb/MANIFEST
has 0 artifact locations
[flink-runner-job-invoker] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/job_7ae67b55-79a9-47d4-af08-0d14f6c863eb/
> 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: 181
* What went wrong:
Execution failed for task ':sdks:python:postCommitIT'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
* 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 6m 46s
105 actionable tasks: 81 executed, 21 from cache, 3 up-to-date
Publishing build scan...
https://gradle.com/s/kikoz4zlo2zkq
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]
