See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/306/display/redirect?page=changes>
Changes:
[valentyn] Add tests for assert_that with cases that cover negative numbers and
[ehudm] Properly clean up docker-compose artifacts.
[robertwb] [BEAM-6008] Propagate errors through portable portable runner.
[robertwb] Enable inherited error checking tests.
[robertwb] [BEAM-5692] Send current state to callback on registration.
------------------------------------------
[...truncated 501.41 MB...]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (3/16)
(3447407d65fb81165b8d7634b9fb2382) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (1/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (10/16)
(3bc1b40031eb9aa5b471676f7bec8c4b) 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@70e1f9f0) (10/16)
(3bc1b40031eb9aa5b471676f7bec8c4b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (10/16)
(3bc1b40031eb9aa5b471676f7bec8c4b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (10/16)
(3bc1b40031eb9aa5b471676f7bec8c4b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (10/16)
(3bc1b40031eb9aa5b471676f7bec8c4b) [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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
0d36c0bc41a9e73278e4065b637b6591.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (29dc7903adb1b0a594ee9d7484e61212) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (29dc7903adb1b0a594ee9d7484e61212).
[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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
991eba3ced537694a36d153db279683a.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (29dc7903adb1b0a594ee9d7484e61212) [FINISHED]
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (0d36c0bc41a9e73278e4065b637b6591) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (991eba3ced537694a36d153db279683a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (7/16).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (1/16)
(49b0c05b2244bf89aa9c2a0b5f95aa6c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (1/16)
(49b0c05b2244bf89aa9c2a0b5f95aa6c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(1/16) (49b0c05b2244bf89aa9c2a0b5f95aa6c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (7/16)
(9f6b5eeb6674a064864c37bc8dc7c053) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (7/16)
(9f6b5eeb6674a064864c37bc8dc7c053) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(7/16) (9f6b5eeb6674a064864c37bc8dc7c053) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (1/16)
(49b0c05b2244bf89aa9c2a0b5f95aa6c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (1/16)
(49b0c05b2244bf89aa9c2a0b5f95aa6c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (4/16)
(e5754688473780f4766c39f66b8855cd) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (7/16)
(9f6b5eeb6674a064864c37bc8dc7c053) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (4/16)
(e5754688473780f4766c39f66b8855cd) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(4/16) (e5754688473780f4766c39f66b8855cd) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (7/16)
(9f6b5eeb6674a064864c37bc8dc7c053) 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@70e1f9f0) (1/16)
(49b0c05b2244bf89aa9c2a0b5f95aa6c) 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@70e1f9f0) (7/16)
(9f6b5eeb6674a064864c37bc8dc7c053) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (4/16)
(e5754688473780f4766c39f66b8855cd) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (1/16)
(49b0c05b2244bf89aa9c2a0b5f95aa6c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(1/16) (49b0c05b2244bf89aa9c2a0b5f95aa6c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (1/16)
(49b0c05b2244bf89aa9c2a0b5f95aa6c) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (4/16)
(e5754688473780f4766c39f66b8855cd) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (7/16)
(9f6b5eeb6674a064864c37bc8dc7c053) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(7/16) (9f6b5eeb6674a064864c37bc8dc7c053).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (7/16)
(9f6b5eeb6674a064864c37bc8dc7c053) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (4/16)
(e5754688473780f4766c39f66b8855cd) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (4/16)
(e5754688473780f4766c39f66b8855cd) 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@70e1f9f0)
8d336469e65f48a94b2bd6b9bd3bad46.
[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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
d85c05c6020625673d4ca50896a7506b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (2/16)
(416c83088b2d58c084effa787dd15781) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (2/16)
(416c83088b2d58c084effa787dd15781) [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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
a1e7e927002ff81d2dfe9ea0af6c9c31.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(2/16) (416c83088b2d58c084effa787dd15781) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(4/16) (e5754688473780f4766c39f66b8855cd).
[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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
f6244060662598ecf49b45169328c032.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (4/16)
(e5754688473780f4766c39f66b8855cd) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (16/16)
(8d336469e65f48a94b2bd6b9bd3bad46) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (2/16)
(416c83088b2d58c084effa787dd15781) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (2/16)
(416c83088b2d58c084effa787dd15781) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (d85c05c6020625673d4ca50896a7506b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (a1e7e927002ff81d2dfe9ea0af6c9c31) 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@70e1f9f0) (9/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (f6244060662598ecf49b45169328c032) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (2/16)
(416c83088b2d58c084effa787dd15781) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (2/16)
(416c83088b2d58c084effa787dd15781) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(2/16) (416c83088b2d58c084effa787dd15781).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (2/16)
(416c83088b2d58c084effa787dd15781) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (9/16)
(14ebea4dcbaaee1d8257c9bbe4940dc9) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (9/16)
(14ebea4dcbaaee1d8257c9bbe4940dc9) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16) (14ebea4dcbaaee1d8257c9bbe4940dc9) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (9/16)
(14ebea4dcbaaee1d8257c9bbe4940dc9) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (9/16)
(14ebea4dcbaaee1d8257c9bbe4940dc9) 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@70e1f9f0) (9/16)
(14ebea4dcbaaee1d8257c9bbe4940dc9) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (9/16)
(14ebea4dcbaaee1d8257c9bbe4940dc9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16) (14ebea4dcbaaee1d8257c9bbe4940dc9).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (9/16)
(14ebea4dcbaaee1d8257c9bbe4940dc9) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(11/16) (e3b3270dfebba68a08b61edd4cf805a8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8) [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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
aa8bb20d2d772b8ee5afc48342239c2f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16) (aa8bb20d2d772b8ee5afc48342239c2f) 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@70e1f9f0) (13/16).
[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@70e1f9f0)
3447407d65fb81165b8d7634b9fb2382.
[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@70e1f9f0)
3bc1b40031eb9aa5b471676f7bec8c4b.
[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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
29dc7903adb1b0a594ee9d7484e61212.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (3/16)
(3447407d65fb81165b8d7634b9fb2382) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (6/16)
(5976e928a20a86ba0c9bb123417ad151) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(13/16) (68a7373fad7bc76ad38c050b95352d5d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (6/16)
(5976e928a20a86ba0c9bb123417ad151) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16) (5976e928a20a86ba0c9bb123417ad151) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (10/16)
(3bc1b40031eb9aa5b471676f7bec8c4b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d) 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@70e1f9f0) (14/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (29dc7903adb1b0a594ee9d7484e61212) 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@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (6/16)
(5976e928a20a86ba0c9bb123417ad151) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (6/16)
(5976e928a20a86ba0c9bb123417ad151) 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@70e1f9f0) (6/16)
(5976e928a20a86ba0c9bb123417ad151) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (6/16)
(5976e928a20a86ba0c9bb123417ad151) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16) (5976e928a20a86ba0c9bb123417ad151).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (6/16)
(5976e928a20a86ba0c9bb123417ad151) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d) [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@70e1f9f0)
49b0c05b2244bf89aa9c2a0b5f95aa6c.
[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@70e1f9f0)
9f6b5eeb6674a064864c37bc8dc7c053.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) 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 DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
e5754688473780f4766c39f66b8855cd.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(14/16) (a6115198c09b845795ae990daea138cd) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (1/16)
(49b0c05b2244bf89aa9c2a0b5f95aa6c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
416c83088b2d58c084effa787dd15781.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
14ebea4dcbaaee1d8257c9bbe4940dc9.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
e3b3270dfebba68a08b61edd4cf805a8.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (7/16)
(9f6b5eeb6674a064864c37bc8dc7c053) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
5976e928a20a86ba0c9bb123417ad151.
[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@70e1f9f0)
68a7373fad7bc76ad38c050b95352d5d.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (4/16)
(e5754688473780f4766c39f66b8855cd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (2/16)
(416c83088b2d58c084effa787dd15781) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (9/16)
(14ebea4dcbaaee1d8257c9bbe4940dc9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (11/16)
(e3b3270dfebba68a08b61edd4cf805a8) 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@70e1f9f0)
a6115198c09b845795ae990daea138cd.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (6/16)
(5976e928a20a86ba0c9bb123417ad151) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (13/16)
(68a7373fad7bc76ad38c050b95352d5d) 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@70e1f9f0) (14/16)
(a6115198c09b845795ae990daea138cd) switched from RUNNING to FINISHED.
[grpc-default-executor-145] WARN
org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not
supported in the current execution environment.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(8/16) (c86a57a6b215e4c8c78d4ce34d480117) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(8/16) (c86a57a6b215e4c8c78d4ce34d480117).
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(8/16) (c86a57a6b215e4c8c78d4ce34d480117) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
c86a57a6b215e4c8c78d4ce34d480117.
[jobmanager-future-thread-15] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (680f86ea849d4ca29ea35f811d997e4f) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (680f86ea849d4ca29ea35f811d997e4f).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(8/16) (c86a57a6b215e4c8c78d4ce34d480117) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (680f86ea849d4ca29ea35f811d997e4f) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
680f86ea849d4ca29ea35f811d997e4f.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (680f86ea849d4ca29ea35f811d997e4f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) 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@70e1f9f0) (8/16) (attempt
#0) to localhost
[jobmanager-future-thread-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) 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@70e1f9f0) (5/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (8/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(8/16) (c1c7dee711eaeac0a027c13ed0044f1a) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(5/16) (827a47d41aacda54b01cb19c74f893a8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) 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@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) 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@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(8/16) (c1c7dee711eaeac0a027c13ed0044f1a).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) [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@70e1f9f0)
c1c7dee711eaeac0a027c13ed0044f1a.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (8/16)
(c1c7dee711eaeac0a027c13ed0044f1a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(5/16) (827a47d41aacda54b01cb19c74f893a8).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0)
(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@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) [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@70e1f9f0)
827a47d41aacda54b01cb19c74f893a8.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@70e1f9f0) (5/16)
(827a47d41aacda54b01cb19c74f893a8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1113200841-f2454326
(2074cc4e3d219263c86a5ce0380616cf) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
2074cc4e3d219263c86a5ce0380616cf 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.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1113200841-f2454326(2074cc4e3d219263c86a5ce0380616cf).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher37c17786-d14d-4a66-a9b3-aaf0ddd25cc2.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher37c17786-d14d-4a66-a9b3-aaf0ddd25cc2.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
3a7c438555157aed66c0fcea59894b10: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
2074cc4e3d219263c86a5ce0380616cf with leader id
b5f1b15b2f759ac8f97323a686d54440 lost leadership.
[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-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-8c82453e-c669-4d4a-b588-99c2b3c2f375
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[ForkJoinPool.commonPool-worker-13] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher37c17786-d14d-4a66-a9b3-aaf0ddd25cc2.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:35163
[flink-akka.actor.default-dispatcher-3] 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 13719 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1113200841-f2454326_32125479-7ed5-4b1f-8028-020172c9de65/MANIFEST
has 185 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1113200841-f2454326_32125479-7ed5-4b1f-8028-020172c9de65/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:38405
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:35853
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
187 tests completed, 1 failed, 1 skipped
Finished generating test XML results (3.008 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunner>
Generating HTML test report...
Finished generating test html results (3.5 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker
for ':' Thread 4,5,main]) completed. Took 38 mins 30.563 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 41m 25s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/thf4ls75qwqss
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org
