Build failed in Jenkins: beam_PostCommit_XVR_Flink #1380

[Apache Jenkins Server]

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

Changes:

[apilloud] [BEAM-9027] [SQL] Fix ZetaSQL Byte Literals

[github] [BEAM-9058] Fix line-too-long exclusion regex and re-enable


------------------------------------------
[...truncated 3.38 MB...]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/16) (dc1870b7b1f7df40cdb55477221b98a9) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (5e03599bfa5b50f23049531800cd56fa) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16).
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (attempt #0) to a4a4fb58-dc9c-4ef8-868e-c1a53e2bb6c7 @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (583156924abc2e88573dbf59d7482d79) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (583156924abc2e88573dbf59d7482d79) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (attempt #0) to a4a4fb58-dc9c-4ef8-868e-c1a53e2bb6c7 @ localhost 
(dataPort=-1)
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16) (ad5f19cccfe9843caca14e8b6cc6f02b) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (486b0e52d1a38442f9dd19d857e79397) switched from CREATED to SCHEDULED.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16) (ad5f19cccfe9843caca14e8b6cc6f02b) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16) (ad5f19cccfe9843caca14e8b6cc6f02b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (486b0e52d1a38442f9dd19d857e79397) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (attempt #0) to a4a4fb58-dc9c-4ef8-868e-c1a53e2bb6c7 @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (02e4a99e92c0c8ae89af9a9ce9e0b1aa) switched from CREATED to SCHEDULED.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16) (ad5f19cccfe9843caca14e8b6cc6f02b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (02e4a99e92c0c8ae89af9a9ce9e0b1aa) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (attempt #0) to a4a4fb58-dc9c-4ef8-868e-c1a53e2bb6c7 @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (7f4b5d1b1b2c5a6d84da423b8100a83c) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (7f4b5d1b1b2c5a6d84da423b8100a83c) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16).
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (attempt #0) to a4a4fb58-dc9c-4ef8-868e-c1a53e2bb6c7 @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (ca3d81cecd8ceeb56155e648bf57e28d) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (ca3d81cecd8ceeb56155e648bf57e28d) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (attempt #0) to a4a4fb58-dc9c-4ef8-868e-c1a53e2bb6c7 @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (c77d3da66b0c4fd05e4b4dde210d390f) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (c77d3da66b0c4fd05e4b4dde210d390f) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (attempt #0) to a4a4fb58-dc9c-4ef8-868e-c1a53e2bb6c7 @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (8b9fbbf0c5b56b9b55265e174182e3e9) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (8b9fbbf0c5b56b9b55265e174182e3e9) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (attempt #0) to a4a4fb58-dc9c-4ef8-868e-c1a53e2bb6c7 @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16) (8e7c06e043a117ae00de7d5fe1159589) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16) (8e7c06e043a117ae00de7d5fe1159589) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16) (8e7c06e043a117ae00de7d5fe1159589) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16) (8e7c06e043a117ae00de7d5fe1159589) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16) (01539bd992dd302caa8cec6a78b1245f) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16) (01539bd992dd302caa8cec6a78b1245f) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16) (01539bd992dd302caa8cec6a78b1245f) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16) (3ad085860cb6455fdbb974a2bd6b5182) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16) (3ad085860cb6455fdbb974a2bd6b5182) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16) (3ad085860cb6455fdbb974a2bd6b5182) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16) (01539bd992dd302caa8cec6a78b1245f) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/16) (dc1870b7b1f7df40cdb55477221b98a9) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16) (ad5f19cccfe9843caca14e8b6cc6f02b) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16) (3ad085860cb6455fdbb974a2bd6b5182) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/16) (dc1870b7b1f7df40cdb55477221b98a9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16) (ad5f19cccfe9843caca14e8b6cc6f02b) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (11/16) (6db24cf7fe2931ab2b26101a65935e0b) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (11/16) (6db24cf7fe2931ab2b26101a65935e0b).
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (8fe67215bb8a3e8619b06906a66c5d78) switched from CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (9/16) (5614a1ea9d3e8e1e44bcdaf803f2b282) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (9/16) (5614a1ea9d3e8e1e44bcdaf803f2b282).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16) (01539bd992dd302caa8cec6a78b1245f) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (8fe67215bb8a3e8619b06906a66c5d78) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (8fe67215bb8a3e8619b06906a66c5d78) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16) (3ad085860cb6455fdbb974a2bd6b5182) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (8fe67215bb8a3e8619b06906a66c5d78) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/16) (0f33c81e231534b9eebbb4b0b5656a17) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (8fe67215bb8a3e8619b06906a66c5d78) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16) (01539bd992dd302caa8cec6a78b1245f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16) (3ad085860cb6455fdbb974a2bd6b5182) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/16) (0f33c81e231534b9eebbb4b0b5656a17) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16).
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (8fe67215bb8a3e8619b06906a66c5d78) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (5e03599bfa5b50f23049531800cd56fa) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (5e03599bfa5b50f23049531800cd56fa) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16) (8e7c06e043a117ae00de7d5fe1159589) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (5e03599bfa5b50f23049531800cd56fa) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (583156924abc2e88573dbf59d7482d79) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16) (8e7c06e043a117ae00de7d5fe1159589) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (583156924abc2e88573dbf59d7482d79) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (583156924abc2e88573dbf59d7482d79) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (583156924abc2e88573dbf59d7482d79) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/16) (70c1645e363f44b90080394ccc9ce3bf) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16).
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/16) (70c1645e363f44b90080394ccc9ce3bf) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (583156924abc2e88573dbf59d7482d79) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (583156924abc2e88573dbf59d7482d79) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (5e03599bfa5b50f23049531800cd56fa) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (5e03599bfa5b50f23049531800cd56fa) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (5e03599bfa5b50f23049531800cd56fa) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (486b0e52d1a38442f9dd19d857e79397) switched from CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (4/16) (aa30768f641943974e57c00ba8798cd5) switched from 
RUNNING to FINISHED.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (486b0e52d1a38442f9dd19d857e79397) [DEPLOYING]
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (4/16) (aa30768f641943974e57c00ba8798cd5).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (486b0e52d1a38442f9dd19d857e79397) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (486b0e52d1a38442f9dd19d857e79397) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (486b0e52d1a38442f9dd19d857e79397) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16).
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (486b0e52d1a38442f9dd19d857e79397) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (02e4a99e92c0c8ae89af9a9ce9e0b1aa) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (02e4a99e92c0c8ae89af9a9ce9e0b1aa) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (02e4a99e92c0c8ae89af9a9ce9e0b1aa) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (02e4a99e92c0c8ae89af9a9ce9e0b1aa) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (02e4a99e92c0c8ae89af9a9ce9e0b1aa) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (02e4a99e92c0c8ae89af9a9ce9e0b1aa) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (7f4b5d1b1b2c5a6d84da423b8100a83c) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (7f4b5d1b1b2c5a6d84da423b8100a83c) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (7f4b5d1b1b2c5a6d84da423b8100a83c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (7f4b5d1b1b2c5a6d84da423b8100a83c) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (7f4b5d1b1b2c5a6d84da423b8100a83c) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (ca3d81cecd8ceeb56155e648bf57e28d) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (7f4b5d1b1b2c5a6d84da423b8100a83c) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (ca3d81cecd8ceeb56155e648bf57e28d) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (ca3d81cecd8ceeb56155e648bf57e28d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (ca3d81cecd8ceeb56155e648bf57e28d) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (ca3d81cecd8ceeb56155e648bf57e28d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (ca3d81cecd8ceeb56155e648bf57e28d) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (6/16) (2e03338690618ac8da4ab500662bfc99) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (6/16) (2e03338690618ac8da4ab500662bfc99).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (c77d3da66b0c4fd05e4b4dde210d390f) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (c77d3da66b0c4fd05e4b4dde210d390f) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (c77d3da66b0c4fd05e4b4dde210d390f) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (c77d3da66b0c4fd05e4b4dde210d390f) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (c77d3da66b0c4fd05e4b4dde210d390f) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (c77d3da66b0c4fd05e4b4dde210d390f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16).
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (1/16) (508ade013fc76ddf3b1d49d5fa8ed205) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (1/16) (508ade013fc76ddf3b1d49d5fa8ed205).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (8b9fbbf0c5b56b9b55265e174182e3e9) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (8b9fbbf0c5b56b9b55265e174182e3e9) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (8b9fbbf0c5b56b9b55265e174182e3e9) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (8b9fbbf0c5b56b9b55265e174182e3e9) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (8b9fbbf0c5b56b9b55265e174182e3e9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (8b9fbbf0c5b56b9b55265e174182e3e9) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (15/16) (a15f816110b1b1fce484338bd1d1c2e4) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (15/16) (a15f816110b1b1fce484338bd1d1c2e4).
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (5/16) (0da6f4e902883aa79a28452406c636bf) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (5/16) (0da6f4e902883aa79a28452406c636bf).
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (14/16) (eccab5d69241114709646366d74b5579) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (14/16) (eccab5d69241114709646366d74b5579).
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (12/16) (1d4f0cdccfc53f9f8dba87c4aa0e71a5) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (12/16) (1d4f0cdccfc53f9f8dba87c4aa0e71a5).
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (16/16) (7493093d667ae4e7d8a5d46326fa269d) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (16/16) (7493093d667ae4e7d8a5d46326fa269d).
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (8/16) (26e65525be60077cd1e2f9eb29a0f61a) [FINISHED]
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (13/16) (7e90558f1ea0822c2b8a8317eec7f574) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (13/16) (7e90558f1ea0822c2b8a8317eec7f574).
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) 26e65525be60077cd1e2f9eb29a0f61a.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (8/16) (26e65525be60077cd1e2f9eb29a0f61a) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (10/16) (8af8a37c8e9b2eef55f147c3e572f15c) [FINISHED]
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (13/16) (7e90558f1ea0822c2b8a8317eec7f574) [FINISHED]
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (2/16) (24136c6cc17bb5eb0c850253de1bea08) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (14/16) (eccab5d69241114709646366d74b5579) [FINISHED]
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (16/16) (7493093d667ae4e7d8a5d46326fa269d) [FINISHED]
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (5/16) (0da6f4e902883aa79a28452406c636bf) [FINISHED]
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (15/16) (a15f816110b1b1fce484338bd1d1c2e4) [FINISHED]
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (12/16) (1d4f0cdccfc53f9f8dba87c4aa0e71a5) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) 8af8a37c8e9b2eef55f147c3e572f15c.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (2/16) (24136c6cc17bb5eb0c850253de1bea08).
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) 7e90558f1ea0822c2b8a8317eec7f574.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) eccab5d69241114709646366d74b5579.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (10/16) (8af8a37c8e9b2eef55f147c3e572f15c) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) 7493093d667ae4e7d8a5d46326fa269d.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (13/16) (7e90558f1ea0822c2b8a8317eec7f574) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) a15f816110b1b1fce484338bd1d1c2e4.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) 1d4f0cdccfc53f9f8dba87c4aa0e71a5.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (14/16) (eccab5d69241114709646366d74b5579) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) 0da6f4e902883aa79a28452406c636bf.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (16/16) (7493093d667ae4e7d8a5d46326fa269d) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (15/16) (a15f816110b1b1fce484338bd1d1c2e4) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (12/16) (1d4f0cdccfc53f9f8dba87c4aa0e71a5) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (5/16) (0da6f4e902883aa79a28452406c636bf) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (1/16) (508ade013fc76ddf3b1d49d5fa8ed205) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) 508ade013fc76ddf3b1d49d5fa8ed205.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (1/16) (508ade013fc76ddf3b1d49d5fa8ed205) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (6/16) (2e03338690618ac8da4ab500662bfc99) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) 2e03338690618ac8da4ab500662bfc99.
[flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (6/16) (2e03338690618ac8da4ab500662bfc99) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (4/16) (aa30768f641943974e57c00ba8798cd5) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) aa30768f641943974e57c00ba8798cd5.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (4/16) (aa30768f641943974e57c00ba8798cd5) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (3/16) (51d0ded215b76c441ef54e809530227c) switched from 
RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for CHAIN MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at 
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> 
Map (Key Extractor) (3/16) (51d0ded215b76c441ef54e809530227c).
OpenJDK 64-Bit Server VM warning: INFO: os::commit_memory(0x000000076da80000, 
522190848, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 522190848 bytes for committing 
reserved memory.
# An error report file with more information is saved as:
# /opt/apache/beam/hs_err_pid6.log
FATAL: command execution failed
hudson.remoting.ChannelClosedException: Channel "unknown": Remote call on 
JNLP4-connect connection from 
132.78.198.104.bc.googleusercontent.com/104.198.78.132:43388 failed. The 
channel is closing down or has closed down
        at hudson.remoting.Channel.call(Channel.java:950)
        at 
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:283)
        at com.sun.proxy.$Proxy141.isAlive(Unknown Source)
        at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1150)
        at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1142)
        at hudson.Launcher$ProcStarter.join(Launcher.java:470)
        at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
        at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:741)
        at hudson.model.Build$BuildExecution.build(Build.java:206)
        at hudson.model.Build$BuildExecution.doRun(Build.java:163)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:504)
        at hudson.model.Run.execute(Run.java:1815)
        at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
        at hudson.model.ResourceController.execute(ResourceController.java:97)
        at hudson.model.Executor.run(Executor.java:429)
