You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/11/13 12:50:57 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #301
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/301/display/redirect>
------------------------------------------
[...truncated 389.91 MB...]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16) (926d97b77538db933227415223a7a003) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16) (926d97b77538db933227415223a7a003) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16) (9197cb666000b36079d83a5589bf3982) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16) (926d97b77538db933227415223a7a003) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16) (9197cb666000b36079d83a5589bf3982) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16) (9197cb666000b36079d83a5589bf3982) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16) (926d97b77538db933227415223a7a003) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16) (926d97b77538db933227415223a7a003).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16) (9197cb666000b36079d83a5589bf3982) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16) (9197cb666000b36079d83a5589bf3982).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (16/16) (926d97b77538db933227415223a7a003) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16) (9197cb666000b36079d83a5589bf3982) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 547806fbb9830c792bd085eb82d32962.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 04224a156206038d6f3349428e6f831c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (12/16) (547806fbb9830c792bd085eb82d32962) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (13/16) (04224a156206038d6f3349428e6f831c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) f9fc2eef3e5b1201e0ac02b44126e4fb.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16) (f9fc2eef3e5b1201e0ac02b44126e4fb) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) f1d90dbef4ac0f8f1b112c12d46ff6af.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] 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@6192e472) 0974c17ac98cf1ab0808b006ee427437.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (f1d90dbef4ac0f8f1b112c12d46ff6af) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (8/16) (0974c17ac98cf1ab0808b006ee427437) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 2656df07fe0c3249d2a859d566ac412e.
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) c4f878ed261164ca86f3359c375f6ee0.
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) bfebfe8fb2cda0683394b455cf31fba0.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (2656df07fe0c3249d2a859d566ac412e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (c4f878ed261164ca86f3359c375f6ee0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (bfebfe8fb2cda0683394b455cf31fba0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) 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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) beafdd156b0308faf0e60864fbfd489c.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (beafdd156b0308faf0e60864fbfd489c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) [DEPLOYING]
[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@6192e472) 1702d54b0436fd0b88de62196757b32a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (14/16) (1702d54b0436fd0b88de62196757b32a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16).
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) c1e05fb86601a73595bc9a61f35649b0.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) 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@6192e472) 926d97b77538db933227415223a7a003.
[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@6192e472) 9197cb666000b36079d83a5589bf3982.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16) (c1e05fb86601a73595bc9a61f35649b0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) 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@6192e472) 20e67d20ac0b1d9d326c4dc550fcbffa.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) 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@6192e472) 66b431f13c3b20bc6ca756b43d8e1e95.
[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@6192e472) 34ae2780700ff6b3c75cc9a4cfd4c216.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (16/16) (926d97b77538db933227415223a7a003) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) 266acaa63de8125e232a92cde098b3fa.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (10/16) (9197cb666000b36079d83a5589bf3982) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) 305d638b1cfaa0a05fa640b4ec5dd2e9.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) 19a568696cac2829dd2655412ddd761a.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (9/16) (20e67d20ac0b1d9d326c4dc550fcbffa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (15/16) (66b431f13c3b20bc6ca756b43d8e1e95) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb).
[flink-akka.actor.default-dispatcher-7] 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@6192e472) 3e418e083c34a25025412688164306eb.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (1/16) (34ae2780700ff6b3c75cc9a4cfd4c216) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571).
[flink-akka.actor.default-dispatcher-7] 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@6192e472) 759e875cea8e0a76eee903ead083ae3e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (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@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246).
[flink-akka.actor.default-dispatcher-7] 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@6192e472) f52b775db6fc0cc782a674e08582f37d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (12/16) (266acaa63de8125e232a92cde098b3fa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] 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@6192e472) 82d7497088f127fd0be2506dfcf747fb.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (13/16) (305d638b1cfaa0a05fa640b4ec5dd2e9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] 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@6192e472) 710e86a89ef4741a2ba6f12de97e7571.
[flink-akka.actor.default-dispatcher-7] 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@6192e472) bff1dd8466dee030a4bcf9ca8e6d1246.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (11/16) (19a568696cac2829dd2655412ddd761a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (4/16) (3e418e083c34a25025412688164306eb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (5/16) (759e875cea8e0a76eee903ead083ae3e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (7/16) (f52b775db6fc0cc782a674e08582f37d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (3/16) (82d7497088f127fd0be2506dfcf747fb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (6/16) (710e86a89ef4741a2ba6f12de97e7571) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6192e472) (2/16) (bff1dd8466dee030a4bcf9ca8e6d1246) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1113125023-5c180e1b (6d14d2cbad863fd8d53b178f6f24f857) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 6d14d2cbad863fd8d53b178f6f24f857 reached globally terminal state FINISHED.
[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-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher689c7e70-98e8-4d5a-bdc5-24673cc92375.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher689c7e70-98e8-4d5a-bdc5-24673cc92375.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1113125023-5c180e1b(6d14d2cbad863fd8d53b178f6f24f857).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 4fc90eec0fc151c70ad1c93d0e0e3d86: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 6d14d2cbad863fd8d53b178f6f24f857 with leader id 81b49f129e6e87ccfc53e87842384e4b lost leadership.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-90a68fd2-f07b-45b5-808f-29a4c23342ec
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher689c7e70-98e8-4d5a-bdc5-24673cc92375.
[ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:35343
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 12187 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1113125023-5c180e1b_23bb8e28-20a4-4767-b6c4-467b6766f46a/MANIFEST has 185 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1113125023-5c180e1b_23bb8e28-20a4-4767-b6c4-467b6766f46a/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:37235
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:43923
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.transforms.CombineTest$WindowingTests > testCombineGloballyInstanceMethodReference SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 38 mins 46.04 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 41m 31s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/5zbutojbwyyso
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink
#302
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/302/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org