Build failed in Jenkins: beam_PostCommit_XVR_Flink #1486

[Apache Jenkins Server]

See 
<https://builds.apache.org/job/beam_PostCommit_XVR_Flink/1486/display/redirect>

Changes:


------------------------------------------
[...truncated 3.36 MB...]
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (attempt #0) to 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (95d998f185601ee4a6a3445b679bcbf5) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (95d998f185601ee4a6a3445b679bcbf5) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-13] 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 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (e89a0bb2007fffd4b45023c0ae145c81) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (e89a0bb2007fffd4b45023c0ae145c81) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-13] 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 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[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 - 
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) (b25730a3d97fd33a098e12bbd41e1cea) 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 - 
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) (10/16) (b25730a3d97fd33a098e12bbd41e1cea).
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (d07e802954acb0f861b13765d2df3b90) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (d07e802954acb0f861b13765d2df3b90) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-13] 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 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (a6a4d253365bc7d7e0099d5c2d09ff98) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (a6a4d253365bc7d7e0099d5c2d09ff98) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-13] 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 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (75fe34b22a69482bd32c17d871737a65) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (75fe34b22a69482bd32c17d871737a65) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-13] 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 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (f589fccb6adbb663ef95edb51ff04f97) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (f589fccb6adbb663ef95edb51ff04f97) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-13] 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 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (5d6d7fa75827fa22ffd55aef8efbdb21) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (5d6d7fa75827fa22ffd55aef8efbdb21) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-13] 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 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (0f7afe53791f10bef91d912d1d2f67cc) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (0f7afe53791f10bef91d912d1d2f67cc) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-13] 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 07fffe40-3dd1-4948-a263-4b90850124cf @ localhost 
(dataPort=-1)
[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) (d1168e92e03a7ea56bf6a6075e051990) 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) (d1168e92e03a7ea56bf6a6075e051990).
[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) (b25730a3d97fd33a098e12bbd41e1cea) [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) (e8d0776d8295db5f672b20b8f6abedbe) [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 - 
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) (65ae83ba9f2a40179678b55a0a0236cd) 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) (65ae83ba9f2a40179678b55a0a0236cd).
[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 - 
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) (11/16) (65ae83ba9f2a40179678b55a0a0236cd) [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) (d1168e92e03a7ea56bf6a6075e051990) [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 - 
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) (5e3390b65b17d14f744c07158f59adba) 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 - 
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) (5e3390b65b17d14f744c07158f59adba).
[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) (5e3390b65b17d14f744c07158f59adba) [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 - 
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) (f6f796bb24b5edb733e71bad8236f274) 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) (f6f796bb24b5edb733e71bad8236f274).
[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 - 
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) (a45aa4cb5e80d92bb93c0405f35bfbb8) 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) (8/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) (8/16) (a45aa4cb5e80d92bb93c0405f35bfbb8).
[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) (7/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) (7/16) (2a648619d20358093652fab653b279f5) 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) (7/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) (7/16) (2a648619d20358093652fab653b279f5).
[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) (0e067d920081b1c729b99e59f005f6af) 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) (0e067d920081b1c729b99e59f005f6af).
[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 - 
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) (9/16) (0e067d920081b1c729b99e59f005f6af) [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) (7/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) (7/16) (2a648619d20358093652fab653b279f5) [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 - 
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) (9af90a4ed5d0abb4967e14043f452f2c) 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) (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) (a45aa4cb5e80d92bb93c0405f35bfbb8) [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) (9af90a4ed5d0abb4967e14043f452f2c).
[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) (f6f796bb24b5edb733e71bad8236f274) [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) (9af90a4ed5d0abb4967e14043f452f2c) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/16).
[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) (fcab3c187fef5aa6f091d3d30248e809) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/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) 
(1/16) (fcab3c187fef5aa6f091d3d30248e809) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/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) 
(1/16) (fcab3c187fef5aa6f091d3d30248e809) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/16) (fcab3c187fef5aa6f091d3d30248e809) [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) (fcab3c187fef5aa6f091d3d30248e809) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/16).
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(1/16) (fcab3c187fef5aa6f091d3d30248e809) switched from DEPLOYING to RUNNING.
[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) (77f81fdcc40a7184fc803ff2cfdedef9) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/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) 
(2/16) (77f81fdcc40a7184fc803ff2cfdedef9) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/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) 
(2/16) (77f81fdcc40a7184fc803ff2cfdedef9) [DEPLOYING].
[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) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/16) (77f81fdcc40a7184fc803ff2cfdedef9) [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) (77f81fdcc40a7184fc803ff2cfdedef9) 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.
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(2/16) (77f81fdcc40a7184fc803ff2cfdedef9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/16).
[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) (ffe9140023d69fb096db68d0e20f5c7e) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/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) 
(3/16) (ffe9140023d69fb096db68d0e20f5c7e) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/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) 
(3/16) (ffe9140023d69fb096db68d0e20f5c7e) [DEPLOYING].
[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) (ffe9140023d69fb096db68d0e20f5c7e) [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) (ffe9140023d69fb096db68d0e20f5c7e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-14] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(3/16) (ffe9140023d69fb096db68d0e20f5c7e) 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.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16).
[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) (3dda825cbc63231200195d5e1b81c66f) switched from CREATED to DEPLOYING.
[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) (3dda825cbc63231200195d5e1b81c66f) [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) (3dda825cbc63231200195d5e1b81c66f) [DEPLOYING].
[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) (3dda825cbc63231200195d5e1b81c66f) [DEPLOYING].
[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) (3dda825cbc63231200195d5e1b81c66f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16).
[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.
[flink-akka.actor.default-dispatcher-14] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(4/16) (3dda825cbc63231200195d5e1b81c66f) switched from DEPLOYING to RUNNING.
[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) (104c0755f3ce53c565990cb1509549f9) 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) (104c0755f3ce53c565990cb1509549f9) [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) (104c0755f3ce53c565990cb1509549f9) [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) (104c0755f3ce53c565990cb1509549f9) [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) (104c0755f3ce53c565990cb1509549f9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] 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)] 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-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(5/16) (104c0755f3ce53c565990cb1509549f9) switched from DEPLOYING to RUNNING.
[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) (54babe5011f33697e328a6839e4af21a) 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) (54babe5011f33697e328a6839e4af21a) [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) (54babe5011f33697e328a6839e4af21a) [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) (54babe5011f33697e328a6839e4af21a) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] 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) (54babe5011f33697e328a6839e4af21a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(6/16) (54babe5011f33697e328a6839e4af21a) switched from DEPLOYING to RUNNING.
[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) (10c89e346946df8a9dc78bb3c2ec0e27) 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) (10c89e346946df8a9dc78bb3c2ec0e27) [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) (10c89e346946df8a9dc78bb3c2ec0e27) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] 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) 
(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) (10c89e346946df8a9dc78bb3c2ec0e27) [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) (10c89e346946df8a9dc78bb3c2ec0e27) 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.
[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) (1142e5eed80fa456ed85cec435a6e847) switched from CREATED to DEPLOYING.
[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) (1142e5eed80fa456ed85cec435a6e847) [DEPLOYING]
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(7/16) (10c89e346946df8a9dc78bb3c2ec0e27) 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 - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (1142e5eed80fa456ed85cec435a6e847) [DEPLOYING].
[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) (1142e5eed80fa456ed85cec435a6e847) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] 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 - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (1142e5eed80fa456ed85cec435a6e847) 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) (95d998f185601ee4a6a3445b679bcbf5) 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) (95d998f185601ee4a6a3445b679bcbf5) [DEPLOYING]
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(8/16) (1142e5eed80fa456ed85cec435a6e847) 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) (95d998f185601ee4a6a3445b679bcbf5) [DEPLOYING].
[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-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16).
[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) (95d998f185601ee4a6a3445b679bcbf5) [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) (95d998f185601ee4a6a3445b679bcbf5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(9/16) (95d998f185601ee4a6a3445b679bcbf5) 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) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (e89a0bb2007fffd4b45023c0ae145c81) switched from CREATED to DEPLOYING.
[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) (e89a0bb2007fffd4b45023c0ae145c81) [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) (e89a0bb2007fffd4b45023c0ae145c81) [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) (e89a0bb2007fffd4b45023c0ae145c81) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16).
[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) (e89a0bb2007fffd4b45023c0ae145c81) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(10/16) (e89a0bb2007fffd4b45023c0ae145c81) 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) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (d07e802954acb0f861b13765d2df3b90) switched from CREATED to DEPLOYING.
[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) (d07e802954acb0f861b13765d2df3b90) [DEPLOYING]
[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) (d07e802954acb0f861b13765d2df3b90) [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) (d07e802954acb0f861b13765d2df3b90) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16).
[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) (d07e802954acb0f861b13765d2df3b90) switched from DEPLOYING to RUNNING.
[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) (a6a4d253365bc7d7e0099d5c2d09ff98) switched from CREATED to DEPLOYING.
[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 - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (a6a4d253365bc7d7e0099d5c2d09ff98) [DEPLOYING]
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(11/16) (d07e802954acb0f861b13765d2df3b90) switched from DEPLOYING to RUNNING.
[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) (a6a4d253365bc7d7e0099d5c2d09ff98) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] 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) 
(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) (a6a4d253365bc7d7e0099d5c2d09ff98) [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) (a6a4d253365bc7d7e0099d5c2d09ff98) 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-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(12/16) (a6a4d253365bc7d7e0099d5c2d09ff98) switched from DEPLOYING to RUNNING.
[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) (75fe34b22a69482bd32c17d871737a65) 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) (75fe34b22a69482bd32c17d871737a65) [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) (75fe34b22a69482bd32c17d871737a65) [DEPLOYING].
[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) (75fe34b22a69482bd32c17d871737a65) [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) (75fe34b22a69482bd32c17d871737a65) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] 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)] 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-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(13/16) (75fe34b22a69482bd32c17d871737a65) 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) (f589fccb6adbb663ef95edb51ff04f97) switched from CREATED to DEPLOYING.
[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) (f589fccb6adbb663ef95edb51ff04f97) [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) (f589fccb6adbb663ef95edb51ff04f97) [DEPLOYING].
[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) (f589fccb6adbb663ef95edb51ff04f97) [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) (f589fccb6adbb663ef95edb51ff04f97) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(14/16) (f589fccb6adbb663ef95edb51ff04f97) 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.
[flink-akka.actor.default-dispatcher-8] 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) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (5d6d7fa75827fa22ffd55aef8efbdb21) 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) (5d6d7fa75827fa22ffd55aef8efbdb21) [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) (5d6d7fa75827fa22ffd55aef8efbdb21) [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) (5d6d7fa75827fa22ffd55aef8efbdb21) [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) (5d6d7fa75827fa22ffd55aef8efbdb21) 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-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(15/16) (5d6d7fa75827fa22ffd55aef8efbdb21) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16).
[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) (0f7afe53791f10bef91d912d1d2f67cc) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) b25730a3d97fd33a098e12bbd41e1cea.
[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) (0f7afe53791f10bef91d912d1d2f67cc) [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) (0f7afe53791f10bef91d912d1d2f67cc) [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) (0f7afe53791f10bef91d912d1d2f67cc) [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) (0f7afe53791f10bef91d912d1d2f67cc) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-15] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
(16/16) (0f7afe53791f10bef91d912d1d2f67cc) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) e8d0776d8295db5f672b20b8f6abedbe.
[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.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) 65ae83ba9f2a40179678b55a0a0236cd.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) d1168e92e03a7ea56bf6a6075e051990.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) 5e3390b65b17d14f744c07158f59adba.
[flink-akka.actor.default-dispatcher-15] 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) (b25730a3d97fd33a098e12bbd41e1cea) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) 0e067d920081b1c729b99e59f005f6af.
[flink-akka.actor.default-dispatcher-15] 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) (e8d0776d8295db5f672b20b8f6abedbe) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) a45aa4cb5e80d92bb93c0405f35bfbb8.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) f6f796bb24b5edb733e71bad8236f274.
[flink-akka.actor.default-dispatcher-15] 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) (11/16) (65ae83ba9f2a40179678b55a0a0236cd) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) 2a648619d20358093652fab653b279f5.
[flink-akka.actor.default-dispatcher-15] 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) (d1168e92e03a7ea56bf6a6075e051990) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN 
MapPartition (MapPartition at 
[3]{ExternalTransform(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) 9af90a4ed5d0abb4967e14043f452f2c.
[flink-akka.actor.default-dispatcher-15] 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) (5e3390b65b17d14f744c07158f59adba) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-15] 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) (9/16) (0e067d920081b1c729b99e59f005f6af) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-15] 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) (a45aa4cb5e80d92bb93c0405f35bfbb8) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-15] 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) (f6f796bb24b5edb733e71bad8236f274) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-15] 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) (7/16) (2a648619d20358093652fab653b279f5) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-15] 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) (9af90a4ed5d0abb4967e14043f452f2c) switched from 
RUNNING to FINISHED.
OpenJDK 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000703e80000, 
445120512, 0) failed; error='Cannot allocate memory' (errno=12)
FATAL: command execution failed
hudson.remoting.ChannelClosedException: Channel "unknown": Remote call on 
JNLP4-connect connection from 
192.194.239.35.bc.googleusercontent.com/35.239.194.192:39588 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.$Proxy145.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-7 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