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/26 23:53:07 UTC

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #275

See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/275/display/redirect?page=changes>

Changes:

[heejong] [BEAM-6287] pyarrow is not supported on Windows Python 2

------------------------------------------
[...truncated 355.14 MB...]
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5) [DEPLOYING]
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5) [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) f4989f4d78d1c7b63b53452032fc0cf7.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5) [DEPLOYING].
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5).
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (1/16) (a4a5a871069c053ebd8e0c1629b57093) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (10/16).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8) 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) (97ccb3c9dbd70cca3e24254dc0aa4bc8) [DEPLOYING]
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8) [DEPLOYING].
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (3/16).
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16) (f4989f4d78d1c7b63b53452032fc0cf7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8) switched from DEPLOYING to RUNNING.
    [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 [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 0028c7d7aca4cde6ed049c52710ed05c.
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8).
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8) [FINISHED]
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20) 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) (1c8fc34fec9a43ecd74b3a22f501fd20) [DEPLOYING]
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20) [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) b3d3b2c82bc316836504f047af796d85.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20) [DEPLOYING].
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20).
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (6/16) (0028c7d7aca4cde6ed049c52710ed05c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (7/16).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16) (b3d3b2c82bc316836504f047af796d85) 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 [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) c7180dd5e666252b028670d918bf9a52.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) [DEPLOYING]
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 4b9021586aeb3923badb30dabcb76cf5.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) [DEPLOYING].
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (12/16) (c7180dd5e666252b028670d918bf9a52) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329).
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (1/16).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16) (4b9021586aeb3923badb30dabcb76cf5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0) 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) (d78a7a00240c314dd873d255aff767c0) [DEPLOYING]
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (6/16).
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0) [DEPLOYING].
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0).
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0) [FINISHED]
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e) 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) (fdf23d1a2d0980234dc8edd18619686e) [DEPLOYING]
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (2/16).
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e) [DEPLOYING].
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e).
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e) [FINISHED]
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) [DEPLOYING]
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (14/16).
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) [DEPLOYING].
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6) 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) (819cf2715dce4b314ed380c0c88e1ce6) [DEPLOYING]
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6) [DEPLOYING].
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784).
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (15/16).
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6) [DEPLOYING].
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6).
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6) [FINISHED]
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) [DEPLOYING]
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (12/16).
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) [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) cbd8233d66afd5bfb8f8f19b55ed9898.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) switched from CREATED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 974d2cfd7e9b29d6797ee68c3265ff67.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) [DEPLOYING]
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) [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) 3287d10225955cc1b6239e17c506e0ac.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (cbd8233d66afd5bfb8f8f19b55ed9898) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 4c756b1d1ddcc1d2ea019b3a20f43669.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) [DEPLOYING].
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286).
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) switched from DEPLOYING to RUNNING.
    [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) a3d5061e064c374c5c6e49f2c7643b91.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) [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) 02d6f9a82c4700a13304452b065d49c5.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (974d2cfd7e9b29d6797ee68c3265ff67) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1).
    [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) 97ccb3c9dbd70cca3e24254dc0aa4bc8.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) [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) 1c8fc34fec9a43ecd74b3a22f501fd20.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (3287d10225955cc1b6239e17c506e0ac) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 1d3bbc92ba7fa473a2f59748aa0ce329.
    [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) d78a7a00240c314dd873d255aff767c0.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (4c756b1d1ddcc1d2ea019b3a20f43669) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) fdf23d1a2d0980234dc8edd18619686e.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) 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) 44769e3f35f7c130931812c3e5006784.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (a3d5061e064c374c5c6e49f2c7643b91) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 819cf2715dce4b314ed380c0c88e1ce6.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (02d6f9a82c4700a13304452b065d49c5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) b30b001fedda93e73d4d5d0c8a144286.
    [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) b3084065d0c730d0bf2bcc34b6cff8e1.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (97ccb3c9dbd70cca3e24254dc0aa4bc8) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (1c8fc34fec9a43ecd74b3a22f501fd20) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (1d3bbc92ba7fa473a2f59748aa0ce329) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (d78a7a00240c314dd873d255aff767c0) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (fdf23d1a2d0980234dc8edd18619686e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (44769e3f35f7c130931812c3e5006784) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (819cf2715dce4b314ed380c0c88e1ce6) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (b30b001fedda93e73d4d5d0c8a144286) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (b3084065d0c730d0bf2bcc34b6cff8e1) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (b88de73f3431bcaa61de6b280ff754d3) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (b88de73f3431bcaa61de6b280ff754d3).
    [jobmanager-future-thread-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) switched from CREATED to SCHEDULED.
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (b88de73f3431bcaa61de6b280ff754d3) [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 [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) b88de73f3431bcaa61de6b280ff754d3.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (8/16) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (8/16).
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (b88de73f3431bcaa61de6b280ff754d3) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) 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) (67d2ca037fcf4abf76b1f59289da7e23) [DEPLOYING]
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) [DEPLOYING].
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) [DEPLOYING].
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23).
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) [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) 67d2ca037fcf4abf76b1f59289da7e23.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (67d2ca037fcf4abf76b1f59289da7e23) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1226235233-2164bb9f (f8ccb5b241d5cfbe487bd571cb1267dc) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job f8ccb5b241d5cfbe487bd571cb1267dc reached globally terminal state FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1226235233-2164bb9f(f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f8ccb5b241d5cfbe487bd571cb1267dc.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 7928ea67c0ae2cdf714158cdfb0d2c23: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 91a2365ae7ebf631669c3c6e3c184a80@akka://flink/user/jobmanager_231 for job f8ccb5b241d5cfbe487bd571cb1267dc from the resource manager.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job f8ccb5b241d5cfbe487bd571cb1267dc with leader id 91a2365ae7ebf631669c3c6e3c184a80 lost leadership.
    [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.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher47989e65-dd79-4d90-9b22-5bfcb0b34d9f.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher47989e65-dd79-4d90-9b22-5bfcb0b34d9f.
    [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.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/dispatcher47989e65-dd79-4d90-9b22-5bfcb0b34d9f.
    [flink-akka.actor.default-dispatcher-7] 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{e64e3f6249d3c3d0ca9212087a478f49}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{414f4a2e80f994a75fcbeba02a21ec85}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{6e6c7d89db40e36abbfa0b0e971bd2b6}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{08e5483dc0efdbda1da5150628a43928}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{a658a2519d87a311d197aaa5ad3ee184}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{3879f1823dc6bf684ff892fb8b0d5bbb}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{1fcd6c1c45b3c4446afa1550b7685507}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{bbe46038076a4d4b5eb8da05f739ada4}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{c782dfc822d92953e1c52bde22690eff}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{6959b886318ac1fe59d429e77853faeb}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{7259e1ab7d6d121a0fa7bba9e07143cc}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{343544a1e8f3c837f006a4d07b27bd33}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{24eaa069558d063029501a55a79e69fd}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-7] 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{468d7d22dbc49ec24d10695ae175c47d}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-2] 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{17cdbd0acded93595231ca0da5524b77}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-2] 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{4d8e0c89c0050fd3a5e4f6148e3376d7}, jobId: f8ccb5b241d5cfbe487bd571cb1267dc).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job f8ccb5b241d5cfbe487bd571cb1267dc from job leader monitoring.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f8ccb5b241d5cfbe487bd571cb1267dc.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f8ccb5b241d5cfbe487bd571cb1267dc.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_230.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-47320982-3a20-4baa-b8a4-c5ced95c3fa1
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_230.
    [ForkJoinPool.commonPool-worker-4] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-4] 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:38459
    [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 12031 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@51085b18
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1226235233-2164bb9f_e1be4856-bbc2-493d-9813-8413faa919fe/MANIFEST has 186 artifact locations
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1226235233-2164bb9f_e1be4856-bbc2-493d-9813-8413faa919fe/
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:32809
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:44589

Gradle Test Executor 1 finished executing tests.

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch

org.apache.beam.sdk.transforms.ParDoTest$TimerCoderInferenceTests > testValueStateCoderInferenceFromInputCoder SKIPPED

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 5,5,main]) completed. Took 41 mins 45.499 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 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 45m 26s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/6fbctb64ozhqm

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