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/26 16:17:25 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #19
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/19/display/redirect?page=changes>
Changes:
[me] RedisIO: only call .exec on finishBundle if there is somthing to send
------------------------------------------
[...truncated 357.07 MB...]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (attempt #0) to localhost
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (204af9f872a7d130ea77ebcc4277246d) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (204af9f872a7d130ea77ebcc4277246d).
[jobmanager-future-thread-16] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (204af9f872a7d130ea77ebcc4277246d) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) [DEPLOYING]
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (60da9a9293e0b879032beb253411d575) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (60da9a9293e0b879032beb253411d575).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) [DEPLOYING].
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (60da9a9293e0b879032beb253411d575) [FINISHED]
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (b16565869d3afeb1ebd315fd04cf370a) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (b16565869d3afeb1ebd315fd04cf370a).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) ca24808fd30c9b70b6ec86fd3ac3215a.
[MapPartition (MapPartition at PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (b16565869d3afeb1ebd315fd04cf370a) [FINISHED]
[jobmanager-future-thread-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-11] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) 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@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) 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@271e27b9) (1/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16) (ca24808fd30c9b70b6ec86fd3ac3215a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) 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@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] 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@271e27b9) 0c4adc566bba2656cba5460ceb553a4e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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@271e27b9) ace509823d863d33d5de204f894b3b49.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) ef1706a94309b9d3b1956fd3a387ecff.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) c444c519eca3974cd3693648dc85dfa8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (14/16) (0c4adc566bba2656cba5460ceb553a4e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) 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@271e27b9) (8/16) (ace509823d863d33d5de204f894b3b49) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (ef1706a94309b9d3b1956fd3a387ecff) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (10/16) (c444c519eca3974cd3693648dc85dfa8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) 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@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 883939ec877c5b17fac44f23e4750a20.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 65e3fd644c9bab37b74a0f85af05c408.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] 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@271e27b9) 2a77b2000936bc4bd00768e55fb777e0.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (883939ec877c5b17fac44f23e4750a20) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (236c4f8b7c99f44aaaa70cc8f02aa16f) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (236c4f8b7c99f44aaaa70cc8f02aa16f).
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (236c4f8b7c99f44aaaa70cc8f02aa16f) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16) (65e3fd644c9bab37b74a0f85af05c408) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (15/16) (2a77b2000936bc4bd00768e55fb777e0) 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@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) switched from CREATED to DEPLOYING.
[jobmanager-future-thread-16] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 204af9f872a7d130ea77ebcc4277246d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (204af9f872a7d130ea77ebcc4277246d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 60da9a9293e0b879032beb253411d575.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) 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@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) b16565869d3afeb1ebd315fd04cf370a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (60da9a9293e0b879032beb253411d575) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (b16565869d3afeb1ebd315fd04cf370a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16).
[flink-akka.actor.default-dispatcher-3] 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@271e27b9) 75d819d6ca4eb18c1494bf208bc5dced.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] 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@271e27b9) 00a6db00891ea24718847dc70c4dee6d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) 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@271e27b9) (16/16) (75d819d6ca4eb18c1494bf208bc5dced) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] 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@271e27b9) 0964d6b84de2d7354f84dea7606be144.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) 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@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) switched from DEPLOYING to RUNNING.
[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@271e27b9) b9ff8ce72499f4ae078d598aa944cd48.
[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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 236c4f8b7c99f44aaaa70cc8f02aa16f.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (13/16) (00a6db00891ea24718847dc70c4dee6d) 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@271e27b9) 2eaabf334dd8d82879012904872eac61.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (2/16) (0964d6b84de2d7354f84dea7606be144) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (7/16) (b9ff8ce72499f4ae078d598aa944cd48) 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@271e27b9) (3/16).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (236c4f8b7c99f44aaaa70cc8f02aa16f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (10/16) (2eaabf334dd8d82879012904872eac61) 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@271e27b9) d0fe1a078b69f7e6c63342f6986d1701.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) [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@271e27b9) bab0ff2931ad9595fbf801106fbe6bc0.
[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@271e27b9) 0063af5021b7c56ce5c89e257f30e673.
[flink-akka.actor.default-dispatcher-3] 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@271e27b9) dfdfe153119680b0ec3c1579b4d7e8a8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (5/16) (d0fe1a078b69f7e6c63342f6986d1701) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] 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@271e27b9) e6a79a263c80d67f61850f2625230594.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (11/16) (bab0ff2931ad9595fbf801106fbe6bc0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (4/16) (0063af5021b7c56ce5c89e257f30e673) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) 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@271e27b9) (6/16) (dfdfe153119680b0ec3c1579b4d7e8a8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (1/16) (e6a79a263c80d67f61850f2625230594) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (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@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) [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@271e27b9) fbf84c6a5e1e5e4cdb6a5e3fc0423186.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@271e27b9) (3/16) (fbf84c6a5e1e5e4cdb6a5e3fc0423186) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1126161653-2bff99de (ea874699e12d1070a12cbe17b7e91030) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job ea874699e12d1070a12cbe17b7e91030 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.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher22c21015-377a-4a55-8017-62b49c62ff1c.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1126161653-2bff99de(ea874699e12d1070a12cbe17b7e91030).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher22c21015-377a-4a55-8017-62b49c62ff1c.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 797136788121f386c60d46d6d498980c: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[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-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job ea874699e12d1070a12cbe17b7e91030 with leader id a1731acc623ee8ace9bbe21666cf49d2 lost leadership.
[ForkJoinPool.commonPool-worker-6] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher22c21015-377a-4a55-8017-62b49c62ff1c.
[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-80fbdc79-1b68-457b-8f3d-5e8fc3468c18
[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_260.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41073
[flink-akka.actor.default-dispatcher-3] 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 10992 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1126161653-2bff99de_2b34f47b-85c1-48ab-a397-d8c4eef00b48/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1126161653-2bff99de_2b34f47b-85c1-48ab-a397-d8c4eef00b48/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:34053
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:46109
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testCoderInferenceOfList SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 48 mins 14.972 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> 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 50m 38s
75 actionable tasks: 60 executed, 14 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/25jwhtwakctvo
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