See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/23/display/redirect?page=changes>
Changes: [migryz] Add Jira data to Beam Metrics dashboard. ------------------------------------------ [...truncated 452.00 MB...] [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (9/16) (83f09016946c07e96a0f8242790d2ddb). [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (9/16) (83f09016946c07e96a0f8242790d2ddb) [FINISHED] [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) switched from SCHEDULED to DEPLOYING. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (attempt #0) to localhost [jobmanager-future-thread-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) switched from CREATED to SCHEDULED. [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (5/16) (c813ecad1436aa4394802a8402d08cbf) switched from RUNNING to FINISHED. [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (5/16) (c813ecad1436aa4394802a8402d08cbf). [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (5/16) (c813ecad1436aa4394802a8402d08cbf) [FINISHED] [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (3/16) (158b3d03f373fcc46ebeb59f194d52d1) switched from RUNNING to FINISHED. [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (3/16) (158b3d03f373fcc46ebeb59f194d52d1). [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (3/16) (158b3d03f373fcc46ebeb59f194d52d1) [FINISHED] [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (6/16) (f46f3909ea2b98b1d9c71b38617b82ba) switched from RUNNING to FINISHED. [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (6/16) (f46f3909ea2b98b1d9c71b38617b82ba). [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (6/16) (f46f3909ea2b98b1d9c71b38617b82ba) [FINISHED] [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) switched from SCHEDULED to DEPLOYING. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (attempt #0) to localhost [jobmanager-future-thread-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) switched from CREATED to SCHEDULED. [jobmanager-future-thread-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) switched from CREATED to SCHEDULED. [jobmanager-future-thread-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) switched from CREATED to SCHEDULED. [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (12/16) (5666956fa47bacc9dbcdbd896f0c4d0c) switched from RUNNING to FINISHED. [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (12/16) (5666956fa47bacc9dbcdbd896f0c4d0c). [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (12/16) (5666956fa47bacc9dbcdbd896f0c4d0c) [FINISHED] [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) switched from SCHEDULED to DEPLOYING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (attempt #0) to localhost [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) switched from SCHEDULED to DEPLOYING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (attempt #0) to localhost [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) switched from SCHEDULED to DEPLOYING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (attempt #0) to localhost [jobmanager-future-thread-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) switched from CREATED to SCHEDULED. [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) switched from SCHEDULED to DEPLOYING. [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (attempt #0) to localhost [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16) (93dadcb438d7df953143f3f6b8b3f1bb) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16) (93dadcb438d7df953143f3f6b8b3f1bb) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16) (93dadcb438d7df953143f3f6b8b3f1bb). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16) (93dadcb438d7df953143f3f6b8b3f1bb) [FINISHED] [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16) (93dadcb438d7df953143f3f6b8b3f1bb) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) [DEPLOYING] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) [DEPLOYING]. [jobmanager-future-thread-12] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) switched from CREATED to SCHEDULED. [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) switched from SCHEDULED to DEPLOYING. [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (attempt #0) to localhost [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16) (2fe082a6c5cdfe55ab64804645c44e64) switched from DEPLOYING to RUNNING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16) (2fe082a6c5cdfe55ab64804645c44e64) switched from DEPLOYING to RUNNING. [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (16/16) (bbe26c05e6aa0bc402cb48dcb728489c) switched from RUNNING to FINISHED. [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (16/16) (bbe26c05e6aa0bc402cb48dcb728489c). [MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (16/16) (bbe26c05e6aa0bc402cb48dcb728489c) [FINISHED] [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) switched from DEPLOYING to RUNNING. [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 MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) 4e23995d11803c63388b8e7bded6ccf9. [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (15/16) (4e23995d11803c63388b8e7bded6ccf9) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) [DEPLOYING] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) [FINISHED] [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16). [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16) (2fe082a6c5cdfe55ab64804645c44e64) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16) (2fe082a6c5cdfe55ab64804645c44e64). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16) (2fe082a6c5cdfe55ab64804645c44e64) [FINISHED] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) [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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) fb2ac9ffc924260e717d91c652fbc50b. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (11/16) (fb2ac9ffc924260e717d91c652fbc50b) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 270580291866ea881f353957f63489d9. [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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) ca976eab652295fac38666aefebcf1a1. [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 MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) 1793e51939a8b922f9891a331c8a9e3c. [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 MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) 83f09016946c07e96a0f8242790d2ddb. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16). [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (10/16) (270580291866ea881f353957f63489d9) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (4/16) (ca976eab652295fac38666aefebcf1a1) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (1/16) (1793e51939a8b922f9891a331c8a9e3c) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (9/16) (83f09016946c07e96a0f8242790d2ddb) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) [DEPLOYING] [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 MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) c813ecad1436aa4394802a8402d08cbf. [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 MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) 158b3d03f373fcc46ebeb59f194d52d1. [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 MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) f46f3909ea2b98b1d9c71b38617b82ba. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (5/16) (c813ecad1436aa4394802a8402d08cbf) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (3/16) (158b3d03f373fcc46ebeb59f194d52d1) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (6/16) (f46f3909ea2b98b1d9c71b38617b82ba) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) [DEPLOYING] [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 MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) 5666956fa47bacc9dbcdbd896f0c4d0c. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16). [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (12/16) (5666956fa47bacc9dbcdbd896f0c4d0c) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) [DEPLOYING] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) switched from CREATED to DEPLOYING. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) [DEPLOYING] [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) [DEPLOYING] [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) [DEPLOYING] [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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 93dadcb438d7df953143f3f6b8b3f1bb. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16). [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (13/16) (93dadcb438d7df953143f3f6b8b3f1bb) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) [DEPLOYING] [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 MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) bbe26c05e6aa0bc402cb48dcb728489c. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at GroupByKey.out/beam:env:docker:v1:0) (16/16) (bbe26c05e6aa0bc402cb48dcb728489c) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 34e2e0bbfc9cbea9e70a0ca1e5d56b05. [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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 2fe082a6c5cdfe55ab64804645c44e64. [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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 07ce01d85d7b8db1fcdc9c71cad915e2. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (7/16) (34e2e0bbfc9cbea9e70a0ca1e5d56b05) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (14/16) (2fe082a6c5cdfe55ab64804645c44e64) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (8/16) (07ce01d85d7b8db1fcdc9c71cad915e2) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) switched from CREATED to DEPLOYING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) [DEPLOYING] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) [FINISHED] [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) switched from DEPLOYING to RUNNING. [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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) b74de80b5ea25990bf7c0882edcf0c3b. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (9/16) (b74de80b5ea25990bf7c0882edcf0c3b) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) [FINISHED] [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) switched from DEPLOYING to RUNNING. [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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 666a39775ae1cc0c67723dd4d366d650. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (1/16) (666a39775ae1cc0c67723dd4d366d650) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) [FINISHED] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) [FINISHED] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) [FINISHED] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) [FINISHED] [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) [FINISHED] [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) switched from DEPLOYING to RUNNING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) switched from DEPLOYING to RUNNING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) switched from DEPLOYING to RUNNING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) switched from DEPLOYING to RUNNING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) switched from DEPLOYING to RUNNING. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 9e2d2795b2f0e6c0cac219d8da7a09ba. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 2fdf07d8977140b43559e63cc550788c. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 697704c1e0c30f577e7651feedfbd381. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 1a9f2f7e80016719ccfd69b7c569b77b. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) 01e574456988014c0505d24b64cf9761. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (12/16) (9e2d2795b2f0e6c0cac219d8da7a09ba) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (6/16) (2fdf07d8977140b43559e63cc550788c) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (3/16) (697704c1e0c30f577e7651feedfbd381) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (5/16) (1a9f2f7e80016719ccfd69b7c569b77b) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (15/16) (01e574456988014c0505d24b64cf9761) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) [DEPLOYING]. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) switched from DEPLOYING to RUNNING. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) switched from DEPLOYING to RUNNING. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) switched from RUNNING to FINISHED. [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8). [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) [FINISHED] [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) fc34762dec27343a2aca5cd2c0bef2c8. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6eca1e3f) (16/16) (fc34762dec27343a2aca5cd2c0bef2c8) switched from RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job windowtest0testtimestampcombinerendofwindow-jenkins-1017214451-417ebc36 (dc829759d00d5bf93088a5b91a808b46) switched from state RUNNING to FINISHED. [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job dc829759d00d5bf93088a5b91a808b46 reached globally terminal state FINISHED. [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job windowtest0testtimestampcombinerendofwindow-jenkins-1017214451-417ebc36(dc829759d00d5bf93088a5b91a808b46). [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster [flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job dc829759d00d5bf93088a5b91a808b46. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_196. [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher131e83ab-14c8-47f1-98e0-3b639c3cf4fb. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher131e83ab-14c8-47f1-98e0-3b639c3cf4fb. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 1c73aa618522140806fa0500e7dc4205 from the SlotManager. [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 9741fa3817166f03a33a7247dc463629: JobManager is shutting down.. [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool. # # There is insufficient memory for the Java Runtime Environment to continue. Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f06f95ca000, 12288, 0) failed; error='Cannot allocate memory' (errno=12) Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f070aafa000, 12288, 0) failed; error='Cannot allocate memory' (errno=12) Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f06f98cd000, 12288, 0) failed; error='Cannot allocate memory' (errno=12) Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f06f8dc2000, 12288, 0) failed; error='Cannot allocate memory' (errno=12) # Native memory allocation (mmap) failed to map 12288 bytes for committing reserved memory. [thread 139668221830912 also had an error] [thread 139667934336768 also had an error] [thread 139667922757376 also had an error] # An error report file with more information is saved as: # org.apache.beam.sdk.transforms.windowing.WindowTest > testTimestampCombinerEndOfWindow SKIPPED > Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED :beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 35 mins 13.031 secs. FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunner'. > Process 'Gradle Test Executor 2' finished with non-zero exit value 137 This problem might be caused by incorrect test process configuration. Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution * Try: Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights. * Get more help at https://help.gradle.org Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 38m 12s 75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date Publishing build scan... https://gradle.com/s/gjuaqgcaop3f4 Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure