You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/10/17 21:45:26 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #23
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
Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink
#24
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/24/display/redirect?page=changes>