You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/12/06 06:25:26 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming
#108
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/108/display/redirect>
------------------------------------------
[...truncated 248.40 MB...]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$89/RunChecks/ParMultiDo(SideInputChecker), PAssert$89/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (26fb134bbb94de75942b0e41c2d86bea) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (6/16) (3af4b477449d94cdb8a71d10072ed67f) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (6/16) (3af4b477449d94cdb8a71d10072ed67f).
[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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map 94c24cb8e0c0c8f9d797893d99f3fa70.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (6/16) (3af4b477449d94cdb8a71d10072ed67f) [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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map 3af4b477449d94cdb8a71d10072ed67f.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (16/16) (01ed11e9fc13305d635631a7326311dc) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey -> [3]{PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/ParDo(Anonymous), PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map, PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)} -> Map -> ToKeyedWorkItem (1/16) (9e8dc8c99f3b12d02c9364b640dd2159) 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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map 01ed11e9fc13305d635631a7326311dc.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (8/16) (79659cf17fa5919e032e45b863d6acf6) [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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map 79659cf17fa5919e032e45b863d6acf6.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (4/16) (a58cb26596f06aa803c6034585cbadc2) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (4/16) (a58cb26596f06aa803c6034585cbadc2).
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (3/16) (52ca35aa3c71b855beb98fd7faaf1c35) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$92/RunChecks/ParMultiDo(SideInputChecker), PAssert$92/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (dc1c2d21f3e0c236a88faec8f67243dd) 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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map 52ca35aa3c71b855beb98fd7faaf1c35.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (4/16) (a58cb26596f06aa803c6034585cbadc2) [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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map a58cb26596f06aa803c6034585cbadc2.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (ad44d4460c246a08408a9db3c4618208) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (960c6c68f06c3f2a5981c23f9635ce97) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (10/16) (b371e5704c6536f6790f80a2cb916126) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (10/16) (b371e5704c6536f6790f80a2cb916126).
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (13/16) (d9827b412266d43da3780a1cb93f2fa7) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (13/16) (d9827b412266d43da3780a1cb93f2fa7).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$92/RunChecks/ParMultiDo(SideInputChecker), PAssert$92/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (8471c96ea6f70e70def7b2946bcde3d6) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (7/16) (916598a51487d1c4225212354f84c8e1) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (7/16) (916598a51487d1c4225212354f84c8e1).
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (10/16) (b371e5704c6536f6790f80a2cb916126) [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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map b371e5704c6536f6790f80a2cb916126.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (15/16) (35c2c1eef8caf8febc5d1bbd64d80050) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (15/16) (35c2c1eef8caf8febc5d1bbd64d80050).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (32166d4d1abdfaf3758ccf58fb583fe8) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (7/16) (916598a51487d1c4225212354f84c8e1) [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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map 916598a51487d1c4225212354f84c8e1.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (13/16) (d9827b412266d43da3780a1cb93f2fa7) [FINISHED]
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (15/16) (35c2c1eef8caf8febc5d1bbd64d80050) [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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map d9827b412266d43da3780a1cb93f2fa7.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$92/RunChecks/ParMultiDo(SideInputChecker), PAssert$92/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (41c7859a72e69f3812ebbed46be98698) 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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map 35c2c1eef8caf8febc5d1bbd64d80050.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (14/16) (e5dd732e95232bdcbad9bb14ca5d3df8) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (14/16) (e5dd732e95232bdcbad9bb14ca5d3df8).
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (11/16) (0828051966f5b1b9ee0a3473aa022992) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (2659b3974587d3039753a17ca07670b2) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (11/16) (0828051966f5b1b9ee0a3473aa022992).
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (14/16) (e5dd732e95232bdcbad9bb14ca5d3df8) [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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map e5dd732e95232bdcbad9bb14ca5d3df8.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey -> [3]{PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/ParDo(Anonymous), PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map, PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)} -> Map -> ToKeyedWorkItem (4/16) (dfa26358e0f0dead9d66a5532e1dbbdd) switched from RUNNING to FINISHED.
[PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (11/16) (0828051966f5b1b9ee0a3473aa022992) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (6bb0e704aac63c7aa8d6cc2991329349) 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 PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map 0828051966f5b1b9ee0a3473aa022992.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$92/RunChecks/ParMultiDo(SideInputChecker), PAssert$92/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (8b0f3cf23e51b822ace4b6706a5fbbdb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (5285fb3e13c3efe77bdc2b1642fa1972) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (7020b50f295113cc1ca13db902721298) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (443b02763a22001e0a620e45106ea794) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (234ebbc988613f2793aa2bd63ff8a72c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$89/RunChecks/ParMultiDo(SideInputChecker), PAssert$89/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (d224bf3abdce2d3f04a4a987bbfac7f0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$91/RunChecks/ParMultiDo(SideInputChecker), PAssert$91/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (a0ba20b680737404ffe51574cf6edd32) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey -> [3]{PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/ParDo(Anonymous), PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map, PAssert$90/CreateActual/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)} -> Map -> ToKeyedWorkItem (16/16) (6364c14544f9a044ac303ef6a11850ad) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (2/16) (04f9ee5f779fd5996fe74833ad9df4fc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (12/16) (0061a8cfc66e82edeeca74751e8d2551) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (1/16) (e3178209f77776ea76e15038855ee197) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$92/RunChecks/ParMultiDo(SideInputChecker), PAssert$92/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (f37a66e8cedd16e5f3f9e60ceeebbeab) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (5/16) (48f6b89f1a2474207b50a455022ac5c3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (9/16) (94c24cb8e0c0c8f9d797893d99f3fa70) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (6/16) (3af4b477449d94cdb8a71d10072ed67f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (16/16) (01ed11e9fc13305d635631a7326311dc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (8/16) (79659cf17fa5919e032e45b863d6acf6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (3/16) (52ca35aa3c71b855beb98fd7faaf1c35) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (4/16) (a58cb26596f06aa803c6034585cbadc2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (10/16) (b371e5704c6536f6790f80a2cb916126) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (7/16) (916598a51487d1c4225212354f84c8e1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (13/16) (d9827b412266d43da3780a1cb93f2fa7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (15/16) (35c2c1eef8caf8febc5d1bbd64d80050) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (14/16) (e5dd732e95232bdcbad9bb14ca5d3df8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$90/RunChecks/ParMultiDo(SideInputChecker)-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:389#f8be1df736352312 -> Map (11/16) (0828051966f5b1b9ee0a3473aa022992) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16) (afe029286bd5ae7ea9e2952fc635948c) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16) (afe029286bd5ae7ea9e2952fc635948c).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16) (afe029286bd5ae7ea9e2952fc635948c) [FINISHED]
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (64e14f6fd4b81abf1fe9e405d729e7a1) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (64e14f6fd4b81abf1fe9e405d729e7a1).
[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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} afe029286bd5ae7ea9e2952fc635948c.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (64e14f6fd4b81abf1fe9e405d729e7a1) [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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 64e14f6fd4b81abf1fe9e405d729e7a1.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16) (afe029286bd5ae7ea9e2952fc635948c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (64e14f6fd4b81abf1fe9e405d729e7a1) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (c5e8151ee1eff8b5e4a0e619b411b96f) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (c5e8151ee1eff8b5e4a0e619b411b96f).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (910b0962c888fbfb38e9395308ac6b1b) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (910b0962c888fbfb38e9395308ac6b1b).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (c94240d234fc4c7b56aadce875719860) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (c94240d234fc4c7b56aadce875719860).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (e16c2c5e16e45495ee32520d10aa4c16) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (724a639e001f67473b0e4890449b39fe) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (e16c2c5e16e45495ee32520d10aa4c16).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (724a639e001f67473b0e4890449b39fe).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (c5e8151ee1eff8b5e4a0e619b411b96f) [FINISHED]
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (910b0962c888fbfb38e9395308ac6b1b) [FINISHED]
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (724a639e001f67473b0e4890449b39fe) [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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} c5e8151ee1eff8b5e4a0e619b411b96f.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (a8267f38cdc69d27a717905d67138fd1) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (e16c2c5e16e45495ee32520d10aa4c16) [FINISHED]
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (a8267f38cdc69d27a717905d67138fd1).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (b140563ddb0ba7167efcb089394135e7) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (b140563ddb0ba7167efcb089394135e7).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (a8267f38cdc69d27a717905d67138fd1) [FINISHED]
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16) (ffdf920e86c4436f0a2a73e79ffd14a1) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16) (ffdf920e86c4436f0a2a73e79ffd14a1).
[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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 910b0962c888fbfb38e9395308ac6b1b.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (c94240d234fc4c7b56aadce875719860) [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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 724a639e001f67473b0e4890449b39fe.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16) (ffdf920e86c4436f0a2a73e79ffd14a1) [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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} e16c2c5e16e45495ee32520d10aa4c16.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (b140563ddb0ba7167efcb089394135e7) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (c5e8151ee1eff8b5e4a0e619b411b96f) 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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} a8267f38cdc69d27a717905d67138fd1.
[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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} c94240d234fc4c7b56aadce875719860.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (910b0962c888fbfb38e9395308ac6b1b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (724a639e001f67473b0e4890449b39fe) 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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} ffdf920e86c4436f0a2a73e79ffd14a1.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (092e4292a6c83341ef6bd2c091ef0b63) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (092e4292a6c83341ef6bd2c091ef0b63).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (b74ce45608cbdd4331c6959e08e448cf) 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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} b140563ddb0ba7167efcb089394135e7.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (b74ce45608cbdd4331c6959e08e448cf).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (f60828285a600fb5b31153751bce919f) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (f60828285a600fb5b31153751bce919f).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (092e4292a6c83341ef6bd2c091ef0b63) [FINISHED]
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (068cd0a431cf610065aed939d0274640) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (068cd0a431cf610065aed939d0274640).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (e16c2c5e16e45495ee32520d10aa4c16) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (f60828285a600fb5b31153751bce919f) [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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 092e4292a6c83341ef6bd2c091ef0b63.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (068cd0a431cf610065aed939d0274640) [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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} f60828285a600fb5b31153751bce919f.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (b74ce45608cbdd4331c6959e08e448cf) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (a8267f38cdc69d27a717905d67138fd1) 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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 068cd0a431cf610065aed939d0274640.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16) (3cddde3bfe80be9023fd7083d069e001) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16) (3cddde3bfe80be9023fd7083d069e001).
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16) (3cddde3bfe80be9023fd7083d069e001) [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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} b74ce45608cbdd4331c6959e08e448cf.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (c94240d234fc4c7b56aadce875719860) 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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 3cddde3bfe80be9023fd7083d069e001.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16) (ffdf920e86c4436f0a2a73e79ffd14a1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (b140563ddb0ba7167efcb089394135e7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (092e4292a6c83341ef6bd2c091ef0b63) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (f60828285a600fb5b31153751bce919f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (068cd0a431cf610065aed939d0274640) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16) (7fdcaa0df89f4c5afa47a137f3a8b324) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16) (7fdcaa0df89f4c5afa47a137f3a8b324).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (b74ce45608cbdd4331c6959e08e448cf) switched from RUNNING to FINISHED.
[[2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16) (7fdcaa0df89f4c5afa47a137f3a8b324) [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 [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 7fdcaa0df89f4c5afa47a137f3a8b324.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16) (3cddde3bfe80be9023fd7083d069e001) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - [2]{PAssert$90/RunChecks/ParMultiDo(SideInputChecker), PAssert$90/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16) (7fdcaa0df89f4c5afa47a137f3a8b324) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job countingsourcetest0testboundedsourcesplits-jenkins-1206062456-c3185c (5867093c25ac5f94888610db599e1081) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 5867093c25ac5f94888610db599e1081.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 5867093c25ac5f94888610db599e1081 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job countingsourcetest0testboundedsourcesplits-jenkins-1206062456-c3185c(5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 5867093c25ac5f94888610db599e1081.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 608456c2e9e95e4cad561683f4e2f96c: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 97f068caeb0b7405d2c5ac41fa514015@akka://flink/user/jobmanager_103 for job 5867093c25ac5f94888610db599e1081 from the resource manager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d1f3aa57a49fd0fade5a7fb5df261fe6}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{3a506efc505b276296dae4f0b9662987}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b1a95813f3a9cecf8cc0c8f290ffa151}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c91be8b28e3ffc21846f3185f6b1fdb9}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d6b3c713a65eadc190ff791f118c236a}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d170874f4d88188140eba0e35894628b}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 5867093c25ac5f94888610db599e1081 with leader id 97f068caeb0b7405d2c5ac41fa514015 lost leadership.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{556a577f032cdf83da446cf6cccd48f2}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2b924461f2eb196703b1be0aacb3a7ce}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{02f057adbeeb2bd7f8e0ee00fda0d4ad}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6ee3e9e6e67a1cf95851ec1d20c94362}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ec3b19645bb92e9378feb5a409bd56e9}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a20695cdc7d60e7d5d8c868e9ed154dd}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{0e13cd892d63d93c76c3897050dd2e87}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a587a4d5598b2f590995a99aca564484}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{40578fd1725a988c3d243915fbebaf67}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c9cf9d194553213af31cd9dbc5331e3d}, jobId: 5867093c25ac5f94888610db599e1081).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 5867093c25ac5f94888610db599e1081 from job leader monitoring.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 5867093c25ac5f94888610db599e1081.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 5867093c25ac5f94888610db599e1081.
[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-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher35f2f236-5817-4eba-a28a-6dc01a56c4cc.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher35f2f236-5817-4eba-a28a-6dc01a56c4cc.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-c3c1c264-9e81-4773-8195-4ff6014eec38
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_102.
[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/dispatcher35f2f236-5817-4eba-a28a-6dc01a56c4cc.
[ForkJoinPool.commonPool-worker-1] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-1] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41033
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 12544 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@3c65969f
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1206062456-c3185c_721c613a-adc3-403e-b124-6a0daaedf3dc/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-1206062456-c3185c_721c613a-adc3-403e-b124-6a0daaedf3dc/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:39911
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:33797
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
org.apache.beam.sdk.values.PCollectionTupleTest > testComposePCollectionTuple SKIPPED
72 tests completed, 4 failed, 2 skipped
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 20 mins 27.086 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 25m 7s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/krbqtw7pnl5ry
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org