See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/53/display/redirect?page=changes>
Changes:
[gleb] [SQL] Add support for TableMacro UDF
------------------------------------------
[...truncated 352.49 MB...]
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) switched from SCHEDULED to DEPLOYING.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16) (e120f9c0753df9069a6e6ebeb631892b) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (6/16).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (9/16)
(f7dcee62060c5f00580ac8f18357acd6) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (9/16)
(f7dcee62060c5f00580ac8f18357acd6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(9/16) (f7dcee62060c5f00580ac8f18357acd6) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (87dd0d993a4f2c0962b27c54260bd609) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (87dd0d993a4f2c0962b27c54260bd609).
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (87dd0d993a4f2c0962b27c54260bd609) [FINISHED]
[jobmanager-future-thread-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (9/16)
(f7dcee62060c5f00580ac8f18357acd6) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (9/16)
(f7dcee62060c5f00580ac8f18357acd6) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (9/16)
(f7dcee62060c5f00580ac8f18357acd6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (9/16)
(f7dcee62060c5f00580ac8f18357acd6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(9/16) (f7dcee62060c5f00580ac8f18357acd6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (9/16)
(f7dcee62060c5f00580ac8f18357acd6) [FINISHED]
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (f7fe05ee4333347c832139ca4862cecc) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (f7fe05ee4333347c832139ca4862cecc).
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (f7fe05ee4333347c832139ca4862cecc) [FINISHED]
[jobmanager-future-thread-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(12/16) (c7d95025a9514301aa3ba01e770092cd).
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(12/16) (c7d95025a9514301aa3ba01e770092cd) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (6/16)
(c7e6fdcc342e9f7a64faf77533d82ea0) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (6/16)
(c7e6fdcc342e9f7a64faf77533d82ea0) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(6/16) (c7e6fdcc342e9f7a64faf77533d82ea0) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (6/16)
(c7e6fdcc342e9f7a64faf77533d82ea0) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (6/16)
(c7e6fdcc342e9f7a64faf77533d82ea0) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (16/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (6/16)
(c7e6fdcc342e9f7a64faf77533d82ea0) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (97788437bd479cbe945adf7653102b97) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (6/16)
(c7e6fdcc342e9f7a64faf77533d82ea0) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (97788437bd479cbe945adf7653102b97).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(6/16) (c7e6fdcc342e9f7a64faf77533d82ea0).
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (97788437bd479cbe945adf7653102b97) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (6/16)
(c7e6fdcc342e9f7a64faf77533d82ea0) [FINISHED]
[jobmanager-future-thread-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) switched from CREATED to SCHEDULED.
[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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
98cb5e1eded38c4b9b8d1b67e626f095.
[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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
565ea67159b526aff7c51f349250e7d1.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (5/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (98cb5e1eded38c4b9b8d1b67e626f095) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (565ea67159b526aff7c51f349250e7d1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(16/16) (03b05e51cfa2328384da157e0a6cc08d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d) 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@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(15/16) (391aa36c92e5766246017709b409d53e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (4/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
f9306c714a5fda236e7e5d4130418781.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (4/16)
(46040b7470f33f35e48db7f84b71bac3) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (4/16)
(46040b7470f33f35e48db7f84b71bac3) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(4/16) (46040b7470f33f35e48db7f84b71bac3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
bbbb767eab202c50a91002a725e05af8.
[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@6ea18b9d)
56f3793c8e091eb5f6cb5295b37d4fce.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e) [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@6ea18b9d)
302dcf3d876cea486c7a8159a3a648a7.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (1/16)
(f9306c714a5fda236e7e5d4130418781) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (4/16)
(46040b7470f33f35e48db7f84b71bac3) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (4/16)
(46040b7470f33f35e48db7f84b71bac3) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16) (bbbb767eab202c50a91002a725e05af8) 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@6ea18b9d) (8/16)
(56f3793c8e091eb5f6cb5295b37d4fce) 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@6ea18b9d) (3/16)
(302dcf3d876cea486c7a8159a3a648a7) 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@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (13/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (4/16)
(46040b7470f33f35e48db7f84b71bac3) 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@6ea18b9d)
a92ae2e303a724c8b36be60f4416cd66.
[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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
e120f9c0753df9069a6e6ebeb631892b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (4/16)
(46040b7470f33f35e48db7f84b71bac3) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(4/16) (46040b7470f33f35e48db7f84b71bac3).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(13/16) (afb9b6b7fbe67373b54d6e507e64528b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (4/16)
(46040b7470f33f35e48db7f84b71bac3) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (7/16)
(a92ae2e303a724c8b36be60f4416cd66) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16) (e120f9c0753df9069a6e6ebeb631892b) 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@6ea18b9d) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(10/16) (45b83a7e59f0aa6836e55280a50a9dea) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
87dd0d993a4f2c0962b27c54260bd609.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16) (9396227a4d435239fd4a61b2c57d0158) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (87dd0d993a4f2c0962b27c54260bd609) 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@6ea18b9d) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) 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@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) 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@6ea18b9d)
f7dcee62060c5f00580ac8f18357acd6.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
f7fe05ee4333347c832139ca4862cecc.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(11/16) (ced95f56ef4dbe962cecd02aa820f166) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
c7d95025a9514301aa3ba01e770092cd.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (9/16)
(f7dcee62060c5f00580ac8f18357acd6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (f7fe05ee4333347c832139ca4862cecc) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) [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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
97788437bd479cbe945adf7653102b97.
[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@6ea18b9d)
c7e6fdcc342e9f7a64faf77533d82ea0.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(12/16) (c7d95025a9514301aa3ba01e770092cd) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(14/16) (930508cfa5bbe8732f8a227bacf79fc0) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (97788437bd479cbe945adf7653102b97) 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@6ea18b9d) (5/16).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (6/16)
(c7e6fdcc342e9f7a64faf77533d82ea0) 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@6ea18b9d)
03b05e51cfa2328384da157e0a6cc08d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(5/16) (3b7d6f5bdb70806b68abd78137874ca6) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) [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@6ea18b9d)
391aa36c92e5766246017709b409d53e.
[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@6ea18b9d)
46040b7470f33f35e48db7f84b71bac3.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) 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@6ea18b9d) (16/16)
(03b05e51cfa2328384da157e0a6cc08d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) [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@6ea18b9d)
45b83a7e59f0aa6836e55280a50a9dea.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (15/16)
(391aa36c92e5766246017709b409d53e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) 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@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) 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@6ea18b9d)
afb9b6b7fbe67373b54d6e507e64528b.
[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@6ea18b9d)
9396227a4d435239fd4a61b2c57d0158.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (4/16)
(46040b7470f33f35e48db7f84b71bac3) 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@6ea18b9d)
ced95f56ef4dbe962cecd02aa820f166.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (10/16)
(45b83a7e59f0aa6836e55280a50a9dea) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) 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@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(5/16) (3b7d6f5bdb70806b68abd78137874ca6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
(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@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
3b7d6f5bdb70806b68abd78137874ca6.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (13/16)
(afb9b6b7fbe67373b54d6e507e64528b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d)
930508cfa5bbe8732f8a227bacf79fc0.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@6ea18b9d) (12/16)
(9396227a4d435239fd4a61b2c57d0158) 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@6ea18b9d) (11/16)
(ced95f56ef4dbe962cecd02aa820f166) 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@6ea18b9d) (5/16)
(3b7d6f5bdb70806b68abd78137874ca6) 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@6ea18b9d) (14/16)
(930508cfa5bbe8732f8a227bacf79fc0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1130001858-24a1024f
(58487cf62655de236747d6e6a1023dcb) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
58487cf62655de236747d6e6a1023dcb 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-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1130001858-24a1024f(58487cf62655de236747d6e6a1023dcb).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherd545594f-5cf5-4308-9207-4b365b90c4f0.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherd545594f-5cf5-4308-9207-4b365b90c4f0.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
b8a791aaab8a6c54e2e7c49e2c6ac89f: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcActor - The rpc endpoint
org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet.
Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation
until processing is started.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
58487cf62655de236747d6e6a1023dcb with leader id
938fdd0b58dc8154207624365b0d41d1 lost leadership.
[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-714c0c0c-c8ca-4e0a-b1c2-d839d39a030a
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherd545594f-5cf5-4308-9207-4b365b90c4f0.
[ForkJoinPool.commonPool-worker-15] 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_260.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:46837
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 11169 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1130001858-24a1024f_314b389a-864d-4a63-9824-a3c2821236fb/MANIFEST
has 186 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1130001858-24a1024f_314b389a-864d-4a63-9824-a3c2821236fb/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:36463
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:39087
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testBagStateSideInput
SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task
worker for ':' Thread 7,5,main]) completed. Took 46 mins 55.486 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 137
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 50m 7s
75 actionable tasks: 65 executed, 9 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/oh4pdynpah7xo
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
