See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/124/display/redirect>
------------------------------------------
[...truncated 195.39 MB...]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (3/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (8/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (6/16) (cf5df0c29cabcd5c0bfb171d64c4fcc3) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (6/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (12/16) (d647d41cee0808c0c15dbf52be34c14d) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (12/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16)
(65a1bdbc515b9134508259e0c15095e7) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16)
(873816acb5f9955886ed59c766d23218) [FINISHED]
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16)
(aa1f4eab299dd101f49a8a222fb9e5c9) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (3/16).
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16)
(78d6064ef17d31d02323c38511263973) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (3/16)
(78d6064ef17d31d02323c38511263973) [DEPLOYING]
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (3/16) (78d6064ef17d31d02323c38511263973) [DEPLOYING].
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (3/16) (78d6064ef17d31d02323c38511263973)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (8/16).
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (7/16)
(a7eeb703fc961e8a98dc1a288fd3cfad) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(7/16) (a7eeb703fc961e8a98dc1a288fd3cfad).
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16)
(78d6064ef17d31d02323c38511263973) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (7/16) (9e64593b1e714546b42a6aece9bcaa2a) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (3/16) (78d6064ef17d31d02323c38511263973) switched from
DEPLOYING to RUNNING.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (7/16)
(a7eeb703fc961e8a98dc1a288fd3cfad) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (7/16) (9e64593b1e714546b42a6aece9bcaa2a) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (7/16) (attempt #0) to localhost
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16)
(e524f2d29ecb1ff40340a36b63489b98) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16)
(78d6064ef17d31d02323c38511263973) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (3/16) (78d6064ef17d31d02323c38511263973).
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (8/16)
(e524f2d29ecb1ff40340a36b63489b98) [DEPLOYING]
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (8/16) (e524f2d29ecb1ff40340a36b63489b98) [DEPLOYING].
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (3/16)
(78d6064ef17d31d02323c38511263973) [FINISHED]
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (8/16) (e524f2d29ecb1ff40340a36b63489b98)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (6/16).
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16)
(e524f2d29ecb1ff40340a36b63489b98) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (8/16) (e524f2d29ecb1ff40340a36b63489b98) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16)
(e524f2d29ecb1ff40340a36b63489b98) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (8/16) (e524f2d29ecb1ff40340a36b63489b98).
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (8/16)
(e524f2d29ecb1ff40340a36b63489b98) [FINISHED]
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (2/16)
(746b7c7c99eb24057ad905f37610094d) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(2/16) (746b7c7c99eb24057ad905f37610094d).
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (34debc8da392aab816f6113f2494f04e) switched from
CREATED to SCHEDULED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (2/16)
(746b7c7c99eb24057ad905f37610094d) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (34debc8da392aab816f6113f2494f04e) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (2/16) (attempt #0) to localhost
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16)
(cf5df0c29cabcd5c0bfb171d64c4fcc3) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (6/16)
(cf5df0c29cabcd5c0bfb171d64c4fcc3) [DEPLOYING]
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (6/16) (cf5df0c29cabcd5c0bfb171d64c4fcc3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (12/16).
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (6/16) (cf5df0c29cabcd5c0bfb171d64c4fcc3)
[DEPLOYING].
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16)
(cf5df0c29cabcd5c0bfb171d64c4fcc3) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
873816acb5f9955886ed59c766d23218.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (6/16) (cf5df0c29cabcd5c0bfb171d64c4fcc3) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16)
(d647d41cee0808c0c15dbf52be34c14d) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (12/16)
(d647d41cee0808c0c15dbf52be34c14d) [DEPLOYING]
[DataSink (DiscardingOutput) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (12/16) (d647d41cee0808c0c15dbf52be34c14d) [DEPLOYING].
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16)
(cf5df0c29cabcd5c0bfb171d64c4fcc3) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (6/16) (cf5df0c29cabcd5c0bfb171d64c4fcc3).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16)
(873816acb5f9955886ed59c766d23218) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (6/16)
(cf5df0c29cabcd5c0bfb171d64c4fcc3) [FINISHED]
[DataSink (DiscardingOutput) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (12/16) (d647d41cee0808c0c15dbf52be34c14d)
[DEPLOYING].
[DataSink (DiscardingOutput) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16)
(d647d41cee0808c0c15dbf52be34c14d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (12/16) (d647d41cee0808c0c15dbf52be34c14d) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
aa1f4eab299dd101f49a8a222fb9e5c9.
[DataSink (DiscardingOutput) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16)
(d647d41cee0808c0c15dbf52be34c14d) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (12/16) (d647d41cee0808c0c15dbf52be34c14d).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
a7eeb703fc961e8a98dc1a288fd3cfad.
[DataSink (DiscardingOutput) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (12/16)
(d647d41cee0808c0c15dbf52be34c14d) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16)
(aa1f4eab299dd101f49a8a222fb9e5c9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (7/16)
(a7eeb703fc961e8a98dc1a288fd3cfad) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (7/16).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 78d6064ef17d31d02323c38511263973.
[DataSink (DiscardingOutput) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16)
(9e64593b1e714546b42a6aece9bcaa2a) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (7/16)
(9e64593b1e714546b42a6aece9bcaa2a) [DEPLOYING]
[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
(DiscardingOutput) e524f2d29ecb1ff40340a36b63489b98.
[DataSink (DiscardingOutput) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (7/16) (9e64593b1e714546b42a6aece9bcaa2a) [DEPLOYING].
[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 MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
746b7c7c99eb24057ad905f37610094d.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (3/16) (78d6064ef17d31d02323c38511263973) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (7/16) (9e64593b1e714546b42a6aece9bcaa2a)
[DEPLOYING].
[DataSink (DiscardingOutput) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16)
(9e64593b1e714546b42a6aece9bcaa2a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (8/16) (e524f2d29ecb1ff40340a36b63489b98) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16)
(9e64593b1e714546b42a6aece9bcaa2a) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (7/16) (9e64593b1e714546b42a6aece9bcaa2a).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (2/16)
(746b7c7c99eb24057ad905f37610094d) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (7/16)
(9e64593b1e714546b42a6aece9bcaa2a) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (2/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (7/16) (9e64593b1e714546b42a6aece9bcaa2a) switched from
DEPLOYING to RUNNING.
[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
(DiscardingOutput) cf5df0c29cabcd5c0bfb171d64c4fcc3.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16)
(34debc8da392aab816f6113f2494f04e) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (2/16)
(34debc8da392aab816f6113f2494f04e) [DEPLOYING]
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (2/16) (34debc8da392aab816f6113f2494f04e) [DEPLOYING].
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (15/16)
(88ee4026ab0b40c3ff87eeac1a89f1fb) 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
(DiscardingOutput) d647d41cee0808c0c15dbf52be34c14d.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks,
VerifyAssertions}) (15/16) (88ee4026ab0b40c3ff87eeac1a89f1fb).
[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
(DiscardingOutput) 9e64593b1e714546b42a6aece9bcaa2a.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (15/16)
(88ee4026ab0b40c3ff87eeac1a89f1fb) [FINISHED]
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (2/16) (34debc8da392aab816f6113f2494f04e)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (6/16) (cf5df0c29cabcd5c0bfb171d64c4fcc3) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
88ee4026ab0b40c3ff87eeac1a89f1fb.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16)
(34debc8da392aab816f6113f2494f04e) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (8d5070d78eac4782ad45a263abbb1ab0) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (12/16) (d647d41cee0808c0c15dbf52be34c14d) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16)
(34debc8da392aab816f6113f2494f04e) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (2/16) (34debc8da392aab816f6113f2494f04e).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (8d5070d78eac4782ad45a263abbb1ab0) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (15/16) (attempt #0) to localhost
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (2/16)
(34debc8da392aab816f6113f2494f04e) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 34debc8da392aab816f6113f2494f04e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (7/16) (9e64593b1e714546b42a6aece9bcaa2a) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (34debc8da392aab816f6113f2494f04e) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (15/16)
(88ee4026ab0b40c3ff87eeac1a89f1fb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (34debc8da392aab816f6113f2494f04e) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (15/16).
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16)
(8d5070d78eac4782ad45a263abbb1ab0) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (15/16)
(8d5070d78eac4782ad45a263abbb1ab0) [DEPLOYING]
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (15/16) (8d5070d78eac4782ad45a263abbb1ab0) [DEPLOYING].
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (15/16) (8d5070d78eac4782ad45a263abbb1ab0)
[DEPLOYING].
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16)
(8d5070d78eac4782ad45a263abbb1ab0) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (8d5070d78eac4782ad45a263abbb1ab0) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16)
(8d5070d78eac4782ad45a263abbb1ab0) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (15/16) (8d5070d78eac4782ad45a263abbb1ab0).
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (15/16)
(8d5070d78eac4782ad45a263abbb1ab0) [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
(DiscardingOutput) 8d5070d78eac4782ad45a263abbb1ab0.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (8d5070d78eac4782ad45a263abbb1ab0) switched from
RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16)
(816ed1892fbfefc06a31d112d4be29f6) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks,
VerifyAssertions}) (11/16) (816ed1892fbfefc06a31d112d4be29f6).
[jobmanager-future-thread-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (11/16) (f1dbc118bfe4183479d3a8cfd36bce0e) switched from
CREATED to SCHEDULED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16)
(816ed1892fbfefc06a31d112d4be29f6) [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 MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
816ed1892fbfefc06a31d112d4be29f6.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (11/16) (f1dbc118bfe4183479d3a8cfd36bce0e) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (11/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16)
(816ed1892fbfefc06a31d112d4be29f6) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16)
(b118ffee941edfa4aa9ed9ff6b3767c9) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks,
VerifyAssertions}) (13/16) (b118ffee941edfa4aa9ed9ff6b3767c9).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (11/16).
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16)
(b118ffee941edfa4aa9ed9ff6b3767c9) [FINISHED]
[jobmanager-future-thread-15] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (d39f6169e82635b63c6ed2978e1837e0) switched from
CREATED to SCHEDULED.
[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 MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
b118ffee941edfa4aa9ed9ff6b3767c9.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (d39f6169e82635b63c6ed2978e1837e0) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (13/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16)
(b118ffee941edfa4aa9ed9ff6b3767c9) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16)
(f1dbc118bfe4183479d3a8cfd36bce0e) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (11/16)
(f1dbc118bfe4183479d3a8cfd36bce0e) [DEPLOYING]
[DataSink (DiscardingOutput) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (11/16) (f1dbc118bfe4183479d3a8cfd36bce0e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (13/16).
[DataSink (DiscardingOutput) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (11/16) (f1dbc118bfe4183479d3a8cfd36bce0e)
[DEPLOYING].
[DataSink (DiscardingOutput) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16)
(f1dbc118bfe4183479d3a8cfd36bce0e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (11/16) (f1dbc118bfe4183479d3a8cfd36bce0e) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16)
(d39f6169e82635b63c6ed2978e1837e0) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (13/16)
(d39f6169e82635b63c6ed2978e1837e0) [DEPLOYING]
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (13/16) (d39f6169e82635b63c6ed2978e1837e0) [DEPLOYING].
[DataSink (DiscardingOutput) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16)
(f1dbc118bfe4183479d3a8cfd36bce0e) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (11/16) (f1dbc118bfe4183479d3a8cfd36bce0e).
[DataSink (DiscardingOutput) (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (11/16)
(f1dbc118bfe4183479d3a8cfd36bce0e) [FINISHED]
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (13/16) (d39f6169e82635b63c6ed2978e1837e0)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) f1dbc118bfe4183479d3a8cfd36bce0e.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16)
(d39f6169e82635b63c6ed2978e1837e0) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (d39f6169e82635b63c6ed2978e1837e0) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16)
(d39f6169e82635b63c6ed2978e1837e0) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (13/16) (d39f6169e82635b63c6ed2978e1837e0).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (11/16) (f1dbc118bfe4183479d3a8cfd36bce0e) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (13/16)
(d39f6169e82635b63c6ed2978e1837e0) [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
(DiscardingOutput) d39f6169e82635b63c6ed2978e1837e0.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (d39f6169e82635b63c6ed2978e1837e0) switched from
RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (10/16)
(2c6811d0501569176b3dbc6d123ee492) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks,
VerifyAssertions}) (10/16) (2c6811d0501569176b3dbc6d123ee492).
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (10/16)
(2c6811d0501569176b3dbc6d123ee492) [FINISHED]
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (10/16) (d9d979a16ead00c6738cf8ea9355339b) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (10/16) (d9d979a16ead00c6738cf8ea9355339b) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
2c6811d0501569176b3dbc6d123ee492.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (10/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (10/16)
(2c6811d0501569176b3dbc6d123ee492) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (10/16).
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16)
(d9d979a16ead00c6738cf8ea9355339b) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (10/16)
(d9d979a16ead00c6738cf8ea9355339b) [DEPLOYING]
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (10/16) (d9d979a16ead00c6738cf8ea9355339b) [DEPLOYING].
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (10/16) (d9d979a16ead00c6738cf8ea9355339b)
[DEPLOYING].
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16)
(d9d979a16ead00c6738cf8ea9355339b) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16)
(d9d979a16ead00c6738cf8ea9355339b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (10/16) (d9d979a16ead00c6738cf8ea9355339b) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (10/16) (d9d979a16ead00c6738cf8ea9355339b).
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (10/16)
(d9d979a16ead00c6738cf8ea9355339b) [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
(DiscardingOutput) d9d979a16ead00c6738cf8ea9355339b.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (10/16) (d9d979a16ead00c6738cf8ea9355339b) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
countingsourcetest0testboundedsourcesplits-jenkins-1208002616-837707f5
(362634f262cf2f305c91cffedefb982d) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
362634f262cf2f305c91cffedefb982d 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.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
countingsourcetest0testboundedsourcesplits-jenkins-1208002616-837707f5(362634f262cf2f305c91cffedefb982d).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher7b5d3288-b42a-4b68-95e0-c26ae5f4c103.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher7b5d3288-b42a-4b68-95e0-c26ae5f4c103.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
e1b9727f12d7a4a3a92c3c30f2de3a72: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-b46928e6-5bc1-4466-a014-ba7ff6ca477a
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-2] 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-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
362634f262cf2f305c91cffedefb982d with leader id
8f6ba07cc4369ffa0a236bba6d5f4b99 lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_102.
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher7b5d3288-b42a-4b68-95e0-c26ae5f4c103.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:33423
[flink-akka.actor.default-dispatcher-2] 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 12010 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1208002616-837707f5_3c5b6caa-a8ea-4552-b18b-399b55f15563/MANIFEST
has 186 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1208002616-837707f5_3c5b6caa-a8ea-4552-b18b-399b55f15563/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:33531
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:45407
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.transforms.ParDoTest$TimerTests >
testAbsoluteProcessingTimeTimerRejected SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task
worker for ':' Thread 6,5,main]) completed. Took 23 mins 16.671 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 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 26m 27s
75 actionable tasks: 64 executed, 10 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/jzt34tcjvdk34
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]
