Build failed in Jenkins: beam_PostCommit_XVR_Flink #1101

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

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

Changes:


------------------------------------------
[...truncated 3.22 MB...]
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (8/16) (e961b78aafc796a16eea9fca8b7501eb) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (8/16) (e961b78aafc796a16eea9fca8b7501eb) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (8/16) (e961b78aafc796a16eea9fca8b7501eb) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 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:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (4b8a79353b4d2ddba1f4824a6f41275d) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (4b8a79353b4d2ddba1f4824a6f41275d).
[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) (6f3a1c20ef62d201a721ee4b74c1f3bb) [FINISHED]
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/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]) (5/16) (443c854491ae1855b9e6c9429b1eff0b) [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) (704b9f1f89b1327b354e0407c16ebc90) [FINISHED]
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/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]) (9/16) (41e382ab3369bb37cee36d85b061b5b7) [FINISHED]
[CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> 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 [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (035806fab3bd1160aa68f4f5ac71d52d) [FINISHED]
[flink-akka.actor.default-dispatcher-5] 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]) 6f3a1c20ef62d201a721ee4b74c1f3bb.
[flink-akka.actor.default-dispatcher-5] 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]) 443c854491ae1855b9e6c9429b1eff0b.
[flink-akka.actor.default-dispatcher-5] 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]) 41e382ab3369bb37cee36d85b061b5b7.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (6f3a1c20ef62d201a721ee4b74c1f3bb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] 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]) 035806fab3bd1160aa68f4f5ac71d52d.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (443c854491ae1855b9e6c9429b1eff0b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] 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]) 704b9f1f89b1327b354e0407c16ebc90.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16) (41e382ab3369bb37cee36d85b061b5b7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (035806fab3bd1160aa68f4f5ac71d52d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (704b9f1f89b1327b354e0407c16ebc90) switched from RUNNING to FINISHED.
[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) (187d9f43e218be3e7613ad7a785e21e7) [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]) 187d9f43e218be3e7613ad7a785e21e7.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16) (fb68b36b57355bb3d8e1354190fe6beb) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16) (4cd59b3cc8bed653b032a5222564e26c) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16) (4cd59b3cc8bed653b032a5222564e26c).
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16) (fb68b36b57355bb3d8e1354190fe6beb).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16) (187d9f43e218be3e7613ad7a785e21e7) switched from RUNNING to FINISHED.
[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) (24e144116913036f6f89f6befbf1bccb) switched from CREATED to SCHEDULED.
[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) (24e144116913036f6f89f6befbf1bccb) switched from SCHEDULED to DEPLOYING.
[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) (9/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (f0414e25da5b92cb43b85c3bde386aac) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (f0414e25da5b92cb43b85c3bde386aac).
[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) (6/16) (6d2c67c99a79e49aca0ef9d050a6b390) switched from CREATED to SCHEDULED.
[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) (6/16) (6d2c67c99a79e49aca0ef9d050a6b390) switched from SCHEDULED to DEPLOYING.
[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) (6/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (66698696c588c3f1402bb0d5a11ec6b0) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (66698696c588c3f1402bb0d5a11ec6b0).
[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) (76139f7dc7dbc71c85a618c799ab3c84) switched from CREATED to SCHEDULED.
[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) (76139f7dc7dbc71c85a618c799ab3c84) switched from SCHEDULED to DEPLOYING.
[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) (10/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (0391f69718877a98adde73883fb20e43) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (0391f69718877a98adde73883fb20e43).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16) (3182e3c47af067f51ef19cff2f41679a) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16) (3182e3c47af067f51ef19cff2f41679a) switched from SCHEDULED to DEPLOYING.
[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) (3/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ 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) (16/16) (5f5fec8b62f036f490c4d52b2f991e86) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (16/16) (5f5fec8b62f036f490c4d52b2f991e86) switched from SCHEDULED to DEPLOYING.
[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) (16/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ 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) (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) (4/16) (d37bf1e4341a48d7eb26c3f98b0bab5c) switched from CREATED to SCHEDULED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (1c7fb63fec4053c92d34ff5e58056de6) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (1c7fb63fec4053c92d34ff5e58056de6).
[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) (4/16) (d37bf1e4341a48d7eb26c3f98b0bab5c) 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) (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) (24e144116913036f6f89f6befbf1bccb) switched from CREATED to DEPLOYING.
[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) (4/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ 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) (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) (24e144116913036f6f89f6befbf1bccb) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (9/16) (24e144116913036f6f89f6befbf1bccb) [DEPLOYING].
[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) (29a8401eb883980b3d11899424610fc2) switched from CREATED to SCHEDULED.
[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) (29a8401eb883980b3d11899424610fc2) 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) (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) (24e144116913036f6f89f6befbf1bccb) [DEPLOYING].
[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) (11/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ 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) (14/16) (ba0bbd88fac97b758ef9157b2cf13819) 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) (24e144116913036f6f89f6befbf1bccb) 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) (14/16) (ba0bbd88fac97b758ef9157b2cf13819) 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) (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.
[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) (14/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (99f160c5d9fb0efa83d47971935fb66c) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (99f160c5d9fb0efa83d47971935fb66c).
[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) (2/16) (7fee86c3e99ab967701d3cac2f1e6b76) switched from CREATED to SCHEDULED.
[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).
[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) (2/16) (7fee86c3e99ab967701d3cac2f1e6b76) switched from SCHEDULED to DEPLOYING.
[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) (2/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ localhost (dataPort=-1)
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (33b297abcfb09002628ffc7fa19a3bff) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (33b297abcfb09002628ffc7fa19a3bff).
[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) (24e144116913036f6f89f6befbf1bccb) 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.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (cdb68a8d7a4fdd3fe6c4857af69b1328) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (cdb68a8d7a4fdd3fe6c4857af69b1328).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (6d2c67c99a79e49aca0ef9d050a6b390) 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) (6d2c67c99a79e49aca0ef9d050a6b390) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (e706886320a74f0aeff9283a96fdfbe6) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16) (2134c943da917230c17d35aaf52a74b5) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16) (2134c943da917230c17d35aaf52a74b5).
[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) (13/16) (cecb5975b123731da929710c87926695) 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) (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) (6d2c67c99a79e49aca0ef9d050a6b390) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (e706886320a74f0aeff9283a96fdfbe6).
[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) (13/16) (cecb5975b123731da929710c87926695) switched from SCHEDULED to DEPLOYING.
[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) (13/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ 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) (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) (6d2c67c99a79e49aca0ef9d050a6b390) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (1/16) (b5e185438419f80889cd3ddde22ff1dd) 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) (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) (6d2c67c99a79e49aca0ef9d050a6b390) 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.
[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) (10/16).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (10/16) (76139f7dc7dbc71c85a618c799ab3c84) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (1/16) (b5e185438419f80889cd3ddde22ff1dd) 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) (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) (76139f7dc7dbc71c85a618c799ab3c84) [DEPLOYING]
[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) (1/16) (attempt #0) to 2921884d-5b20-43ee-ab74-6c043fb89a78 @ 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 - 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) (76139f7dc7dbc71c85a618c799ab3c84) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (6/16) (6d2c67c99a79e49aca0ef9d050a6b390) 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 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) (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) (76139f7dc7dbc71c85a618c799ab3c84) [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) (76139f7dc7dbc71c85a618c799ab3c84) 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) (10/16) (76139f7dc7dbc71c85a618c799ab3c84) switched from DEPLOYING to RUNNING.
[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) (3/16).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (10/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16) (3182e3c47af067f51ef19cff2f41679a) 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) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16) (3182e3c47af067f51ef19cff2f41679a) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16) (3182e3c47af067f51ef19cff2f41679a) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16) (3182e3c47af067f51ef19cff2f41679a) [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)] 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) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16) (3182e3c47af067f51ef19cff2f41679a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16) (3182e3c47af067f51ef19cff2f41679a) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters length limit and was truncated.
[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) (16/16).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (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) (5f5fec8b62f036f490c4d52b2f991e86) 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) (5f5fec8b62f036f490c4d52b2f991e86) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (3/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) exceeded the 80 characters length limit and was truncated.
[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) (4/16).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16) (d37bf1e4341a48d7eb26c3f98b0bab5c) switched from CREATED to DEPLOYING.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16) (d37bf1e4341a48d7eb26c3f98b0bab5c) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16) (d37bf1e4341a48d7eb26c3f98b0bab5c) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16) (d37bf1e4341a48d7eb26c3f98b0bab5c) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16) (d37bf1e4341a48d7eb26c3f98b0bab5c) switched from DEPLOYING to RUNNING.
[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) (11/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) (4/16) (d37bf1e4341a48d7eb26c3f98b0bab5c) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (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) (29a8401eb883980b3d11899424610fc2) 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) (29a8401eb883980b3d11899424610fc2) [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) (29a8401eb883980b3d11899424610fc2) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - 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) (29a8401eb883980b3d11899424610fc2) [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) (5f5fec8b62f036f490c4d52b2f991e86) [DEPLOYING].
[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) (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) (29a8401eb883980b3d11899424610fc2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (11/16) (29a8401eb883980b3d11899424610fc2) switched from DEPLOYING to RUNNING.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (5f5fec8b62f036f490c4d52b2f991e86) [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) (ba0bbd88fac97b758ef9157b2cf13819) 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 - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (5f5fec8b62f036f490c4d52b2f991e86) 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) (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) (ba0bbd88fac97b758ef9157b2cf13819) [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) (ba0bbd88fac97b758ef9157b2cf13819) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (16/16) (5f5fec8b62f036f490c4d52b2f991e86) 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) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-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) (2/16).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (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) (ba0bbd88fac97b758ef9157b2cf13819) [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) (ba0bbd88fac97b758ef9157b2cf13819) 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)] 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) (7fee86c3e99ab967701d3cac2f1e6b76) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (14/16) (ba0bbd88fac97b758ef9157b2cf13819) 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)] 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) (7fee86c3e99ab967701d3cac2f1e6b76) [DEPLOYING]
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 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) (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) (7fee86c3e99ab967701d3cac2f1e6b76) [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)] 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 - 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) (7fee86c3e99ab967701d3cac2f1e6b76) [DEPLOYING].
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) exceeded the 80 characters length limit and was truncated.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (7fee86c3e99ab967701d3cac2f1e6b76) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] 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) (7fee86c3e99ab967701d3cac2f1e6b76) 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.
[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) (13/16).
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (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.
[CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (cecb5975b123731da929710c87926695) 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) (cecb5975b123731da929710c87926695) [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) (cecb5975b123731da929710c87926695) [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) (cecb5975b123731da929710c87926695) [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) (cecb5975b123731da929710c87926695) switched from DEPLOYING to RUNNING.
[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) (1/16).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: ExternalTransform(beam:transforms:xlang:count)/Combine.perKey(Count)/Group) -> Map (Key Extractor) (13/16) (cecb5975b123731da929710c87926695) 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 [3]{ExternalTransform(beam:transforms:xlang:filter_less_than_eq), ExternalTransform(beam:transforms:xlang:count)}) -> 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) (b5e185438419f80889cd3ddde22ff1dd) 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) (b5e185438419f80889cd3ddde22ff1dd) [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) (b5e185438419f80889cd3ddde22ff1dd) [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 - 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) (b5e185438419f80889cd3ddde22ff1dd) [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) (b5e185438419f80889cd3ddde22ff1dd) 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) (1/16) (b5e185438419f80889cd3ddde22ff1dd) 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) (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]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (4b8a79353b4d2ddba1f4824a6f41275d) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) 4b8a79353b4d2ddba1f4824a6f41275d.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (4b8a79353b4d2ddba1f4824a6f41275d) switched from RUNNING to FINISHED.
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (c82d048309b3ab3b83bcca30fa39b01f) [FINISHED]
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (1256e3fb97b6275b98b8908ceab7fed7) [FINISHED]
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> 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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (ce0dcc6cffd02e99a4ef11226b04d550) [FINISHED]
[CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/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:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16) (c6171c9491ed5ec122d3df03c0cb7472) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) c82d048309b3ab3b83bcca30fa39b01f.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) 1256e3fb97b6275b98b8908ceab7fed7.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) ce0dcc6cffd02e99a4ef11226b04d550.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) c6171c9491ed5ec122d3df03c0cb7472.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (c82d048309b3ab3b83bcca30fa39b01f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (1256e3fb97b6275b98b8908ceab7fed7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (ce0dcc6cffd02e99a4ef11226b04d550) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [3]{Create, Map(unicode), Map(<lambda at external_test.py:385>)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16) (c6171c9491ed5ec122d3df03c0cb7472) switched from RUNNING to FINISHED.
#
# There is insufficient memory for the Java Runtime Environment to continue.
OpenJDK 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000710080000, 272629760, 0) failed; error='Cannot allocate memory' (errno=12)
# Native memory allocation (mmap) failed to map 272629760 bytes for committing reserved memory.
# An error report file with more information is saved as:
# /opt/apache/beam/hs_err_pid6.log
# [ timer expired, abort... ]
FATAL: command execution failed
java.io.IOException: Backing channel 'JNLP4-connect connection from 88.61.224.35.bc.googleusercontent.com/35.224.61.88:54838' is disconnected.
	at hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:214)
	at hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:283)
	at com.sun.proxy.$Proxy146.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-10 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 #1102

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

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


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