See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/185/display/redirect?page=changes>
Changes:
[amaliujia] [BEAM-5852] add IS_INF and IS_NAN.
[amaliujia] [BEAM-5885] support COSH
[amaliujia] [BEAM-5889] support SINH
[amaliujia] [BEAM-5890] add TANH
[amaliujia] [SQL] spotless apply
[amaliujia] [BEAM-5892] add annotation to help register built-in functions.
[amaliujia] [SQL] improve beam builtin function registration.
------------------------------------------
[...truncated 500.18 MB...]
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (24f07c795aec0184898353c123614780) 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@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) switched from SCHEDULED to DEPLOYING.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/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)
(7/16) (d395c7452f9378c4c76bab28bac7c668) [FINISHED]
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/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)
(5/16) (24f07c795aec0184898353c123614780).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (7/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (9/16) (attempt
#0) to localhost
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (24f07c795aec0184898353c123614780) [FINISHED]
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (a05c15d4aa9fc3d86ce8407615ca2351) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (a05c15d4aa9fc3d86ce8407615ca2351).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (14/16)
(ca15e078b03a808cfd05762cd67e7a8c) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (1a72642e7421e668b44f434721b07b85) switched from RUNNING to FINISHED.
[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) (1a72642e7421e668b44f434721b07b85).
[MapPartition (MapPartition at
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (a05c15d4aa9fc3d86ce8407615ca2351) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (14/16)
(ca15e078b03a808cfd05762cd67e7a8c) 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@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) 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@352ae477) (4/16) (attempt
#0) to localhost
[jobmanager-future-thread-15] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) switched from CREATED to SCHEDULED.
[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) (1a72642e7421e668b44f434721b07b85) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) 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@352ae477) (5/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (14/16)
(ca15e078b03a808cfd05762cd67e7a8c) 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@352ae477) (2/16).
[jobmanager-future-thread-16] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) 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@352ae477) (6/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (14/16)
(ca15e078b03a808cfd05762cd67e7a8c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (14/16)
(ca15e078b03a808cfd05762cd67e7a8c).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (14/16)
(ca15e078b03a808cfd05762cd67e7a8c) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/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)
f6793c7e713b13c52008130feff4515a.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16) (f6793c7e713b13c52008130feff4515a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (2/16)
(02de6ee11ee70c1b73286cfbcafd89d0) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (2/16)
(02de6ee11ee70c1b73286cfbcafd89d0) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(2/16) (02de6ee11ee70c1b73286cfbcafd89d0) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (10/16).
[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)
ae70bfd5a49d5414e8c929565cf48605.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(10/16) (875248cbc7c6fde80af2d0637be96653) [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)
8ba193f454cc3392bb25f3e9a9563867.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (2/16)
(02de6ee11ee70c1b73286cfbcafd89d0) [DEPLOYING].
[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)
(11/16) (ae70bfd5a49d5414e8c929565cf48605) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (2/16)
(02de6ee11ee70c1b73286cfbcafd89d0) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653) 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)
(12/16) (8ba193f454cc3392bb25f3e9a9563867) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (11/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (2/16)
(02de6ee11ee70c1b73286cfbcafd89d0) 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@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653) 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@352ae477)
2858be513da40cb57276b33aefdffa6f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(11/16) (8880fc7d33870be3e6b728b283b10e03) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (2/16)
(02de6ee11ee70c1b73286cfbcafd89d0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(2/16) (02de6ee11ee70c1b73286cfbcafd89d0).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (8/16)
(2858be513da40cb57276b33aefdffa6f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (2/16)
(02de6ee11ee70c1b73286cfbcafd89d0) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03) 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@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03) [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@352ae477)
d63a8254b0e31598b21167c6f42003ee.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
61dfbee79a1389d8cf5fee97900bd384.
[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@352ae477)
14332dce5d9c0c7f657aadc342a1f8ce.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (1/16)
(d63a8254b0e31598b21167c6f42003ee) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
20caf8206df96d31b2dd705339e4deef.
[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)
bd9b7106cbeb45282033ae8af655ee71.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (13/16)
(61dfbee79a1389d8cf5fee97900bd384) 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@352ae477)
cf80382bfd059a4765050689120ed30d.
[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)
d395c7452f9378c4c76bab28bac7c668.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (16/16)
(14332dce5d9c0c7f657aadc342a1f8ce) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(12/16) (bee19b0c6bba72e6a7b573735813241b) [DEPLOYING].
[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)
(9/16) (20caf8206df96d31b2dd705339e4deef) 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)
(4/16) (bd9b7106cbeb45282033ae8af655ee71) 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@352ae477) (15/16)
(cf80382bfd059a4765050689120ed30d) 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) (d395c7452f9378c4c76bab28bac7c668) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (7/16)
(bf72ff3c95db1527536bba9ad7898fa5) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (7/16)
(bf72ff3c95db1527536bba9ad7898fa5) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(7/16) (bf72ff3c95db1527536bba9ad7898fa5) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (7/16)
(bf72ff3c95db1527536bba9ad7898fa5) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (7/16)
(bf72ff3c95db1527536bba9ad7898fa5) 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@352ae477) (7/16)
(bf72ff3c95db1527536bba9ad7898fa5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
24f07c795aec0184898353c123614780.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
a05c15d4aa9fc3d86ce8407615ca2351.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (7/16)
(bf72ff3c95db1527536bba9ad7898fa5) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(7/16) (bf72ff3c95db1527536bba9ad7898fa5).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(9/16) (75171aa85cea70b7900c43b16af087a4) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b).
[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)
1a72642e7421e668b44f434721b07b85.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (7/16)
(bf72ff3c95db1527536bba9ad7898fa5) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (24f07c795aec0184898353c123614780) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (a05c15d4aa9fc3d86ce8407615ca2351) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(9/16) (75171aa85cea70b7900c43b16af087a4).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (1a72642e7421e668b44f434721b07b85) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (4/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(4/16) (d8b70ab1b336eb034dda5de71d686438) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(5/16) (08dcada106b0e60a6964f22caae0aee8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) 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@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(4/16) (d8b70ab1b336eb034dda5de71d686438).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
ca15e078b03a808cfd05762cd67e7a8c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(5/16) (08dcada106b0e60a6964f22caae0aee8).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(6/16) (5d38b308531a96b04e55932f2062498f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (14/16)
(ca15e078b03a808cfd05762cd67e7a8c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) 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@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
02de6ee11ee70c1b73286cfbcafd89d0.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
875248cbc7c6fde80af2d0637be96653.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
8880fc7d33870be3e6b728b283b10e03.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (2/16)
(02de6ee11ee70c1b73286cfbcafd89d0) 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@352ae477)
bf72ff3c95db1527536bba9ad7898fa5.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (10/16)
(875248cbc7c6fde80af2d0637be96653) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) [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@352ae477)
bee19b0c6bba72e6a7b573735813241b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(3/16) (6d17f84f78f6f3bbd4e6065a05372772) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(6/16) (5d38b308531a96b04e55932f2062498f).
[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@352ae477)
75171aa85cea70b7900c43b16af087a4.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (11/16)
(8880fc7d33870be3e6b728b283b10e03) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) [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@352ae477)
d8b70ab1b336eb034dda5de71d686438.
[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@352ae477)
08dcada106b0e60a6964f22caae0aee8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) 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@352ae477) (7/16)
(bf72ff3c95db1527536bba9ad7898fa5) 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@352ae477)
5d38b308531a96b04e55932f2062498f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(3/16) (6d17f84f78f6f3bbd4e6065a05372772).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (12/16)
(bee19b0c6bba72e6a7b573735813241b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
(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@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477)
6d17f84f78f6f3bbd4e6065a05372772.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (9/16)
(75171aa85cea70b7900c43b16af087a4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (4/16)
(d8b70ab1b336eb034dda5de71d686438) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) 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@352ae477) (5/16)
(08dcada106b0e60a6964f22caae0aee8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (6/16)
(5d38b308531a96b04e55932f2062498f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@352ae477) (3/16)
(6d17f84f78f6f3bbd4e6065a05372772) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1101173802-61aa64f7
(f4ad49b3383513cfbf58309231b378fe) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
f4ad49b3383513cfbf58309231b378fe 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-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatchera338a243-a79e-4581-9f90-bf11f9831220.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatchera338a243-a79e-4581-9f90-bf11f9831220.
[flink-akka.actor.default-dispatcher-6] 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.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1101173802-61aa64f7(f4ad49b3383513cfbf58309231b378fe).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager ab8e483f1d69a59f882e1d7dd60809a5 from the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
c6c054709f662a6df4d3915d9b484155: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcActor - The rpc endpoint
org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet.
Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation
until processing is started.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
f4ad49b3383513cfbf58309231b378fe with leader id
9fb1c95e05e002c9ac476013d90b412b lost leadership.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatchera338a243-a79e-4581-9f90-bf11f9831220.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-49acc800-8476-49c0-b867-826abdaf83fb
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[ForkJoinPool.commonPool-worker-10] 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.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_242.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41401
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 11047 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1101173802-61aa64f7_c1dec344-1d23-4be6-b69e-d8bc288ca64f/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-1101173802-61aa64f7_c1dec344-1d23-4be6-b69e-d8bc288ca64f/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:34029
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:43095
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
187 tests completed, 1 failed, 1 skipped
Finished generating test XML results (1.508 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.689 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 ':',5,main]) completed. Took 45 mins 41.592 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 48m 13s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/tccc7x3faeao2
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
