See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/127/display/redirect>
------------------------------------------
[...truncated 187.24 MB...]
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (13/16)
(f91a13497035c5a53b019e4cb13d07bb) [FINISHED]
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16)
(5dd63848a7e28bf053ae111eedcad9b4) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (2/16) (5dd63848a7e28bf053ae111eedcad9b4).
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (2/16)
(5dd63848a7e28bf053ae111eedcad9b4) [FINISHED]
[DataSink (DiscardingOutput) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16)
(011f841bd4111b6bbc059a571f0978ab) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (9/16)
(011f841bd4111b6bbc059a571f0978ab) [DEPLOYING]
[DataSink (DiscardingOutput) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (9/16) (011f841bd4111b6bbc059a571f0978ab) [DEPLOYING].
[DataSink (DiscardingOutput) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (9/16) (011f841bd4111b6bbc059a571f0978ab)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (4/16).
[DataSink (DiscardingOutput) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16)
(011f841bd4111b6bbc059a571f0978ab) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (9/16) (011f841bd4111b6bbc059a571f0978ab) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16)
(011f841bd4111b6bbc059a571f0978ab) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
6144da130c4ec1b6c8f8d4946eb54c5e.
[DataSink (DiscardingOutput) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (9/16) (011f841bd4111b6bbc059a571f0978ab).
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16)
(785960b63dee9900f6f2b38fb8719047) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (4/16)
(785960b63dee9900f6f2b38fb8719047) [DEPLOYING]
[DataSink (DiscardingOutput) (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (9/16)
(011f841bd4111b6bbc059a571f0978ab) [FINISHED]
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (4/16) (785960b63dee9900f6f2b38fb8719047) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
50390053124ddf41cc739ae5e7aedb76.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (4/16) (785960b63dee9900f6f2b38fb8719047)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (4/16)
(6144da130c4ec1b6c8f8d4946eb54c5e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (16/16)
(50390053124ddf41cc739ae5e7aedb76) 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)
(95bf742a7650157625b17d322fdee6ed) 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) (95bf742a7650157625b17d322fdee6ed).
[jobmanager-future-thread-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (10/16) (cc08f7e45020354d4da913a187981f23) switched from
CREATED to SCHEDULED.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16)
(785960b63dee9900f6f2b38fb8719047) switched from DEPLOYING to RUNNING.
[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)
(95bf742a7650157625b17d322fdee6ed) [FINISHED]
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16)
(a5d7421f20d939d0037009dc2e6a3fed) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (4/16) (785960b63dee9900f6f2b38fb8719047) switched from
DEPLOYING to RUNNING.
[jobmanager-future-thread-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/16) (7181c47f7675de3285154029baceb808) switched from
CREATED to SCHEDULED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(1/16) (a5d7421f20d939d0037009dc2e6a3fed).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (16/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (10/16) (cc08f7e45020354d4da913a187981f23) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (10/16) (attempt #0) to localhost
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16)
(785960b63dee9900f6f2b38fb8719047) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (4/16) (785960b63dee9900f6f2b38fb8719047).
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16)
(a5d7421f20d939d0037009dc2e6a3fed) [FINISHED]
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (4/16)
(785960b63dee9900f6f2b38fb8719047) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/16) (7181c47f7675de3285154029baceb808) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (1/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
91528dc35d67ef918168d1cc357f128c.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16)
(f8c75758a75f77ad697c6ab4503a13ba) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(3/16) (f8c75758a75f77ad697c6ab4503a13ba).
[jobmanager-future-thread-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (3/16) (b5bd3d8ad4c4e382366aba3556ba1153) switched from
CREATED to SCHEDULED.
[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)
(f8c75758a75f77ad697c6ab4503a13ba) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (14/16)
(91528dc35d67ef918168d1cc357f128c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (3/16) (b5bd3d8ad4c4e382366aba3556ba1153) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (3/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (14/16).
[DataSink (DiscardingOutput) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16)
(d1192f97f0663329553b687dc76da951) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (16/16)
(d1192f97f0663329553b687dc76da951) [DEPLOYING]
[DataSink (DiscardingOutput) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (16/16) (d1192f97f0663329553b687dc76da951) [DEPLOYING].
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16)
(8e241c8384b74368a34a2c1b516f80e0) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(6/16) (8e241c8384b74368a34a2c1b516f80e0).
[DataSink (DiscardingOutput) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (16/16) (d1192f97f0663329553b687dc76da951)
[DEPLOYING].
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (6/16) (71bbfd26e155faa41597eabcfe582767) switched from
CREATED to SCHEDULED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16)
(8e241c8384b74368a34a2c1b516f80e0) [FINISHED]
[DataSink (DiscardingOutput) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16)
(d1192f97f0663329553b687dc76da951) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (16/16) (d1192f97f0663329553b687dc76da951) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) e5e61d060763c1d59aa148d7181e6495.
[DataSink (DiscardingOutput) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16)
(d1192f97f0663329553b687dc76da951) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (6/16) (71bbfd26e155faa41597eabcfe582767) switched from
SCHEDULED to DEPLOYING.
[DataSink (DiscardingOutput) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (16/16) (d1192f97f0663329553b687dc76da951).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (6/16) (attempt #0) to localhost
[DataSink (DiscardingOutput) (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (16/16)
(d1192f97f0663329553b687dc76da951) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
d6baf0095fa01b357dd3de2c5897ce09.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (11/16) (e5e61d060763c1d59aa148d7181e6495) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (5/16)
(d6baf0095fa01b357dd3de2c5897ce09) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (5/16).
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16)
(0d8b6e6cbb63efd2dc177c02dd2da579) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (14/16)
(0d8b6e6cbb63efd2dc177c02dd2da579) [DEPLOYING]
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (14/16) (0d8b6e6cbb63efd2dc177c02dd2da579) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (14/16) (0d8b6e6cbb63efd2dc177c02dd2da579)
[DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16)
(0d8b6e6cbb63efd2dc177c02dd2da579) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (14/16) (0d8b6e6cbb63efd2dc177c02dd2da579) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16)
(0d8b6e6cbb63efd2dc177c02dd2da579) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (14/16) (0d8b6e6cbb63efd2dc177c02dd2da579).
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (14/16)
(0d8b6e6cbb63efd2dc177c02dd2da579) [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) a893c72a57bf8618f64db1834c49cb78.
[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) d715d6db38cf0033f73a1eb76ac6d94a.
[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) cae7b86c1cf11d0a3b5fa0272880d0a3.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (7/16) (a893c72a57bf8618f64db1834c49cb78) 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 DataSink
(DiscardingOutput) 5dd63848a7e28bf053ae111eedcad9b4.
[DataSink (DiscardingOutput) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16)
(23d7e4e34564360d65ecfd42f30fc29a) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (5/16)
(23d7e4e34564360d65ecfd42f30fc29a) [DEPLOYING]
[DataSink (DiscardingOutput) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (5/16) (23d7e4e34564360d65ecfd42f30fc29a) [DEPLOYING].
[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) f91a13497035c5a53b019e4cb13d07bb.
[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) 011f841bd4111b6bbc059a571f0978ab.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (d715d6db38cf0033f73a1eb76ac6d94a) 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})
95bf742a7650157625b17d322fdee6ed.
[DataSink (DiscardingOutput) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (5/16) (23d7e4e34564360d65ecfd42f30fc29a)
[DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (12/16) (cae7b86c1cf11d0a3b5fa0272880d0a3) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16)
(23d7e4e34564360d65ecfd42f30fc29a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (5dd63848a7e28bf053ae111eedcad9b4) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16)
(23d7e4e34564360d65ecfd42f30fc29a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (f91a13497035c5a53b019e4cb13d07bb) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (5/16) (23d7e4e34564360d65ecfd42f30fc29a).
[DataSink (DiscardingOutput) (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (5/16)
(23d7e4e34564360d65ecfd42f30fc29a) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (9/16) (011f841bd4111b6bbc059a571f0978ab) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (10/16)
(95bf742a7650157625b17d322fdee6ed) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (5/16) (23d7e4e34564360d65ecfd42f30fc29a) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (10/16).
[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})
a5d7421f20d939d0037009dc2e6a3fed.
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16)
(cc08f7e45020354d4da913a187981f23) 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)
(cc08f7e45020354d4da913a187981f23) [DEPLOYING]
[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) 785960b63dee9900f6f2b38fb8719047.
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (10/16) (cc08f7e45020354d4da913a187981f23) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16)
(a5d7421f20d939d0037009dc2e6a3fed) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (10/16) (cc08f7e45020354d4da913a187981f23)
[DEPLOYING].
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16)
(cc08f7e45020354d4da913a187981f23) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (4/16) (785960b63dee9900f6f2b38fb8719047) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16)
(cc08f7e45020354d4da913a187981f23) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (10/16) (cc08f7e45020354d4da913a187981f23).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (1/16).
[DataSink (DiscardingOutput) (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (10/16)
(cc08f7e45020354d4da913a187981f23) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (10/16) (cc08f7e45020354d4da913a187981f23) switched from
DEPLOYING to RUNNING.
[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})
f8c75758a75f77ad697c6ab4503a13ba.
[DataSink (DiscardingOutput) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16)
(7181c47f7675de3285154029baceb808) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (1/16)
(7181c47f7675de3285154029baceb808) [DEPLOYING]
[DataSink (DiscardingOutput) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (1/16) (7181c47f7675de3285154029baceb808) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16)
(f8c75758a75f77ad697c6ab4503a13ba) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (1/16) (7181c47f7675de3285154029baceb808)
[DEPLOYING].
[DataSink (DiscardingOutput) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16)
(7181c47f7675de3285154029baceb808) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/16) (7181c47f7675de3285154029baceb808) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (3/16).
[DataSink (DiscardingOutput) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16)
(7181c47f7675de3285154029baceb808) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (1/16) (7181c47f7675de3285154029baceb808).
[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})
8e241c8384b74368a34a2c1b516f80e0.
[DataSink (DiscardingOutput) (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (1/16)
(7181c47f7675de3285154029baceb808) [FINISHED]
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16)
(b5bd3d8ad4c4e382366aba3556ba1153) 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)
(b5bd3d8ad4c4e382366aba3556ba1153) [DEPLOYING]
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (3/16) (b5bd3d8ad4c4e382366aba3556ba1153) [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
(DiscardingOutput) d1192f97f0663329553b687dc76da951.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16)
(8e241c8384b74368a34a2c1b516f80e0) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (3/16) (b5bd3d8ad4c4e382366aba3556ba1153)
[DEPLOYING].
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16)
(b5bd3d8ad4c4e382366aba3556ba1153) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (16/16) (d1192f97f0663329553b687dc76da951) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (6/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (3/16) (b5bd3d8ad4c4e382366aba3556ba1153) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16)
(b5bd3d8ad4c4e382366aba3556ba1153) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (3/16) (b5bd3d8ad4c4e382366aba3556ba1153).
[DataSink (DiscardingOutput) (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (3/16)
(b5bd3d8ad4c4e382366aba3556ba1153) [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) 0d8b6e6cbb63efd2dc177c02dd2da579.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (8/16)
(6891b746b28e013aeb7877492feb2915) switched from RUNNING to FINISHED.
[jobmanager-future-thread-1] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (8/16) (0f69daf9dc6a8c551f36af1f7cd04a30) switched from
CREATED to SCHEDULED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(8/16) (6891b746b28e013aeb7877492feb2915).
[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) 23d7e4e34564360d65ecfd42f30fc29a.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
[2]PAssert$90/{RunChecks, VerifyAssertions}) (8/16)
(6891b746b28e013aeb7877492feb2915) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (8/16) (0f69daf9dc6a8c551f36af1f7cd04a30) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) cc08f7e45020354d4da913a187981f23.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (8/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (14/16) (0d8b6e6cbb63efd2dc177c02dd2da579) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 7181c47f7675de3285154029baceb808.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) b5bd3d8ad4c4e382366aba3556ba1153.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (5/16) (23d7e4e34564360d65ecfd42f30fc29a) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions})
6891b746b28e013aeb7877492feb2915.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (10/16) (cc08f7e45020354d4da913a187981f23) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16)
(71bbfd26e155faa41597eabcfe582767) 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)
(71bbfd26e155faa41597eabcfe582767) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (1/16) (7181c47f7675de3285154029baceb808) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (3/16) (b5bd3d8ad4c4e382366aba3556ba1153) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (8/16)
(6891b746b28e013aeb7877492feb2915) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (8/16).
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (6/16) (71bbfd26e155faa41597eabcfe582767) [DEPLOYING].
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16)
(0f69daf9dc6a8c551f36af1f7cd04a30) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (8/16)
(0f69daf9dc6a8c551f36af1f7cd04a30) [DEPLOYING]
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (8/16) (0f69daf9dc6a8c551f36af1f7cd04a30) [DEPLOYING].
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (6/16) (71bbfd26e155faa41597eabcfe582767)
[DEPLOYING].
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16)
(71bbfd26e155faa41597eabcfe582767) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (8/16) (0f69daf9dc6a8c551f36af1f7cd04a30)
[DEPLOYING].
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16)
(0f69daf9dc6a8c551f36af1f7cd04a30) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (6/16) (71bbfd26e155faa41597eabcfe582767) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (8/16) (0f69daf9dc6a8c551f36af1f7cd04a30) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16)
(71bbfd26e155faa41597eabcfe582767) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16)
(0f69daf9dc6a8c551f36af1f7cd04a30) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (8/16) (0f69daf9dc6a8c551f36af1f7cd04a30).
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (6/16) (71bbfd26e155faa41597eabcfe582767).
[DataSink (DiscardingOutput) (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (8/16)
(0f69daf9dc6a8c551f36af1f7cd04a30) [FINISHED]
[DataSink (DiscardingOutput) (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (6/16)
(71bbfd26e155faa41597eabcfe582767) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 0f69daf9dc6a8c551f36af1f7cd04a30.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 71bbfd26e155faa41597eabcfe582767.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (8/16) (0f69daf9dc6a8c551f36af1f7cd04a30) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (6/16) (71bbfd26e155faa41597eabcfe582767) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
countingsourcetest0testboundedsourcesplits-jenkins-1208122633-a472717b
(177d16a090a9fac3941fa0b2d5e7ea78) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
177d16a090a9fac3941fa0b2d5e7ea78 reached globally terminal state FINISHED.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
countingsourcetest0testboundedsourcesplits-jenkins-1208122633-a472717b(177d16a090a9fac3941fa0b2d5e7ea78).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherfaaed0af-8cb8-43fa-a9de-3174d0907f4a.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherfaaed0af-8cb8-43fa-a9de-3174d0907f4a.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
070c2d85f145b934ebec26fbdef2b71b: 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-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[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-cbef0a91-bc27-4ed8-8996-2033061b9461
[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-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_102.
[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/dispatcherfaaed0af-8cb8-43fa-a9de-3174d0907f4a.
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:38549
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 16339 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1208122633-a472717b_2c9154ef-9989-4761-b2a6-1473e9bba2f3/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-1208122633-a472717b_2c9154ef-9989-4761-b2a6-1473e9bba2f3/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:33307
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:33049
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.testing.PAssertTest > testWindowedIsEqualTo SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task
worker for ':' Thread 10,5,main]) completed. Took 22 mins 3.923 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 26m 45s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/hr64uy2nkz4w2
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]
