See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/84/display/redirect?page=changes>
Changes:
[kedin] [SQL] Move builtin aggregations creation to a map of factories
[kedin] [SQL] Simplify AggregationRel
[kedin] [SQL] Add AggregationCall wrapper
[kedin] [SQL] Inline aggregation rel helper transforms
[kedin] [SQL] Move CombineFn creation to AggregationCall constructor
[kedin] [SQL] Split and rename Aggregation CombineFn wrappers
[kedin] [SQL] Make AggregationCombineFnAdapter non-AutoValue
[kedin] [SQL] Convert ifs to guard statements in AggregationCombineFnAdapter
[kedin] [SQL] Convert Covariance to accept rows instead of KVs
[kedin] [SQL] Split Args Adapters from AggregationCombineFnAdapter
[kedin] [SQL] Extract MultipleAggregationFn from BeamAggregationTransforms
[kedin] [SQL] Clean up, comment aggregation transforms
------------------------------------------
[...truncated 219.18 MB...]
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (13/16)
(9f700b449ca161f32206cd27847602a6) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (13/16)
(9f700b449ca161f32206cd27847602a6).
[jobmanager-future-thread-12] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (13/16)
(9f700b449ca161f32206cd27847602a6) [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$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
9f700b449ca161f32206cd27847602a6.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) 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@6df99931) (13/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(13/16) (9f700b449ca161f32206cd27847602a6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(13/16) (ee3c9010a60ba2761c6b7dd3fbbb38f8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) 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@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) [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@6df99931)
ee3c9010a60ba2761c6b7dd3fbbb38f8.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (13/16)
(ee3c9010a60ba2761c6b7dd3fbbb38f8) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (10/16)
(c3013622c415c4ca854ca4df5588f46c) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (10/16)
(c3013622c415c4ca854ca4df5588f46c).
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.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$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (10/16)
(c3013622c415c4ca854ca4df5588f46c) [FINISHED]
[jobmanager-future-thread-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
c3013622c415c4ca854ca4df5588f46c.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) 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@6df99931) (10/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(10/16) (c3013622c415c4ca854ca4df5588f46c) 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@6df99931) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(10/16) (bbcfa8ca7cafd6b32b03d189f9a14018) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) 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@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) [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@6df99931)
bbcfa8ca7cafd6b32b03d189f9a14018.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (10/16)
(bbcfa8ca7cafd6b32b03d189f9a14018) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (4/16)
(bfd4751cd41e203257cd14c621289c98) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (4/16)
(bfd4751cd41e203257cd14c621289c98).
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (16/16)
(6175350a8457270619eaef615925f62c) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (15/16)
(343368e335648bb21450aa258cd8d252) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)
(c3cdfc9ee7e70b5a152482489c2fecd0) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (16/16)
(6175350a8457270619eaef615925f62c).
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)
(c3cdfc9ee7e70b5a152482489c2fecd0).
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (15/16)
(343368e335648bb21450aa258cd8d252).
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.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$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (4/16)
(bfd4751cd41e203257cd14c621289c98) [FINISHED]
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)
(c3cdfc9ee7e70b5a152482489c2fecd0) [FINISHED]
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (2/16)
(83987a308ea0ccd282c6e0da8132b896) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
bfd4751cd41e203257cd14c621289c98.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) switched from SCHEDULED to DEPLOYING.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (2/16)
(83987a308ea0ccd282c6e0da8132b896).
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (1/16)
(e60b85b65de43b29f4f8166cae5577d7) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (1/16)
(e60b85b65de43b29f4f8166cae5577d7).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16) (attempt
#0) to localhost
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (16/16)
(6175350a8457270619eaef615925f62c) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
c3cdfc9ee7e70b5a152482489c2fecd0.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (2/16)
(83987a308ea0ccd282c6e0da8132b896) [FINISHED]
[jobmanager-future-thread-12] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)
(62c4f2a471e5e5591abf7cd4612b4513) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)
(62c4f2a471e5e5591abf7cd4612b4513).
[jobmanager-future-thread-1] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16) (attempt
#0) to localhost
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)
(62c4f2a471e5e5591abf7cd4612b4513) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(4/16) (bfd4751cd41e203257cd14c621289c98) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) switched from SCHEDULED to DEPLOYING.
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (15/16)
(343368e335648bb21450aa258cd8d252) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16) (attempt
#0) to localhost
[MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at
PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (1/16)
(e60b85b65de43b29f4f8166cae5577d7) [FINISHED]
[jobmanager-future-thread-15] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(14/16) (c3cdfc9ee7e70b5a152482489c2fecd0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
6175350a8457270619eaef615925f62c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
83987a308ea0ccd282c6e0da8132b896.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(16/16) (6175350a8457270619eaef615925f62c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(4/16) (97d88f524cdfb7562c4d4b82de1bc190) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(2/16) (83987a308ea0ccd282c6e0da8132b896) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
62c4f2a471e5e5591abf7cd4612b4513.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(14/16) (d3a46a66aa6fb6089155ab5ee3e85c88) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(7/16) (62c4f2a471e5e5591abf7cd4612b4513) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) 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@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16) (f53adc0e871970d64e72151d0e25114e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
343368e335648bb21450aa258cd8d252.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(4/16) (97d88f524cdfb7562c4d4b82de1bc190).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(16/16) (1ce7ab2a087d3d5bf465d3ce751b4cb4) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(15/16) (343368e335648bb21450aa258cd8d252) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(2/16) (33b00fa54917ed628224725273ab70fe) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
e60b85b65de43b29f4f8166cae5577d7.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(2/16) (33b00fa54917ed628224725273ab70fe).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(1/16) (e5bf2b779d13e98e6a356f5f50b04cdc) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at PAssert$98/WindowToken/Window.Assign.out/beam:env:docker:v1:0)
(1/16) (e60b85b65de43b29f4f8166cae5577d7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
97d88f524cdfb7562c4d4b82de1bc190.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
d3a46a66aa6fb6089155ab5ee3e85c88.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(7/16) (5b4d6fa8cc779eaabdf1cf42925077d5) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
f53adc0e871970d64e72151d0e25114e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (4/16)
(97d88f524cdfb7562c4d4b82de1bc190) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
1ce7ab2a087d3d5bf465d3ce751b4cb4.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
33b00fa54917ed628224725273ab70fe.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(1/16) (e5bf2b779d13e98e6a356f5f50b04cdc).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
e5bf2b779d13e98e6a356f5f50b04cdc.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (14/16)
(d3a46a66aa6fb6089155ab5ee3e85c88) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(7/16) (5b4d6fa8cc779eaabdf1cf42925077d5).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
(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@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (15/16)
(f53adc0e871970d64e72151d0e25114e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931)
5b4d6fa8cc779eaabdf1cf42925077d5.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (16/16)
(1ce7ab2a087d3d5bf465d3ce751b4cb4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (2/16)
(33b00fa54917ed628224725273ab70fe) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (1/16)
(e5bf2b779d13e98e6a356f5f50b04cdc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6df99931) (7/16)
(5b4d6fa8cc779eaabdf1cf42925077d5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
countingsourcetest0testboundedsourcesplits-jenkins-1023224509-fc83f513
(f518ef7c7c184dcffc869c6c9b9d71cf) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
f518ef7c7c184dcffc869c6c9b9d71cf reached globally terminal state FINISHED.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher0216e28f-80c0-45bf-a145-242cfda686dd.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
countingsourcetest0testboundedsourcesplits-jenkins-1023224509-fc83f513(f518ef7c7c184dcffc869c6c9b9d71cf).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_104.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher0216e28f-80c0-45bf-a145-242cfda686dd.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager f5c5b0c14534fe1689b57e7fa4d881c8 from the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
1a998c4a68075fd5bb0f424a1a9d2161: 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.rpc.akka.AkkaRpcActor - The rpc endpoint
org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet.
Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation
until processing is started.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
f518ef7c7c184dcffc869c6c9b9d71cf with leader id
859fa8df2b0b2a03d6783115ff6a46d7 lost leadership.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-d97ee4d2-1e04-4b46-83b6-11d3d6239c7f
[flink-akka.actor.default-dispatcher-3] 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.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_104.
[ForkJoinPool.commonPool-worker-11] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher0216e28f-80c0-45bf-a145-242cfda686dd.
[ForkJoinPool.commonPool-worker-11] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:36585
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 13009 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1023224509-fc83f513_4227e730-8cf8-4156-a803-7cc23ec86716/MANIFEST
has 179 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1023224509-fc83f513_4227e730-8cf8-4156-a803-7cc23ec86716/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:33191
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:42497
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.transforms.ViewTest > testListSideInput SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker
for ':' Thread 2,5,main]) completed. Took 21 mins 11.228 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> 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 39s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/rz5kihmtlobas
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