Caused by: java.nio.channels.ClosedChannelException
        at 
org.jenkinsci.remoting.protocol.impl.ChannelApplicationLayer.onReadClosed(ChannelApplicationLayer.java:209)
        at 
org.jenkinsci.remoting.protocol.ApplicationLayer.onRecvClosed(ApplicationLayer.java:222)
        at 
org.jenkinsci.remoting.protocol.ProtocolStack$Ptr.onRecvClosed(ProtocolStack.java:816)
        at 
org.jenkinsci.remoting.protocol.FilterLayer.onRecvClosed(FilterLayer.java:287)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.onRecvClosed(SSLEngineFilterLayer.java:181)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.switchToNoSecure(SSLEngineFilterLayer.java:283)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.processWrite(SSLEngineFilterLayer.java:503)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.processQueuedWrites(SSLEngineFilterLayer.java:248)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.doSend(SSLEngineFilterLayer.java:200)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.doCloseSend(SSLEngineFilterLayer.java:213)
        at 
org.jenkinsci.remoting.protocol.ProtocolStack$Ptr.doCloseSend(ProtocolStack.java:784)
        at 
org.jenkinsci.remoting.protocol.ApplicationLayer.doCloseWrite(ApplicationLayer.java:173)
        at 
org.jenkinsci.remoting.protocol.impl.ChannelApplicationLayer$ByteBufferCommandTransport.closeWrite(ChannelApplicationLayer.java:314)
        at hudson.remoting.Channel.close(Channel.java:1452)
        at hudson.remoting.Channel.close(Channel.java:1405)
        at hudson.slaves.SlaveComputer.closeChannel(SlaveComputer.java:847)
        at hudson.slaves.SlaveComputer.access$800(SlaveComputer.java:108)
        at hudson.slaves.SlaveComputer$3.run(SlaveComputer.java:756)
        at 
jenkins.util.ContextResettingExecutorService$1.run(ContextResettingExecutorService.java:28)
        at 
jenkins.security.ImpersonatingExecutorService$1.run(ImpersonatingExecutorService.java:59)
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-9 is offline; cannot locate JDK 1.8 (latest)

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org