Build failed in Jenkins: beam_PostCommit_XVR_Flink #1435

[Apache Jenkins Server <je...@builds.apache.org>]

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

Changes:


------------------------------------------
[...truncated 3.24 MB...]
[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) (10/16) (b8a88e2b58c85910dd5f91eb56e253f5) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[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) (9/16) (4691c6b4966778286c070862ef77d35d) switched from CREATED to SCHEDULED.
[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) (9/16) (4691c6b4966778286c070862ef77d35d) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[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) (11/16) (6b83c3656ad33fb7ea97a5776596025a) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] 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).
[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) (11/16) (6b83c3656ad33fb7ea97a5776596025a) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[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) (75b72fb5f8d990b972d6cadab723ac37) switched from CREATED to SCHEDULED.
[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) (75b72fb5f8d990b972d6cadab723ac37) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (10/16) (b8a88e2b58c85910dd5f91eb56e253f5) 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) (b8a88e2b58c85910dd5f91eb56e253f5) [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) (b8a88e2b58c85910dd5f91eb56e253f5) [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) (b8a88e2b58c85910dd5f91eb56e253f5) [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) (b8a88e2b58c85910dd5f91eb56e253f5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] 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).
[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) (10/16) (b8a88e2b58c85910dd5f91eb56e253f5) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (7f65e1158299a9d81cd7d3786168a484) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (10/16)] 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]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (7f65e1158299a9d81cd7d3786168a484).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (7bf8952d3dec8f0deaff8fc80bba26cd) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (7bf8952d3dec8f0deaff8fc80bba26cd).
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (e467014dab883fca531ac171f431f578) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (e467014dab883fca531ac171f431f578).
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (d0c8cc36c1bab0f03fae43849df792a3) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (d0c8cc36c1bab0f03fae43849df792a3).
[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) (15/16) (acd025e7f29e47922111edb9f1bed6a5) switched from CREATED to SCHEDULED.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (4691c6b4966778286c070862ef77d35d) 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) (4691c6b4966778286c070862ef77d35d) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16) (65075e1b8281625e10213a2326f6d172) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - 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) (4691c6b4966778286c070862ef77d35d) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16) (65075e1b8281625e10213a2326f6d172).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (4691c6b4966778286c070862ef77d35d) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (9/16) (4691c6b4966778286c070862ef77d35d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] 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) (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) (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) (6b83c3656ad33fb7ea97a5776596025a) 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) (6b83c3656ad33fb7ea97a5776596025a) [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) (6b83c3656ad33fb7ea97a5776596025a) [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) (6b83c3656ad33fb7ea97a5776596025a) [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) (6b83c3656ad33fb7ea97a5776596025a) 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)] 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-8] 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).
[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) (15/16) (acd025e7f29e47922111edb9f1bed6a5) switched from SCHEDULED 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)] 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 - 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) (15/16) (attempt #0) to 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[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) (4691c6b4966778286c070862ef77d35d) 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) (6b83c3656ad33fb7ea97a5776596025a) 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 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) (75b72fb5f8d990b972d6cadab723ac37) 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) (75b72fb5f8d990b972d6cadab723ac37) [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) (75b72fb5f8d990b972d6cadab723ac37) [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) (75b72fb5f8d990b972d6cadab723ac37) [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 - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (75b72fb5f8d990b972d6cadab723ac37) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] 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) (15/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (2/16) (75b72fb5f8d990b972d6cadab723ac37) 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) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (15/16) (acd025e7f29e47922111edb9f1bed6a5) 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) (15/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) (15/16) (acd025e7f29e47922111edb9f1bed6a5) [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) (15/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) (15/16) (acd025e7f29e47922111edb9f1bed6a5) [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) (15/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) (15/16) (acd025e7f29e47922111edb9f1bed6a5) [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) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (15/16) (acd025e7f29e47922111edb9f1bed6a5) 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-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (15/16) (acd025e7f29e47922111edb9f1bed6a5) 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) (15/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) (15/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]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (2e46b7cbe003e934fa7384d071e02044) [FINISHED]
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (0283d33136dfc725ba00d2309796123d) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) 2e46b7cbe003e934fa7384d071e02044.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) 0283d33136dfc725ba00d2309796123d.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (2e46b7cbe003e934fa7384d071e02044) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (0283d33136dfc725ba00d2309796123d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (5/16) (b6bfd831dcbba6b570c35666910d5e1a) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (5/16) (b6bfd831dcbba6b570c35666910d5e1a) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (1/16) (053f5f073d6c56f2470c3df8671affe2) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (1/16) (053f5f073d6c56f2470c3df8671affe2) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-8] 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).
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (4028d2d216b8e8d151bc6ba73ba2b1cb) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (4028d2d216b8e8d151bc6ba73ba2b1cb).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (16/16) (ac6ab325c508f337e751a05990c12975) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (16/16) (ac6ab325c508f337e751a05990c12975) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (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) (b6bfd831dcbba6b570c35666910d5e1a) 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) (b6bfd831dcbba6b570c35666910d5e1a) [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) (b6bfd831dcbba6b570c35666910d5e1a) [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) (b6bfd831dcbba6b570c35666910d5e1a) [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) (b6bfd831dcbba6b570c35666910d5e1a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (5/16) (b6bfd831dcbba6b570c35666910d5e1a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] 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) (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.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (053f5f073d6c56f2470c3df8671affe2) 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) (053f5f073d6c56f2470c3df8671affe2) [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) (053f5f073d6c56f2470c3df8671affe2) [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) (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) (053f5f073d6c56f2470c3df8671affe2) [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) (053f5f073d6c56f2470c3df8671affe2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] 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).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (1/16) (053f5f073d6c56f2470c3df8671affe2) 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.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (ac6ab325c508f337e751a05990c12975) 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) (ac6ab325c508f337e751a05990c12975) [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) (ac6ab325c508f337e751a05990c12975) [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) (ac6ab325c508f337e751a05990c12975) [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)] 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) (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) (ac6ab325c508f337e751a05990c12975) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] 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) (ac6ab325c508f337e751a05990c12975) 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.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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 [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16) (a8581c0c44ae0f134268369cc4200cbc) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) a8581c0c44ae0f134268369cc4200cbc.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16) (a8581c0c44ae0f134268369cc4200cbc) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (4f42c10bff6dca7d3dba70eb8b13afab) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (4f42c10bff6dca7d3dba70eb8b13afab).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (6/16) (277bb21ec799dc4b41cd9e6e8058ec68) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (6/16) (277bb21ec799dc4b41cd9e6e8058ec68) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-3] 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) (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) (277bb21ec799dc4b41cd9e6e8058ec68) 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) (277bb21ec799dc4b41cd9e6e8058ec68) [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) (277bb21ec799dc4b41cd9e6e8058ec68) [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) (277bb21ec799dc4b41cd9e6e8058ec68) [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) (277bb21ec799dc4b41cd9e6e8058ec68) 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) (6/16) (277bb21ec799dc4b41cd9e6e8058ec68) 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) (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.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16) (d7216eb486c2ce2d6bc685a245a201cf) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16) (d7216eb486c2ce2d6bc685a245a201cf).
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16) (46820dbc6a0293e2efbc60799231ee04) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16) (46820dbc6a0293e2efbc60799231ee04).
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (51dee14849f67dd2ec171545d117539c) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (51dee14849f67dd2ec171545d117539c).
[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) (5845dd8250c4e38f9fdfbb35b7aea6a8) switched from CREATED to SCHEDULED.
[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) (5845dd8250c4e38f9fdfbb35b7aea6a8) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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) (14/16) (attempt #0) to 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[flink-akka.actor.default-dispatcher-3] 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) (5845dd8250c4e38f9fdfbb35b7aea6a8) 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) (5845dd8250c4e38f9fdfbb35b7aea6a8) [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) (5845dd8250c4e38f9fdfbb35b7aea6a8) [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) (5845dd8250c4e38f9fdfbb35b7aea6a8) [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) (5845dd8250c4e38f9fdfbb35b7aea6a8) 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) (12/16) (8598a84b22dfbbe8361661b06426d285) switched from CREATED to SCHEDULED.
[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) (12/16) (8598a84b22dfbbe8361661b06426d285) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (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.
[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) (7/16) (7f51c4b67985ac58b5e49f9cbd64d2c6) switched from CREATED to SCHEDULED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (03eea8666a95d812d211f9cb8532d533) [FINISHED]
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (14/16)] 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-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) (7/16) (7f51c4b67985ac58b5e49f9cbd64d2c6) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[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) (5845dd8250c4e38f9fdfbb35b7aea6a8) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16) (4b71772b0caad91bf36e723318879ffc) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16) (4b71772b0caad91bf36e723318879ffc).
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (8d23a28ce6e7f958ab93722f5a5189ec) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (8d23a28ce6e7f958ab93722f5a5189ec).
[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) (13/16) (d1f3573894e7bed4841634d490109274) switched from CREATED to SCHEDULED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (edae10822ac5b04b3e5b5e9aa7f9c24f) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:398>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (edae10822ac5b04b3e5b5e9aa7f9c24f).
[flink-akka.actor.default-dispatcher-7] 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).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) 03eea8666a95d812d211f9cb8532d533.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (8598a84b22dfbbe8361661b06426d285) switched from CREATED to DEPLOYING.
[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) (13/16) (d1f3573894e7bed4841634d490109274) switched from SCHEDULED 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) (8598a84b22dfbbe8361661b06426d285) [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) (8598a84b22dfbbe8361661b06426d285) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] 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 47ae4219-589a-4e6d-ae7c-07f90c30574a @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - 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) (8598a84b22dfbbe8361661b06426d285) [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) (8598a84b22dfbbe8361661b06426d285) 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-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (03eea8666a95d812d211f9cb8532d533) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (12/16)] 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-7] 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).
[flink-akka.actor.default-dispatcher-8] 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) (8598a84b22dfbbe8361661b06426d285) 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)] 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) (7f51c4b67985ac58b5e49f9cbd64d2c6) 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) (7f51c4b67985ac58b5e49f9cbd64d2c6) [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) (7f51c4b67985ac58b5e49f9cbd64d2c6) [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) (7f51c4b67985ac58b5e49f9cbd64d2c6) [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 - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (7f51c4b67985ac58b5e49f9cbd64d2c6) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] 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).
[flink-akka.actor.default-dispatcher-8] 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) (7f51c4b67985ac58b5e49f9cbd64d2c6) 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) (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) (d1f3573894e7bed4841634d490109274) 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) (d1f3573894e7bed4841634d490109274) [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) (d1f3573894e7bed4841634d490109274) [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) (d1f3573894e7bed4841634d490109274) [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) (d1f3573894e7bed4841634d490109274) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (13/16) (d1f3573894e7bed4841634d490109274) 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.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (6fcf30241c6c18f403cf80f6fe171521) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) 6fcf30241c6c18f403cf80f6fe171521.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (6fcf30241c6c18f403cf80f6fe171521) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (a475223eb3ece2f9b56d531d1609393d) [FINISHED]
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (8dc983a8ac9d318ffdd8a4337ad9df5e) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) a475223eb3ece2f9b56d531d1609393d.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) 8dc983a8ac9d318ffdd8a4337ad9df5e.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (a475223eb3ece2f9b56d531d1609393d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (8dc983a8ac9d318ffdd8a4337ad9df5e) switched from RUNNING to FINISHED.
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:43312 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.$Proxy127.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-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org

Jenkins build is back to normal : beam_PostCommit_XVR_Flink #1436

[Apache Jenkins Server <je...@builds.apache.org>]

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


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