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/08 22:08:28 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #261
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/261/display/redirect?page=changes>
Changes:
[github] [BEAM-6013] Reduce logging within SerializableCoder. (#6982)
------------------------------------------
[...truncated 344.06 MB...]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (attempt #0) to localhost
[MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.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 PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (12/16) (7c8197b030ee3f45eaa3ccd74d46414b) [FINISHED]
[MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (50a408cb915a3ae32c5149c2cd91ec05) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (9/16) (a65fb8765d1935d62f41231469c6ddf1) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (9/16) (a65fb8765d1935d62f41231469c6ddf1) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16).
[MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16) (0ca742da73188f1a6d073b6fb169bbea) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16) (0ca742da73188f1a6d073b6fb169bbea).
[jobmanager-future-thread-1] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.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 PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16) (0ca742da73188f1a6d073b6fb169bbea) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (9/16) (a65fb8765d1935d62f41231469c6ddf1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (9/16) (a65fb8765d1935d62f41231469c6ddf1).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (9/16) (a65fb8765d1935d62f41231469c6ddf1) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 3d8f07f56dc9074f73a42bf12a68f5e8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) [FINISHED]
[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) (15/16) (3d8f07f56dc9074f73a42bf12a68f5e8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 602162283e7800b7437cf694cfdf739e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (602162283e7800b7437cf694cfdf739e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 4c762e487a322fc54c00d109c5e66391.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) [FINISHED]
[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) (3/16) (4c762e487a322fc54c00d109c5e66391) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 9ce30515fcf25fda0d6e1afb7c366b83.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) f0acd48fe2c7376c6e16d66ccce29ac5.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) d1cec71a681560ae23a6ef65e9f1831b.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 06f3e50e079bf8a0978a6ece78bfaac8.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (2/16) (9ce30515fcf25fda0d6e1afb7c366b83) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) switched from DEPLOYING to RUNNING.
[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) (13/16) (f0acd48fe2c7376c6e16d66ccce29ac5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16).
[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) (14/16) (d1cec71a681560ae23a6ef65e9f1831b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 7c8197b030ee3f45eaa3ccd74d46414b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 50a408cb915a3ae32c5149c2cd91ec05.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (8/16) (06f3e50e079bf8a0978a6ece78bfaac8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414).
[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) (12/16) (7c8197b030ee3f45eaa3ccd74d46414b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) switched from DEPLOYING to RUNNING.
[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) (1/16) (50a408cb915a3ae32c5149c2cd91ec05) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 0ca742da73188f1a6d073b6fb169bbea.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) a65fb8765d1935d62f41231469c6ddf1.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) [FINISHED]
[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) (16/16) (0ca742da73188f1a6d073b6fb169bbea) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (9/16) (a65fb8765d1935d62f41231469c6ddf1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 8754610e7f86e05dbd2e486c4bc4c692.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 66e1a4c23b16210ca2906af812de82e2.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 3f84c3b146bb8a86a83aa210eddfd836.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (5/16) (8754610e7f86e05dbd2e486c4bc4c692) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 0a19947c5f90fc3cc3a6b061c951dfc9.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 14dadc0ba80fe1e2c80c97dc39d9f939.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) daa6e3441733eaf44e9aac3c0d20a414.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 0f88522a33c642efca5119750da54d3d.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (10/16) (66e1a4c23b16210ca2906af812de82e2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) d57f2cc4b2a4ff3d1f0c54e329e2534d.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 5d254286b1619d64d7381ab3cd7f2ca9.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 8448061ec751426b0c05363552d6ac1d.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (6/16) (3f84c3b146bb8a86a83aa210eddfd836) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 68da017dad188b2b92c6fda9c147b29a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (7/16) (0a19947c5f90fc3cc3a6b061c951dfc9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (4/16) (14dadc0ba80fe1e2c80c97dc39d9f939) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (15/16) (daa6e3441733eaf44e9aac3c0d20a414) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (3/16) (0f88522a33c642efca5119750da54d3d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (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@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (13/16) (d57f2cc4b2a4ff3d1f0c54e329e2534d) switched from RUNNING to 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) 0cc8f636f092f99f80d6a517540f74ee.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (14/16) (5d254286b1619d64d7381ab3cd7f2ca9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (1/16) (8448061ec751426b0c05363552d6ac1d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (12/16) (68da017dad188b2b92c6fda9c147b29a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75414bd6) (16/16) (0cc8f636f092f99f80d6a517540f74ee) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1108214617-477ddf8 (c54b497e4a514f03b6e1b7ab51886788) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job c54b497e4a514f03b6e1b7ab51886788 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-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1108214617-477ddf8(c54b497e4a514f03b6e1b7ab51886788).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatchered3b9205-e8a1-41ff-be44-ff42735f3180.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatchered3b9205-e8a1-41ff-be44-ff42735f3180.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 37b5d84e60cc2fb94d9a1fbb857d744e: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job c54b497e4a514f03b6e1b7ab51886788 with leader id b2239d1783fb96b13ea3651b54a74891 lost leadership.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-dbd8c376-aeb4-465d-b075-f0b7171aca77
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatchered3b9205-e8a1-41ff-be44-ff42735f3180.
[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-6] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:38601
[flink-akka.actor.default-dispatcher-6] 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 11368 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1108214617-477ddf8_10c8a89c-9b3a-43d9-9bdc-a2b3c948b0d4/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-1108214617-477ddf8_10c8a89c-9b3a-43d9-9bdc-a2b3c948b0d4/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:39995
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:46753
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testValueStateDedup SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 59 mins 24.265 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 1h 2m 22s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/26zs4qzqu3y52
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