See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/49/display/redirect>
------------------------------------------
[...truncated 236.02 MB...]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (14/16)
(ae32d3763013f5bc7755c21a46ec037c) [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$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
cde46d453c8b7afb80350e8c43ae33e1.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
194c7b99b625cf9f2b48d2900eb7e859.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(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@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(12/16) (a97c504b189c0cffb6c3842fdca96c66) [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$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
2a56c6a5847e49353e8fd78516933c19.
[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@7e5967b9)
743945d0c6e18eb8bf101baf2d4bae79.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(13/16) (cde46d453c8b7afb80350e8c43ae33e1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(2/16) (194c7b99b625cf9f2b48d2900eb7e859) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(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@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(16/16) (2a56c6a5847e49353e8fd78516933c19) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
df54baca8492c3a3b88921edbdae3d29.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (6/16)
(743945d0c6e18eb8bf101baf2d4bae79) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16) (f18252aa73067c9d6efebf79ece01676) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(11/16) (df54baca8492c3a3b88921edbdae3d29) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676) 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@484e078b) (2/16).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (2/16)
(62d74031df3452a82778afe75cca107b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (2/16)
(62d74031df3452a82778afe75cca107b) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(2/16) (62d74031df3452a82778afe75cca107b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (2/16)
(62d74031df3452a82778afe75cca107b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (2/16)
(62d74031df3452a82778afe75cca107b) 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@484e078b) (2/16)
(62d74031df3452a82778afe75cca107b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (2/16)
(62d74031df3452a82778afe75cca107b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(2/16) (62d74031df3452a82778afe75cca107b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (2/16)
(62d74031df3452a82778afe75cca107b) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (3/16)
(58eca5bd97ac8028a9cedff8c0bac2a8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (3/16)
(58eca5bd97ac8028a9cedff8c0bac2a8) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(3/16) (58eca5bd97ac8028a9cedff8c0bac2a8) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16).
[MapPartition (MapPartition at
PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (8/16)
(2adae3174af04e98097d334009e8f7c6) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (8/16)
(2adae3174af04e98097d334009e8f7c6).
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (3/16)
(58eca5bd97ac8028a9cedff8c0bac2a8) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at
PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (8/16)
(2adae3174af04e98097d334009e8f7c6) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (3/16)
(58eca5bd97ac8028a9cedff8c0bac2a8) 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@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) 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@7e5967b9) (8/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@484e078b) (3/16)
(58eca5bd97ac8028a9cedff8c0bac2a8) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
c32547bb087aaaaa821bc865d936831d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (3/16)
(58eca5bd97ac8028a9cedff8c0bac2a8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(3/16) (58eca5bd97ac8028a9cedff8c0bac2a8).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(16/16) (fe68d8f71fa6cb9aec87358ded05040e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (3/16)
(58eca5bd97ac8028a9cedff8c0bac2a8) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(4/16) (c32547bb087aaaaa821bc865d936831d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(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@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(11/16) (d77c2b5402d05a979d26e320e6e0d5f8) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (4/16)
(b073b206e5e1f9e5687fdc6a05c8a99e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (4/16)
(b073b206e5e1f9e5687fdc6a05c8a99e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(4/16) (b073b206e5e1f9e5687fdc6a05c8a99e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (4/16)
(b073b206e5e1f9e5687fdc6a05c8a99e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(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@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(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@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (4/16)
(b073b206e5e1f9e5687fdc6a05c8a99e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (4/16)
(b073b206e5e1f9e5687fdc6a05c8a99e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
30b9dff52eb6ccecfec2d8d2aea05460.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (4/16)
(b073b206e5e1f9e5687fdc6a05c8a99e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
4e38d373459bd0aa14d15e43cf57bbdd.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(4/16) (b073b206e5e1f9e5687fdc6a05c8a99e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (4/16)
(b073b206e5e1f9e5687fdc6a05c8a99e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16)
(8894468492eddc20cbd39e7db42d185e) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
ee005f89a9389c6f68a065e6e574184c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16)
(8894468492eddc20cbd39e7db42d185e) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
55f7a1ebce4502ff208e974d726f1c42.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(8/16) (30b9dff52eb6ccecfec2d8d2aea05460) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16) (8894468492eddc20cbd39e7db42d185e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(3/16) (4e38d373459bd0aa14d15e43cf57bbdd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(5/16) (ee005f89a9389c6f68a065e6e574184c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (5/16).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$89/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(1/16) (55f7a1ebce4502ff208e974d726f1c42) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16)
(8894468492eddc20cbd39e7db42d185e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16)
(8894468492eddc20cbd39e7db42d185e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
4f69fc461f8e1e356d5b80099d1d291f.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16)
(8894468492eddc20cbd39e7db42d185e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (5/16)
(a4ab0280cbfe443289082897e077d3fa) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (5/16)
(a4ab0280cbfe443289082897e077d3fa) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(5/16) (a4ab0280cbfe443289082897e077d3fa) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(13/16) (4f69fc461f8e1e356d5b80099d1d291f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (5/16)
(a4ab0280cbfe443289082897e077d3fa) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (5/16)
(a4ab0280cbfe443289082897e077d3fa) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16)
(8894468492eddc20cbd39e7db42d185e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16) (8894468492eddc20cbd39e7db42d185e).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (5/16)
(a4ab0280cbfe443289082897e077d3fa) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16)
(8894468492eddc20cbd39e7db42d185e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (5/16)
(a4ab0280cbfe443289082897e077d3fa) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(5/16) (a4ab0280cbfe443289082897e077d3fa).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(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@484e078b) (5/16)
(a4ab0280cbfe443289082897e077d3fa) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16) (208810ada549c61ad3f290b0ace5d9e3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (1/16).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
1879a1a24f2b061f1c333387a54dea0f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
366d68d9d9aee87a43bb6a2841c67eca.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
4dbf4ab12117b39b30dc615df5427034.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (6/16)
(1879a1a24f2b061f1c333387a54dea0f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
ae32d3763013f5bc7755c21a46ec037c.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
a97c504b189c0cffb6c3842fdca96c66.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (12/16)
(366d68d9d9aee87a43bb6a2841c67eca) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
f18252aa73067c9d6efebf79ece01676.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
62d74031df3452a82778afe75cca107b.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (16/16)
(4dbf4ab12117b39b30dc615df5427034) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
2adae3174af04e98097d334009e8f7c6.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (14/16)
(ae32d3763013f5bc7755c21a46ec037c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (12/16)
(a97c504b189c0cffb6c3842fdca96c66) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (13/16)
(f18252aa73067c9d6efebf79ece01676) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (2/16)
(62d74031df3452a82778afe75cca107b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$92/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(8/16) (2adae3174af04e98097d334009e8f7c6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
58eca5bd97ac8028a9cedff8c0bac2a8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
d77c2b5402d05a979d26e320e6e0d5f8.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
fe68d8f71fa6cb9aec87358ded05040e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16) (90b81d41ad5cb8cb081ad17cd486045b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
b073b206e5e1f9e5687fdc6a05c8a99e.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (3/16)
(58eca5bd97ac8028a9cedff8c0bac2a8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
8894468492eddc20cbd39e7db42d185e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
a4ab0280cbfe443289082897e077d3fa.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (11/16)
(d77c2b5402d05a979d26e320e6e0d5f8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
208810ada549c61ad3f290b0ace5d9e3.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (16/16)
(fe68d8f71fa6cb9aec87358ded05040e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (4/16)
(b073b206e5e1f9e5687fdc6a05c8a99e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (8/16)
(8894468492eddc20cbd39e7db42d185e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (5/16)
(a4ab0280cbfe443289082897e077d3fa) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16) (90b81d41ad5cb8cb081ad17cd486045b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9)
90b81d41ad5cb8cb081ad17cd486045b.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (13/16)
(208810ada549c61ad3f290b0ace5d9e3) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (1/16)
(d0f7d724eef6b8871c2e748a1be6ab4a) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (1/16)
(d0f7d724eef6b8871c2e748a1be6ab4a) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@7e5967b9) (8/16)
(90b81d41ad5cb8cb081ad17cd486045b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16) (d0f7d724eef6b8871c2e748a1be6ab4a) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (1/16)
(d0f7d724eef6b8871c2e748a1be6ab4a) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (1/16)
(d0f7d724eef6b8871c2e748a1be6ab4a) 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@484e078b) (1/16)
(d0f7d724eef6b8871c2e748a1be6ab4a) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (1/16)
(d0f7d724eef6b8871c2e748a1be6ab4a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16) (d0f7d724eef6b8871c2e748a1be6ab4a).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (1/16)
(d0f7d724eef6b8871c2e748a1be6ab4a) [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@484e078b)
d0f7d724eef6b8871c2e748a1be6ab4a.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@484e078b) (1/16)
(d0f7d724eef6b8871c2e748a1be6ab4a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
countingsourcetest0testboundedsourcesplits-jenkins-1129122420-238dcd09
(b40a2e088b2749200cfcc42072ca72ea) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
b40a2e088b2749200cfcc42072ca72ea reached globally terminal state FINISHED.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher6edcab6e-812b-482c-a120-5e322de88cad.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
countingsourcetest0testboundedsourcesplits-jenkins-1129122420-238dcd09(b40a2e088b2749200cfcc42072ca72ea).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher6edcab6e-812b-482c-a120-5e322de88cad.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
f550b5aecd9343ae034cc378e2212e72: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
b40a2e088b2749200cfcc42072ca72ea with leader id
be81eb83b97876094b2f68811eb84bb9 lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-80bf917c-66b8-4224-8f20-b6a04c2de32f
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher6edcab6e-812b-482c-a120-5e322de88cad.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_102.
[ForkJoinPool.commonPool-worker-2] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-2] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41459
[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 14367 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1129122420-238dcd09_4a5d226b-38e3-4f8e-a4ae-419fd97f458c/MANIFEST
has 186 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1129122420-238dcd09_4a5d226b-38e3-4f8e-a4ae-419fd97f458c/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:37413
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:44631
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.values.PCollectionTupleTest > testComposePCollectionTuple
SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task
worker for ':' Thread 4,5,main]) completed. Took 20 mins 56.927 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at
https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 24m 35s
75 actionable tasks: 66 executed, 8 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/ypjpxqtemoadu
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]
