Build failed in Jenkins: beam_PostCommit_XVR_Flink #1340

[Apache Jenkins Server]

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

Changes:

[sunjincheng121] [BEAM-8935] Fail fast if sdk harness startup failed.


------------------------------------------
[...truncated 3.23 MB...]
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at 
ExtractOutput[0]) (3/16) (f171773d7ae8f2ea2c2f8e119694d213) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) 
(9dda6d1eef6b8eba5f4c8cec78f65441) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at 
ExtractOutput[0]) (13/16) (7b1a3452b89497382646f8fd88ac6a8d) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] 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) (9b4a2b08999c70c97cc4cfc579cac037) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] 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) (9b4a2b08999c70c97cc4cfc579cac037) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (7/16) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-5] 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) (2/16) (b937233699c7a6c166eef71025f1504c) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] 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) (2/16) (b937233699c7a6c166eef71025f1504c) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (2/16) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-5] 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) (627e191a4194de5e2dd5c0c9f0268831) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] 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) (627e191a4194de5e2dd5c0c9f0268831) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (16/16) (attempt #0) to 
f9334468-008f-497e-a67e-232d9d7f6238 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-5] 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) (00ef3d93d624afc6b54e395bee5713c6) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] 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) (00ef3d93d624afc6b54e395bee5713c6) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (6/16) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (a7d7d4265b35a4d94c83b85e684e2a50) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (a7d7d4265b35a4d94c83b85e684e2a50) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (3/16) (d9411ff0963a08f4d87e0683ab7d7b37) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (3/16) (d9411ff0963a08f4d87e0683ab7d7b37) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (3/16) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (d0cbff3387e05095495354493d7f3927) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (d0cbff3387e05095495354493d7f3927) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (1/16) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (0825c993984b59450d208074157c61d9) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (0825c993984b59450d208074157c61d9) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (fa853c76d0c289218a6961755fd13d95) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (fa853c76d0c289218a6961755fd13d95) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (5/16) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (aaf77c9701f7b29087c0d88ffafbcfa9) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (aaf77c9701f7b29087c0d88ffafbcfa9) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (8/16) (attempt #0) to f9334468-008f-497e-a67e-232d9d7f6238 
@ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (41b5e46c2df21076755d8a3ed8c727e4) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (41b5e46c2df21076755d8a3ed8c727e4) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (12/16) (attempt #0) to 
f9334468-008f-497e-a67e-232d9d7f6238 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (68b5428f92a31f7ebbd50e68bf9bda57) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (68b5428f92a31f7ebbd50e68bf9bda57) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (11/16) (attempt #0) to 
f9334468-008f-497e-a67e-232d9d7f6238 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (95b5b3486890c025051ee14e51ccb600) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (95b5b3486890c025051ee14e51ccb600) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (13/16) (attempt #0) to 
f9334468-008f-497e-a67e-232d9d7f6238 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] 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) (de909e3f5e5f173283705917d0d68e56) switched from 
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] 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) (de909e3f5e5f173283705917d0d68e56) switched from 
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 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) (10/16) (attempt #0) to 
f9334468-008f-497e-a67e-232d9d7f6238 @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) 
(e23b5354108c32cd6824cc93ad5fda5e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) 
(b830e6ef37a2984a0399ff07184ef1fa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) 
(c4c50640431635973c8a4c5bde05ceb0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) 
(252f55e271002addbdc883d9f58c92d9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) 
(b6aadd438044ce49220339a7b2e623fd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) 
(15c5992439cba2f16decdccab5b9ba59) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) 
(460a3f9f13ccc9ebb2be106c77744719) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) 
(4ed16f4c1b6b2a43361af5b2dc13c961) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16) 
(f937d99fc09ea0079ddf7ffc4fe5b7d8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16) 
(302deef60aee26a627d2403bde13906d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16) 
(888193d02c5dbb62fbeeca0d3b0f5291) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) 
(be2c6c295ce1128bfc6c26a07034fc29) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16) 
(259bf9ba20779200376927688b75d14e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) 
(04d6575a73fa6d2c1a4a9aa487deb4cb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at [3]{Create, Map(unicode), Map(<lambda at 
external_test.py:396>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) 
(347a991701c5b9ffd7e18a2f9059dda4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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) (29aacb3f6c5e1e6bb96f9f8c3cd7a3a6) 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) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (29aacb3f6c5e1e6bb96f9f8c3cd7a3a6) [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) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (29aacb3f6c5e1e6bb96f9f8c3cd7a3a6) [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) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (29aacb3f6c5e1e6bb96f9f8c3cd7a3a6) [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) (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) (29aacb3f6c5e1e6bb96f9f8c3cd7a3a6) switched from 
DEPLOYING to RUNNING.
[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) (14/16) (29aacb3f6c5e1e6bb96f9f8c3cd7a3a6) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (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) (9b4a2b08999c70c97cc4cfc579cac037) 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) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (9b4a2b08999c70c97cc4cfc579cac037) [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) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (9b4a2b08999c70c97cc4cfc579cac037) [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) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (9b4a2b08999c70c97cc4cfc579cac037) [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) (14/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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.taskexecutor.TaskExecutor - Received 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).
[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) (9b4a2b08999c70c97cc4cfc579cac037) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] 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) (9b4a2b08999c70c97cc4cfc579cac037) 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) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (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) (b937233699c7a6c166eef71025f1504c) 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) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (2/16) (b937233699c7a6c166eef71025f1504c) [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) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (2/16) (b937233699c7a6c166eef71025f1504c) [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) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (b937233699c7a6c166eef71025f1504c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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) (b937233699c7a6c166eef71025f1504c) switched from 
DEPLOYING to RUNNING.
[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) (2/16) (b937233699c7a6c166eef71025f1504c) 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) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (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) (627e191a4194de5e2dd5c0c9f0268831) 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) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (627e191a4194de5e2dd5c0c9f0268831) [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) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (627e191a4194de5e2dd5c0c9f0268831) [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) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (627e191a4194de5e2dd5c0c9f0268831) [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) (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) (627e191a4194de5e2dd5c0c9f0268831) 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) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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 - 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) (627e191a4194de5e2dd5c0c9f0268831) 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) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters 
length limit and was truncated.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (00ef3d93d624afc6b54e395bee5713c6) 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) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (00ef3d93d624afc6b54e395bee5713c6) [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) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (00ef3d93d624afc6b54e395bee5713c6) [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) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (00ef3d93d624afc6b54e395bee5713c6) [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) (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) (00ef3d93d624afc6b54e395bee5713c6) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters 
length limit and was truncated.
[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) (6/16) (00ef3d93d624afc6b54e395bee5713c6) 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) (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) (a7d7d4265b35a4d94c83b85e684e2a50) 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 - 
Creating FileSystem stream leak safety net 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) (a7d7d4265b35a4d94c83b85e684e2a50) [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 - 
Loading JAR files 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) (a7d7d4265b35a4d94c83b85e684e2a50) [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) (6/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (a7d7d4265b35a4d94c83b85e684e2a50) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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) (a7d7d4265b35a4d94c83b85e684e2a50) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] 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) (a7d7d4265b35a4d94c83b85e684e2a50) 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) (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) (d9411ff0963a08f4d87e0683ab7d7b37) 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)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (3/16) (d9411ff0963a08f4d87e0683ab7d7b37) [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) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (3/16) (d9411ff0963a08f4d87e0683ab7d7b37) [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) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (d9411ff0963a08f4d87e0683ab7d7b37) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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) (d9411ff0963a08f4d87e0683ab7d7b37) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] 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) (3/16) (d9411ff0963a08f4d87e0683ab7d7b37) 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) (3/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (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) (d0cbff3387e05095495354493d7f3927) 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) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (d0cbff3387e05095495354493d7f3927) [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) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (d0cbff3387e05095495354493d7f3927) [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) (3/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (d0cbff3387e05095495354493d7f3927) [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) (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) (d0cbff3387e05095495354493d7f3927) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] 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) (d0cbff3387e05095495354493d7f3927) 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) (1/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters 
length limit and was truncated.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (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) (0825c993984b59450d208074157c61d9) 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 - 
Creating FileSystem stream leak safety net 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) (0825c993984b59450d208074157c61d9) [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 - 
Loading JAR files 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) (0825c993984b59450d208074157c61d9) [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 - 
Registering task at network: 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) (0825c993984b59450d208074157c61d9) [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) (0825c993984b59450d208074157c61d9) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[flink-akka.actor.default-dispatcher-5] 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) (0825c993984b59450d208074157c61d9) 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) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (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) (fa853c76d0c289218a6961755fd13d95) 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) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (fa853c76d0c289218a6961755fd13d95) [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) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (fa853c76d0c289218a6961755fd13d95) [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) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (fa853c76d0c289218a6961755fd13d95) [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) (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) (fa853c76d0c289218a6961755fd13d95) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] 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) (fa853c76d0c289218a6961755fd13d95) 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) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters 
length limit and was truncated.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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) (aaf77c9701f7b29087c0d88ffafbcfa9) 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) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (aaf77c9701f7b29087c0d88ffafbcfa9) [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) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (aaf77c9701f7b29087c0d88ffafbcfa9) [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) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (aaf77c9701f7b29087c0d88ffafbcfa9) [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) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (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) (aaf77c9701f7b29087c0d88ffafbcfa9) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] 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) (aaf77c9701f7b29087c0d88ffafbcfa9) 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) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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) (41b5e46c2df21076755d8a3ed8c727e4) 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) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (41b5e46c2df21076755d8a3ed8c727e4) [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) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (41b5e46c2df21076755d8a3ed8c727e4) [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) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (41b5e46c2df21076755d8a3ed8c727e4) [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) (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) (41b5e46c2df21076755d8a3ed8c727e4) 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) (12/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters 
length limit and was truncated.
[flink-akka.actor.default-dispatcher-6] 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) (41b5e46c2df21076755d8a3ed8c727e4) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (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) (68b5428f92a31f7ebbd50e68bf9bda57) 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) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (68b5428f92a31f7ebbd50e68bf9bda57) [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) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (68b5428f92a31f7ebbd50e68bf9bda57) [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) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (68b5428f92a31f7ebbd50e68bf9bda57) [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) (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) (68b5428f92a31f7ebbd50e68bf9bda57) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] 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) (68b5428f92a31f7ebbd50e68bf9bda57) 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)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters 
length limit and was truncated.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
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) (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) (95b5b3486890c025051ee14e51ccb600) 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) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (95b5b3486890c025051ee14e51ccb600) [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) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (95b5b3486890c025051ee14e51ccb600) [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) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (95b5b3486890c025051ee14e51ccb600) [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) (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) (95b5b3486890c025051ee14e51ccb600) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] 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) (95b5b3486890c025051ee14e51ccb600) 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) (13/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (13/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received 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).
[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) (de909e3f5e5f173283705917d0d68e56) 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) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net 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) (de909e3f5e5f173283705917d0d68e56) [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) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files 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) (de909e3f5e5f173283705917d0d68e56) [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) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 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) (de909e3f5e5f173283705917d0d68e56) [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) (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) (de909e3f5e5f173283705917d0d68e56) switched from 
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] 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) (de909e3f5e5f173283705917d0d68e56) 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) (10/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
[3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), 
ExternalTransform(beam:transforms:xlang:count)}) 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) (10/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) 
exceeded the 80 characters length limit and was truncated.
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map OpenJDK 64-Bit Server VM 
warning: INFO: os::commit_memory(0x000000072c600000, 304087040, 0) failed; 
error='Cannot allocate memory' (errno=12)
304087040 bytes for committing reserved memory.
# An error report file with more information is saved as:
# /opt/apache/beam/hs_err_pid6.log
# [ timer expired, abort... ]
FATAL: command execution failed
hudson.remoting.ChannelClosedException: Channel "unknown": Remote call on 
JNLP4-connect connection from 
165.171.154.104.bc.googleusercontent.com/104.154.171.165:43674 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-12 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