See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/165/display/redirect?page=changes>
Changes:
[iemejia] [BEAM-4783] Fix invalid parameter to set the partitioner in Spark GbK
[timrobertson100] [BEAM-5036] Optimize the FileBasedSink
WriteOperation.moveToOutput()
[scott] [BEAM-5913] Re-enable parallel builds for Java Jenkins jobs (#6882)
[scott] [BEAM-308] Print warning about using non-public PipelineOptions
------------------------------------------
[...truncated 499.12 MB...]
[MapPartition (MapPartition at
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (a3ff4fef6929568ea4c10f73ed627534).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (12/16)
(89fb22303f1b20e405236ff2b266f6ec) [FINISHED]
[jobmanager-future-thread-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2) switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (a3ff4fef6929568ea4c10f73ed627534) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(16/16) (2cf68514a1f4ece6090116c78168e4c2) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16) (ac656bbd3d4ea9fdfceffdd3b5c8ac0d) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16) (ac656bbd3d4ea9fdfceffdd3b5c8ac0d).
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (79c6e81d8fadb4f4df1de9bf6bb702cc) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (79c6e81d8fadb4f4df1de9bf6bb702cc).
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16) (ac656bbd3d4ea9fdfceffdd3b5c8ac0d) [FINISHED]
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (79c6e81d8fadb4f4df1de9bf6bb702cc) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (6d3336668bb565e1b72b27ae16da0f3a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2) 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@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) 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@33a46ad9) (3/16) (attempt
#0) to localhost
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (10/16).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) 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@33a46ad9) (13/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) 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@33a46ad9) (2/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
cffb4b84d1a87cf14dfc07cb202b02d0.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
fe016f8af9582696379b8747248bcc70.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(10/16) (887d01518ba57daa98f6c60409d4f9ee) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
a2ec2d1e788974fa17aae9d09f9a8a51.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (cffb4b84d1a87cf14dfc07cb202b02d0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (fe016f8af9582696379b8747248bcc70) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16) (a2ec2d1e788974fa17aae9d09f9a8a51) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(15/16) (154e89da57edcbd49d50363d4a6261f1) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1) 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@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (7/16)
(a0e0cf6efb227f735ae6839489972ab1) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (7/16)
(a0e0cf6efb227f735ae6839489972ab1) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(7/16) (a0e0cf6efb227f735ae6839489972ab1) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (7/16)
(a0e0cf6efb227f735ae6839489972ab1) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (6/16)
(b510408fbd7c252a981b3fbc930cc055) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (6/16)
(b510408fbd7c252a981b3fbc930cc055) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(6/16) (b510408fbd7c252a981b3fbc930cc055) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (7/16)
(a0e0cf6efb227f735ae6839489972ab1) 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@33a46ad9) (7/16)
(a0e0cf6efb227f735ae6839489972ab1) 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@33a46ad9) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (6/16)
(b510408fbd7c252a981b3fbc930cc055) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (6/16)
(b510408fbd7c252a981b3fbc930cc055) 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@33a46ad9) (6/16)
(b510408fbd7c252a981b3fbc930cc055) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
03fc0302f154b776dbb3b4bb2def0cf2.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (5/16)
(6ce5385af3038515cce330f295bb3026) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (5/16)
(6ce5385af3038515cce330f295bb3026) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(5/16) (6ce5385af3038515cce330f295bb3026) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
7a32c8f928a50457632f4e2edb32e1ae.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (5/16)
(6ce5385af3038515cce330f295bb3026) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (5/16)
(6ce5385af3038515cce330f295bb3026) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (11/16)
(03fc0302f154b776dbb3b4bb2def0cf2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (6/16)
(b510408fbd7c252a981b3fbc930cc055) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(6/16) (b510408fbd7c252a981b3fbc930cc055).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (5/16)
(6ce5385af3038515cce330f295bb3026) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (7/16)
(a0e0cf6efb227f735ae6839489972ab1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(5/16) (6ce5385af3038515cce330f295bb3026).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (6/16)
(b510408fbd7c252a981b3fbc930cc055) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(7/16) (a0e0cf6efb227f735ae6839489972ab1).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (5/16)
(6ce5385af3038515cce330f295bb3026) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (7/16)
(a0e0cf6efb227f735ae6839489972ab1) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (7a32c8f928a50457632f4e2edb32e1ae) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (9/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (5/16)
(6ce5385af3038515cce330f295bb3026) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
0904c02cee9a4b1f2a917de25247e5b7.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (9/16)
(fdd4b936a25582f4f6be27cde2c21e3e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (9/16)
(fdd4b936a25582f4f6be27cde2c21e3e) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
a0adef81a91aeface114cd94ed04497b.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
6525e0f77e6aade10878a509b63c8d4c.
[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@33a46ad9)
8424c91e0819e838805412421773a815.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (8/16)
(0904c02cee9a4b1f2a917de25247e5b7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16) (fdd4b936a25582f4f6be27cde2c21e3e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (1/16)
(a0adef81a91aeface114cd94ed04497b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (4/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (6525e0f77e6aade10878a509b63c8d4c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (9/16)
(fdd4b936a25582f4f6be27cde2c21e3e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (9/16)
(fdd4b936a25582f4f6be27cde2c21e3e) 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@33a46ad9) (14/16)
(8424c91e0819e838805412421773a815) 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@33a46ad9) (9/16)
(fdd4b936a25582f4f6be27cde2c21e3e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
89fb22303f1b20e405236ff2b266f6ec.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (4/16)
(a1471bebecbe308982846e09c8f0f6cd) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
a3ff4fef6929568ea4c10f73ed627534.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (4/16)
(a1471bebecbe308982846e09c8f0f6cd) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
ac656bbd3d4ea9fdfceffdd3b5c8ac0d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(4/16) (a1471bebecbe308982846e09c8f0f6cd) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (9/16)
(fdd4b936a25582f4f6be27cde2c21e3e) 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 MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
79c6e81d8fadb4f4df1de9bf6bb702cc.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(9/16) (fdd4b936a25582f4f6be27cde2c21e3e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (9/16)
(fdd4b936a25582f4f6be27cde2c21e3e) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (12/16)
(89fb22303f1b20e405236ff2b266f6ec) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (4/16)
(a1471bebecbe308982846e09c8f0f6cd) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (a3ff4fef6929568ea4c10f73ed627534) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (4/16)
(a1471bebecbe308982846e09c8f0f6cd) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16) (ac656bbd3d4ea9fdfceffdd3b5c8ac0d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (4/16)
(a1471bebecbe308982846e09c8f0f6cd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (79c6e81d8fadb4f4df1de9bf6bb702cc) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(4/16) (a1471bebecbe308982846e09c8f0f6cd).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (4/16)
(a1471bebecbe308982846e09c8f0f6cd) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (4/16)
(a1471bebecbe308982846e09c8f0f6cd) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(3/16) (e08c2c0eb566cf8fe7a9f6cfc59dcc28) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(13/16) (98acc806d20806e951345bff097c5b29) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
2cf68514a1f4ece6090116c78168e4c2.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(2/16) (b55862d70d3ba44b60f4b10317a8c295) [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@33a46ad9)
887d01518ba57daa98f6c60409d4f9ee.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (16/16)
(2cf68514a1f4ece6090116c78168e4c2) 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@33a46ad9)
154e89da57edcbd49d50363d4a6261f1.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(3/16) (e08c2c0eb566cf8fe7a9f6cfc59dcc28).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) 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@33a46ad9)
b510408fbd7c252a981b3fbc930cc055.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) [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@33a46ad9)
6ce5385af3038515cce330f295bb3026.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (10/16)
(887d01518ba57daa98f6c60409d4f9ee) 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@33a46ad9)
a0e0cf6efb227f735ae6839489972ab1.
[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@33a46ad9)
fdd4b936a25582f4f6be27cde2c21e3e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(2/16) (b55862d70d3ba44b60f4b10317a8c295).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
(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@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (15/16)
(154e89da57edcbd49d50363d4a6261f1) 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 DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
a1471bebecbe308982846e09c8f0f6cd.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) 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@33a46ad9)
e08c2c0eb566cf8fe7a9f6cfc59dcc28.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (6/16)
(b510408fbd7c252a981b3fbc930cc055) 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 DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9)
98acc806d20806e951345bff097c5b29.
[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@33a46ad9)
b55862d70d3ba44b60f4b10317a8c295.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (5/16)
(6ce5385af3038515cce330f295bb3026) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (7/16)
(a0e0cf6efb227f735ae6839489972ab1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (9/16)
(fdd4b936a25582f4f6be27cde2c21e3e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (4/16)
(a1471bebecbe308982846e09c8f0f6cd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (3/16)
(e08c2c0eb566cf8fe7a9f6cfc59dcc28) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (13/16)
(98acc806d20806e951345bff097c5b29) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@33a46ad9) (2/16)
(b55862d70d3ba44b60f4b10317a8c295) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1030155907-16e329fe
(87a908b12e7de240c3ac2f7987414243) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
87a908b12e7de240c3ac2f7987414243 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1030155907-16e329fe(87a908b12e7de240c3ac2f7987414243).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 87a908b12e7de240c3ac2f7987414243.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
bb61126d98aecf1251acbd4cbefac151: JobManager is shutting down..
[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.resourcemanager.StandaloneResourceManager - Disconnect
job manager bf7fe4348ac5c85b9aa29cfa842044c4@akka://flink/user/jobmanager_243
for job 87a908b12e7de240c3ac2f7987414243 from the resource manager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher5d716051-d675-4010-bf35-27e644177a7d.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher5d716051-d675-4010-bf35-27e644177a7d.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager f5174172833a026497676cf3cbbe3317 from the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
87a908b12e7de240c3ac2f7987414243 with leader id
bf7fe4348ac5c85b9aa29cfa842044c4 lost leadership.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{46120fb9efcf011e4edb9eb97be11a43}, jobId:
87a908b12e7de240c3ac2f7987414243).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{9a200bf630edd6dab4eaae6fd2d36cb2}, jobId:
87a908b12e7de240c3ac2f7987414243).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_242.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-c8e4f640-c592-43d6-99a4-181eead81709
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher5d716051-d675-4010-bf35-27e644177a7d.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_242.
[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-7] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:33379
[flink-akka.actor.default-dispatcher-7] 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 11234 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1030155907-16e329fe_c27226f0-2e1e-4b97-a95a-25a3482962dc/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-1030155907-16e329fe_c27226f0-2e1e-4b97-a95a-25a3482962dc/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:46655
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:39113
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
187 tests completed, 1 failed, 1 skipped
Finished generating test XML results (4.468 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunner>
Generating HTML test report...
Finished generating test html results (1.854 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker
for ':' Thread 11,5,main]) completed. Took 42 mins 58.385 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner/index.html>
* 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 45m 35s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/m354ohmmfpztm
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org
