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-unsubscr...@beam.apache.org For additional commands, e-mail: builds-h...@beam.apache.org