See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/82/display/redirect?page=changes>
Changes:
[github] [BEAM-3612] Make function registration idempotent
[github] [BEAM-3612] Make type registration idempotent
------------------------------------------
[...truncated 468.16 MB...]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (10/16) (attempt
#0) to localhost
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16) (e445d273c1486f56a13d96ecbedef76b) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16) (e445d273c1486f56a13d96ecbedef76b).
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16) (e445d273c1486f56a13d96ecbedef76b) [FINISHED]
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (a5fff9d6d62aeef718e8fcf4af9882a8) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (a5fff9d6d62aeef718e8fcf4af9882a8).
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (a5fff9d6d62aeef718e8fcf4af9882a8) [FINISHED]
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (76afb103ec968b23d7b3d52a0e122a2b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(12/16) (40cb3dc3894aed569ac2bf1ea8695bef) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (76afb103ec968b23d7b3d52a0e122a2b).
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (5c4fe4db4406448aaba5ee62218a5b9d) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (5c4fe4db4406448aaba5ee62218a5b9d).
[jobmanager-future-thread-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (76afb103ec968b23d7b3d52a0e122a2b) [FINISHED]
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (5c4fe4db4406448aaba5ee62218a5b9d) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (4/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (16/16)
(6720fbf265e5f4e4ddc2a7d2b3f36465) 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@f03ee20) (16/16)
(6720fbf265e5f4e4ddc2a7d2b3f36465) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (12/16)
(40cb3dc3894aed569ac2bf1ea8695bef) 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@f03ee20) (12/16)
(40cb3dc3894aed569ac2bf1ea8695bef) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (16/16)
(6720fbf265e5f4e4ddc2a7d2b3f36465) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (16/16)
(6720fbf265e5f4e4ddc2a7d2b3f36465).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (12/16)
(40cb3dc3894aed569ac2bf1ea8695bef) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (16/16)
(6720fbf265e5f4e4ddc2a7d2b3f36465) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (12/16)
(40cb3dc3894aed569ac2bf1ea8695bef).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (12/16)
(40cb3dc3894aed569ac2bf1ea8695bef) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (9/16)
(684d20f0e707154cbc3b1c8d8fd2231e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (9/16)
(684d20f0e707154cbc3b1c8d8fd2231e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16) (684d20f0e707154cbc3b1c8d8fd2231e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16) (684d20f0e707154cbc3b1c8d8fd2231e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (9/16)
(684d20f0e707154cbc3b1c8d8fd2231e) 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@f03ee20) (9/16)
(684d20f0e707154cbc3b1c8d8fd2231e) 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@f03ee20)
84aad30ea657c0539576579e4034ebce.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (14/16)
(f2e568cd2835b4b29f681a755d867769) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (14/16)
(f2e568cd2835b4b29f681a755d867769) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16) (f2e568cd2835b4b29f681a755d867769) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
0015ee345b3c95ff4d9c2427653fab87.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
6ca7e2c8b02a3edc6978788d17bd9196.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16) (f2e568cd2835b4b29f681a755d867769) [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@f03ee20)
581f547fac2742ae72c0703b23839bf3.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (14/16)
(f2e568cd2835b4b29f681a755d867769) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (9/16)
(684d20f0e707154cbc3b1c8d8fd2231e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(9/16) (684d20f0e707154cbc3b1c8d8fd2231e).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (8/16)
(84aad30ea657c0539576579e4034ebce) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (9/16)
(684d20f0e707154cbc3b1c8d8fd2231e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (14/16)
(f2e568cd2835b4b29f681a755d867769) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (14/16)
(f2e568cd2835b4b29f681a755d867769).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (14/16)
(f2e568cd2835b4b29f681a755d867769) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (0015ee345b3c95ff4d9c2427653fab87) 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@f03ee20) (11/16).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (6ca7e2c8b02a3edc6978788d17bd9196) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (1/16)
(581f547fac2742ae72c0703b23839bf3) 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@f03ee20)
6f2523796dc56a0d1ac66944879730ef.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (11/16)
(4dc225c1523fb4a4e237823deb0fddf3) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (11/16)
(4dc225c1523fb4a4e237823deb0fddf3) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (14/16)
(f2e568cd2835b4b29f681a755d867769) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
9b67d888ae3b469489f169c553257401.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (13/16)
(6f2523796dc56a0d1ac66944879730ef) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(11/16) (4dc225c1523fb4a4e237823deb0fddf3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (9b67d888ae3b469489f169c553257401) 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@f03ee20) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(11/16) (4dc225c1523fb4a4e237823deb0fddf3) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (11/16)
(4dc225c1523fb4a4e237823deb0fddf3) 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@f03ee20) (11/16)
(4dc225c1523fb4a4e237823deb0fddf3) 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@f03ee20)
986f4b351d6bc9aeb07419d5d1f5622a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (6/16)
(2145ea109d8e5d27e686a2368d166700) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (6/16)
(2145ea109d8e5d27e686a2368d166700) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16) (2145ea109d8e5d27e686a2368d166700) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16) (2145ea109d8e5d27e686a2368d166700) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (11/16)
(4dc225c1523fb4a4e237823deb0fddf3) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (11/16)
(4dc225c1523fb4a4e237823deb0fddf3).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (15/16)
(986f4b351d6bc9aeb07419d5d1f5622a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (11/16)
(4dc225c1523fb4a4e237823deb0fddf3) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (6/16)
(2145ea109d8e5d27e686a2368d166700) 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@f03ee20) (6/16)
(2145ea109d8e5d27e686a2368d166700) 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@f03ee20) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (6/16)
(2145ea109d8e5d27e686a2368d166700) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(6/16) (2145ea109d8e5d27e686a2368d166700).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (6/16)
(2145ea109d8e5d27e686a2368d166700) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
394c61ab89c642cb977434116d2acec5.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (3/16)
(770344065f4f2eb49ba4b131cd831408) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (3/16)
(770344065f4f2eb49ba4b131cd831408) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16) (770344065f4f2eb49ba4b131cd831408) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16) (394c61ab89c642cb977434116d2acec5) 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@f03ee20) (7/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
43d5949bf7c6c9c00bc074557e2fb7de.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (7/16)
(64bd81ef1d62d79391a1e7a7f193832d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16) (770344065f4f2eb49ba4b131cd831408) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (7/16)
(64bd81ef1d62d79391a1e7a7f193832d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16) (64bd81ef1d62d79391a1e7a7f193832d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (3/16)
(770344065f4f2eb49ba4b131cd831408) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16) (64bd81ef1d62d79391a1e7a7f193832d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (43d5949bf7c6c9c00bc074557e2fb7de) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (7/16)
(64bd81ef1d62d79391a1e7a7f193832d) 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@f03ee20) (3/16)
(770344065f4f2eb49ba4b131cd831408) 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@f03ee20) (2/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (7/16)
(64bd81ef1d62d79391a1e7a7f193832d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (2/16)
(e67da9bef0a872120791b273c68e8f5c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (7/16)
(64bd81ef1d62d79391a1e7a7f193832d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(7/16) (64bd81ef1d62d79391a1e7a7f193832d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (3/16)
(770344065f4f2eb49ba4b131cd831408) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (2/16)
(e67da9bef0a872120791b273c68e8f5c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(3/16) (770344065f4f2eb49ba4b131cd831408).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16) (e67da9bef0a872120791b273c68e8f5c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (7/16)
(64bd81ef1d62d79391a1e7a7f193832d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (3/16)
(770344065f4f2eb49ba4b131cd831408) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16) (e67da9bef0a872120791b273c68e8f5c) [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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
e445d273c1486f56a13d96ecbedef76b.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
a5fff9d6d62aeef718e8fcf4af9882a8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (2/16)
(e67da9bef0a872120791b273c68e8f5c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (10/16)
(f12ae907991af2e0b839b09d0ac82606) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (10/16)
(f12ae907991af2e0b839b09d0ac82606) [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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
76afb103ec968b23d7b3d52a0e122a2b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(10/16) (f12ae907991af2e0b839b09d0ac82606) [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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
5c4fe4db4406448aaba5ee62218a5b9d.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16) (e445d273c1486f56a13d96ecbedef76b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(10/16) (f12ae907991af2e0b839b09d0ac82606) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (2/16)
(e67da9bef0a872120791b273c68e8f5c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (10/16)
(f12ae907991af2e0b839b09d0ac82606) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (a5fff9d6d62aeef718e8fcf4af9882a8) 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@f03ee20) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (2/16)
(e67da9bef0a872120791b273c68e8f5c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(2/16) (e67da9bef0a872120791b273c68e8f5c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (2/16)
(e67da9bef0a872120791b273c68e8f5c) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (76afb103ec968b23d7b3d52a0e122a2b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (10/16)
(f12ae907991af2e0b839b09d0ac82606) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (10/16)
(f12ae907991af2e0b839b09d0ac82606).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (5c4fe4db4406448aaba5ee62218a5b9d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (10/16)
(f12ae907991af2e0b839b09d0ac82606) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (10/16)
(f12ae907991af2e0b839b09d0ac82606) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16) (b76a3d8bb0e412c7317dcb5fff59e665) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16) (b76a3d8bb0e412c7317dcb5fff59e665) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16) (67b82726c8203439684f4a20cabbd32e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16) (67b82726c8203439684f4a20cabbd32e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) 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@f03ee20)
6720fbf265e5f4e4ddc2a7d2b3f36465.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) 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@f03ee20)
40cb3dc3894aed569ac2bf1ea8695bef.
[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@f03ee20)
684d20f0e707154cbc3b1c8d8fd2231e.
[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@f03ee20)
f2e568cd2835b4b29f681a755d867769.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (16/16)
(6720fbf265e5f4e4ddc2a7d2b3f36465) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
4dc225c1523fb4a4e237823deb0fddf3.
[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@f03ee20)
2145ea109d8e5d27e686a2368d166700.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(4/16) (b76a3d8bb0e412c7317dcb5fff59e665).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(5/16) (67b82726c8203439684f4a20cabbd32e).
[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@f03ee20)
64bd81ef1d62d79391a1e7a7f193832d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
(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@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
770344065f4f2eb49ba4b131cd831408.
[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@f03ee20)
e67da9bef0a872120791b273c68e8f5c.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (12/16)
(40cb3dc3894aed569ac2bf1ea8695bef) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20)
f12ae907991af2e0b839b09d0ac82606.
[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@f03ee20)
b76a3d8bb0e412c7317dcb5fff59e665.
[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@f03ee20)
67b82726c8203439684f4a20cabbd32e.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (9/16)
(684d20f0e707154cbc3b1c8d8fd2231e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (14/16)
(f2e568cd2835b4b29f681a755d867769) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (11/16)
(4dc225c1523fb4a4e237823deb0fddf3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (6/16)
(2145ea109d8e5d27e686a2368d166700) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (7/16)
(64bd81ef1d62d79391a1e7a7f193832d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (3/16)
(770344065f4f2eb49ba4b131cd831408) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (2/16)
(e67da9bef0a872120791b273c68e8f5c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (10/16)
(f12ae907991af2e0b839b09d0ac82606) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (4/16)
(b76a3d8bb0e412c7317dcb5fff59e665) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@f03ee20) (5/16)
(67b82726c8203439684f4a20cabbd32e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1023185150-da05d65b
(5255d1ddf55b03c955efb4090d2d2ae0) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
5255d1ddf55b03c955efb4090d2d2ae0 reached globally terminal state FINISHED.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1023185150-da05d65b(5255d1ddf55b03c955efb4090d2d2ae0).
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherfa3a87e2-f5bd-45c4-a836-eec5b9ba7721.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherfa3a87e2-f5bd-45c4-a836-eec5b9ba7721.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
8ef7f06e206c57e7e8e80a61b1ee630c: JobManager is shutting down..
[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-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager 1ca0c780cc96fb639b80df9dbf30e25a from the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
5255d1ddf55b03c955efb4090d2d2ae0 with leader id
bf9d18ada764a37c60f58209df864908 lost leadership.
[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-72afc9f0-4d39-4c24-9ea1-444296dcafd8
[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-6] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherfa3a87e2-f5bd-45c4-a836-eec5b9ba7721.
[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_212.
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:37515
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 11751 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1023185150-da05d65b_995565ac-e928-4070-80e0-9ece057e85a2/MANIFEST
has 179 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1023185150-da05d65b_995565ac-e928-4070-80e0-9ece057e85a2/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:33259
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:34267
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
170 tests completed, 1 failed, 1 skipped
Finished generating test XML results (4.564 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.916 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 8,5,main]) completed. Took 37 mins 28.715 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 40m 31s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/dfgumjvhvqknu
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
