Build failed in Jenkins: beam_PostCommit_XVR_Flink #1541

[Apache Jenkins Server]

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

Changes:

[ehudm] Update beam website for 2.18.0


------------------------------------------
[...truncated 2.08 MB...]
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16) (6209d98abd89bfed15ae49eb8a7edf7b) switched from SCHEDULED to 
DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16) (attempt #0) to 605a9050-20f7-43e4-84e2-efc8d856dfff @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (c216ba7b22a94c7499d90500e8122af5) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (c216ba7b22a94c7499d90500e8122af5) switched from SCHEDULED to 
DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (attempt #0) to 605a9050-20f7-43e4-84e2-efc8d856dfff @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (44d37b9e591d005bb55b8343f6dcbf21) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (44d37b9e591d005bb55b8343f6dcbf21) switched from SCHEDULED to 
DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (attempt #0) to 605a9050-20f7-43e4-84e2-efc8d856dfff @ localhost 
(dataPort=-1)
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (c844f0c44c2dc8102ff2e05928cfe269) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (c844f0c44c2dc8102ff2e05928cfe269) switched from SCHEDULED to 
DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (attempt #0) to 605a9050-20f7-43e4-84e2-efc8d856dfff @ localhost 
(dataPort=-1)
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (2/16) (94a663804ff765be77d8a4d270d05867) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (2/16) (94a663804ff765be77d8a4d270d05867).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16) (e9ce8c9bd8122dca475df6c7d9092c0d) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16) (e9ce8c9bd8122dca475df6c7d9092c0d) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16) (e9ce8c9bd8122dca475df6c7d9092c0d) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16) (e9ce8c9bd8122dca475df6c7d9092c0d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16) (e9ce8c9bd8122dca475df6c7d9092c0d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16) (e9ce8c9bd8122dca475df6c7d9092c0d) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16) (91cbe5f8130738ac8243c29c2e5459ab) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16) (91cbe5f8130738ac8243c29c2e5459ab) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16) (91cbe5f8130738ac8243c29c2e5459ab) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (1/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16) (91cbe5f8130738ac8243c29c2e5459ab) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16) (91cbe5f8130738ac8243c29c2e5459ab) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (2/16) (91cbe5f8130738ac8243c29c2e5459ab) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16) (a061847de810abbcd9f4708a8da975ac) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16) (a061847de810abbcd9f4708a8da975ac) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16) (a061847de810abbcd9f4708a8da975ac) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16) (a061847de810abbcd9f4708a8da975ac) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16) (a061847de810abbcd9f4708a8da975ac) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16) (a061847de810abbcd9f4708a8da975ac) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (3/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16) (b6c1b29062184ebaa0745d492884da4c) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16) (b6c1b29062184ebaa0745d492884da4c) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16) (b6c1b29062184ebaa0745d492884da4c) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16) (b6c1b29062184ebaa0745d492884da4c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16) (b6c1b29062184ebaa0745d492884da4c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16) (b6c1b29062184ebaa0745d492884da4c) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (3/16) (ae294980a3713562fb98742871e32f41) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (3/16) (ae294980a3713562fb98742871e32f41).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16) (da3c684610aa9707143d2c5c5f64820b) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16) (da3c684610aa9707143d2c5c5f64820b) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16) (da3c684610aa9707143d2c5c5f64820b) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16) (4ddbcde89ad93828ae884ea20a5a4c2b) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16) (da3c684610aa9707143d2c5c5f64820b) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16) (4ddbcde89ad93828ae884ea20a5a4c2b) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16) (4ddbcde89ad93828ae884ea20a5a4c2b) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16) (da3c684610aa9707143d2c5c5f64820b) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16) (4ddbcde89ad93828ae884ea20a5a4c2b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16) (da3c684610aa9707143d2c5c5f64820b) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16) (4ddbcde89ad93828ae884ea20a5a4c2b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16) (4ddbcde89ad93828ae884ea20a5a4c2b) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (6/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16) (311e8e78c8af444974f3d8c812f25133) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16) (311e8e78c8af444974f3d8c812f25133) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16) (311e8e78c8af444974f3d8c812f25133) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16) (311e8e78c8af444974f3d8c812f25133) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16) (311e8e78c8af444974f3d8c812f25133) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (7/16) (311e8e78c8af444974f3d8c812f25133) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16) (1bb9fa280dd8dcb7617ba9d30fdf476f) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16) (1bb9fa280dd8dcb7617ba9d30fdf476f) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16) (1bb9fa280dd8dcb7617ba9d30fdf476f) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16) (1bb9fa280dd8dcb7617ba9d30fdf476f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16) (1bb9fa280dd8dcb7617ba9d30fdf476f) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16) (418df8dc926072659900e19b6f1ef76d) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16) (418df8dc926072659900e19b6f1ef76d) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (8/16) (1bb9fa280dd8dcb7617ba9d30fdf476f) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16) (418df8dc926072659900e19b6f1ef76d) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16) (418df8dc926072659900e19b6f1ef76d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16) (418df8dc926072659900e19b6f1ef76d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16) (418df8dc926072659900e19b6f1ef76d) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16) (2534ccb1b0a3966835d9a74adf88c081) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16) (2534ccb1b0a3966835d9a74adf88c081) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files 
for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16) (2534ccb1b0a3966835d9a74adf88c081) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16) (2534ccb1b0a3966835d9a74adf88c081) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16) (2534ccb1b0a3966835d9a74adf88c081) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16) (2534ccb1b0a3966835d9a74adf88c081) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (10/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16) (82d8a476e1e15a7be1233fe316f82d42) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16) (82d8a476e1e15a7be1233fe316f82d42) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files 
for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16) (82d8a476e1e15a7be1233fe316f82d42) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16) (82d8a476e1e15a7be1233fe316f82d42) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16) (82d8a476e1e15a7be1233fe316f82d42) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (11/16) (82d8a476e1e15a7be1233fe316f82d42) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16) (e838fe2c1d04417c52d074b5c685980b) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16) (e838fe2c1d04417c52d074b5c685980b) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files 
for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16) (e838fe2c1d04417c52d074b5c685980b) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16) (e838fe2c1d04417c52d074b5c685980b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16) (e838fe2c1d04417c52d074b5c685980b) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (12/16) (e838fe2c1d04417c52d074b5c685980b) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16) (6209d98abd89bfed15ae49eb8a7edf7b) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16) (6209d98abd89bfed15ae49eb8a7edf7b) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files 
for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16) (6209d98abd89bfed15ae49eb8a7edf7b) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16) (6209d98abd89bfed15ae49eb8a7edf7b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16) (6209d98abd89bfed15ae49eb8a7edf7b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16) (6209d98abd89bfed15ae49eb8a7edf7b) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (13/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (11/16) (a88443ebcd29df746e544b0ca6793f17) switched 
from RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (11/16) (a88443ebcd29df746e544b0ca6793f17).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (c216ba7b22a94c7499d90500e8122af5) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (c216ba7b22a94c7499d90500e8122af5) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files 
for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (c216ba7b22a94c7499d90500e8122af5) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (c216ba7b22a94c7499d90500e8122af5) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (c216ba7b22a94c7499d90500e8122af5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (14/16) (c216ba7b22a94c7499d90500e8122af5) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (44d37b9e591d005bb55b8343f6dcbf21) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (44d37b9e591d005bb55b8343f6dcbf21) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files 
for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (44d37b9e591d005bb55b8343f6dcbf21) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16).
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (44d37b9e591d005bb55b8343f6dcbf21) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (44d37b9e591d005bb55b8343f6dcbf21) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (15/16) (44d37b9e591d005bb55b8343f6dcbf21) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (c844f0c44c2dc8102ff2e05928cfe269) switched from CREATED to DEPLOYING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (c844f0c44c2dc8102ff2e05928cfe269) [DEPLOYING]
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files 
for task GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (c844f0c44c2dc8102ff2e05928cfe269) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (c844f0c44c2dc8102ff2e05928cfe269) [DEPLOYING].
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (c844f0c44c2dc8102ff2e05928cfe269) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupReduce 
(GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16) (c844f0c44c2dc8102ff2e05928cfe269) switched from DEPLOYING to RUNNING.
[GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
GroupReduce (GroupReduce at 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 exceeded the 80 characters length limit and was truncated.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (6/16) (017e51a18df4d47c8fada255aaa77e5f) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (6/16) (017e51a18df4d47c8fada255aaa77e5f).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (9/16) (2e4f0b723520e5950cd960fe054ae51e) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (9/16) (2e4f0b723520e5950cd960fe054ae51e).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (5/16) (9e3db3a26df53a8db75cbdf7a379a19c) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (5/16) (9e3db3a26df53a8db75cbdf7a379a19c).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (10/16) (40bffdfc35b225dea97dd2ddc1a2fd0d) switched 
from RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (10/16) (40bffdfc35b225dea97dd2ddc1a2fd0d).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (12/16) (bf8d9402d3d13ef61220599d2f5b2556) switched 
from RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (12/16) (bf8d9402d3d13ef61220599d2f5b2556).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (8/16) (52085cbe7cc4db2017f801ab11cd84f3) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (8/16) (52085cbe7cc4db2017f801ab11cd84f3).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (13/16) (8a087eb84687daa79dc9e175a727e62b) switched 
from RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (13/16) (8a087eb84687daa79dc9e175a727e62b).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (14/16) (cdf270b665e1c2ebe4fd1ed3480a38b9) switched 
from RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (14/16) (cdf270b665e1c2ebe4fd1ed3480a38b9).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (15/16) (257d855c47c722cde754fdc562362965) switched 
from RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (15/16) (257d855c47c722cde754fdc562362965).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (16/16) (4a2c293c7437707ca309c0af77dcfe5c) switched 
from RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (16/16) (4a2c293c7437707ca309c0af77dcfe5c).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (16/16) (4a2c293c7437707ca309c0af77dcfe5c) [FINISHED]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (14/16) (cdf270b665e1c2ebe4fd1ed3480a38b9) [FINISHED]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (1/16) (6d3cac1f5afd6986d62214fd0b46d85f) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Freeing task resources for CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map 
(Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (1/16) (6d3cac1f5afd6986d62214fd0b46d85f).
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (15/16) (257d855c47c722cde754fdc562362965) [FINISHED]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (12/16) (bf8d9402d3d13ef61220599d2f5b2556) [FINISHED]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (10/16) (40bffdfc35b225dea97dd2ddc1a2fd0d) [FINISHED]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (5/16) (9e3db3a26df53a8db75cbdf7a379a19c) [FINISHED]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (8/16) (52085cbe7cc4db2017f801ab11cd84f3) [FINISHED]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (13/16) (8a087eb84687daa79dc9e175a727e62b) [FINISHED]
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (9/16) (2e4f0b723520e5950cd960fe054ae51e) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) cdf270b665e1c2ebe4fd1ed3480a38b9.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (1/16) (6d3cac1f5afd6986d62214fd0b46d85f) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 257d855c47c722cde754fdc562362965.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (14/16) (cdf270b665e1c2ebe4fd1ed3480a38b9) switched 
from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) bf8d9402d3d13ef61220599d2f5b2556.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 40bffdfc35b225dea97dd2ddc1a2fd0d.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (15/16) (257d855c47c722cde754fdc562362965) switched 
from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 9e3db3a26df53a8db75cbdf7a379a19c.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (12/16) (bf8d9402d3d13ef61220599d2f5b2556) switched 
from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 52085cbe7cc4db2017f801ab11cd84f3.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (10/16) (40bffdfc35b225dea97dd2ddc1a2fd0d) switched 
from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 8a087eb84687daa79dc9e175a727e62b.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (5/16) (9e3db3a26df53a8db75cbdf7a379a19c) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 4a2c293c7437707ca309c0af77dcfe5c.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 2e4f0b723520e5950cd960fe054ae51e.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (8/16) (52085cbe7cc4db2017f801ab11cd84f3) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 6d3cac1f5afd6986d62214fd0b46d85f.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (13/16) (8a087eb84687daa79dc9e175a727e62b) switched 
from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (16/16) (4a2c293c7437707ca309c0af77dcfe5c) switched 
from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (9/16) (2e4f0b723520e5950cd960fe054ae51e) switched from 
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (1/16) (6d3cac1f5afd6986d62214fd0b46d85f) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (6/16) (017e51a18df4d47c8fada255aaa77e5f) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) 017e51a18df4d47c8fada255aaa77e5f.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (6/16) (017e51a18df4d47c8fada255aaa77e5f) switched from 
RUNNING to FINISHED.
[CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> 
GroupCombine (GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Ensuring all FileSystem streams are closed for task CHAIN FlatMap (FlatMap at 
ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (11/16) (a88443ebcd29df746e544b0ca6793f17) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task CHAIN FlatMap 
(FlatMap at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine 
(GroupCombine at GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) a88443ebcd29df746e544b0ca6793f17.
[flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN FlatMap (FlatMap 
at ExtractOutput[1]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at 
GroupCombine: 
ExternalTransform(beam:transforms:xlang:parquet_write)/FileIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten)
 -> Map (Key Extractor) (11/16) (a88443ebcd29df746e544b0ca6793f17) switched 
from RUNNING to FINISHED.
FATAL: command execution failed
hudson.remoting.ChannelClosedException: Channel "unknown": Remote call on 
JNLP4-connect connection from 
165.171.154.104.bc.googleusercontent.com/104.154.171.165:57990 failed. The 
channel is closing down or has closed down
        at hudson.remoting.Channel.call(Channel.java:950)
        at 
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:283)
        at com.sun.proxy.$Proxy145.isAlive(Unknown Source)
        at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1150)
        at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1142)
        at hudson.Launcher$ProcStarter.join(Launcher.java:470)
        at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
        at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:741)
        at hudson.model.Build$BuildExecution.build(Build.java:206)
        at hudson.model.Build$BuildExecution.doRun(Build.java:163)
        at 
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:504)
        at hudson.model.Run.execute(Run.java:1815)
        at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
        at hudson.model.ResourceController.execute(ResourceController.java:97)
        at hudson.model.Executor.run(Executor.java:429)
Caused by: java.nio.channels.ClosedChannelException
        at 
org.jenkinsci.remoting.protocol.impl.ChannelApplicationLayer.onReadClosed(ChannelApplicationLayer.java:209)
        at 
org.jenkinsci.remoting.protocol.ApplicationLayer.onRecvClosed(ApplicationLayer.java:222)
        at 
org.jenkinsci.remoting.protocol.ProtocolStack$Ptr.onRecvClosed(ProtocolStack.java:816)
        at 
org.jenkinsci.remoting.protocol.FilterLayer.onRecvClosed(FilterLayer.java:287)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.onRecvClosed(SSLEngineFilterLayer.java:181)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.switchToNoSecure(SSLEngineFilterLayer.java:283)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.processWrite(SSLEngineFilterLayer.java:503)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.processQueuedWrites(SSLEngineFilterLayer.java:248)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.doSend(SSLEngineFilterLayer.java:200)
        at 
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.doCloseSend(SSLEngineFilterLayer.java:213)
        at 
org.jenkinsci.remoting.protocol.ProtocolStack$Ptr.doCloseSend(ProtocolStack.java:784)
        at 
org.jenkinsci.remoting.protocol.ApplicationLayer.doCloseWrite(ApplicationLayer.java:173)
        at 
org.jenkinsci.remoting.protocol.impl.ChannelApplicationLayer$ByteBufferCommandTransport.closeWrite(ChannelApplicationLayer.java:314)
        at hudson.remoting.Channel.close(Channel.java:1452)
        at hudson.remoting.Channel.close(Channel.java:1405)
        at hudson.slaves.SlaveComputer.closeChannel(SlaveComputer.java:847)
        at hudson.slaves.SlaveComputer.access$800(SlaveComputer.java:108)
        at hudson.slaves.SlaveComputer$3.run(SlaveComputer.java:756)
        at 
jenkins.util.ContextResettingExecutorService$1.run(ContextResettingExecutorService.java:28)
        at 
jenkins.security.ImpersonatingExecutorService$1.run(ImpersonatingExecutorService.java:59)
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-12 is offline; cannot locate JDK 1.8 (latest)

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