beam-builds mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #326
Date Thu, 03 Jan 2019 16:07:23 GMT
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/326/display/redirect?page=changes>

Changes:

[echauchot] split SerializablePipelineOptions into serialization utils and instance

------------------------------------------
[...truncated 59.58 MB...]
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) exceeded the 80 characters length limit and was truncated.
    [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 DataSource (Impulse) 7af8c456da80700c29ad5b8593d10842.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (55845570ca55b8cf14b26130128c4377) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (55845570ca55b8cf14b26130128c4377) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (55845570ca55b8cf14b26130128c4377) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (11/16) (7af8c456da80700c29ad5b8593d10842) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (55845570ca55b8cf14b26130128c4377) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (55845570ca55b8cf14b26130128c4377) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (55845570ca55b8cf14b26130128c4377) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) exceeded the 80 characters length limit and was truncated.
    [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 DataSource (Impulse) 754d423bb6d8cb2972c71d2e0c668dd2.
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (e7a9e44c269b8c1a7c1753a01c3e21ab) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (e7a9e44c269b8c1a7c1753a01c3e21ab) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (e7a9e44c269b8c1a7c1753a01c3e21ab) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (4/16) (754d423bb6d8cb2972c71d2e0c668dd2) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (e7a9e44c269b8c1a7c1753a01c3e21ab) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (e7a9e44c269b8c1a7c1753a01c3e21ab) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (e7a9e44c269b8c1a7c1753a01c3e21ab) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16).
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (23f1b9e9eaf5c80004951111f4cd77a8) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (23f1b9e9eaf5c80004951111f4cd77a8) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (23f1b9e9eaf5c80004951111f4cd77a8) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (23f1b9e9eaf5c80004951111f4cd77a8) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (23f1b9e9eaf5c80004951111f4cd77a8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (23f1b9e9eaf5c80004951111f4cd77a8) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull docker image jenkins-docker-apache.bintray.io/beam/java, cause: Received exit code 1 for command 'docker pull jenkins-docker-apache.bintray.io/beam/java'. stderr: Error response from daemon: unknown: Repo 'apache' was not found

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [pool-81-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [pool-81-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
    [grpc-default-executor-103] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/viewtest0testwindowediterablesideinput-jenkins-0103152442-7fb17f_f64069c9-643c-4784-9bee-5f46b9597a3b/MANIFEST

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [grpc-default-executor-124] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/combinefnstest0testcomposedcombine-jenkins-0103152437-e9962670_be439ed5-5daa-4d80-a298-cd16bad6a34f/MANIFEST

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [grpc-default-executor-103] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Loading manifest for retrieval token /tmp/beam-artifact-staging/viewtest0testwindowediterablesideinput-jenkins-0103152442-7fb17f_f64069c9-643c-4784-9bee-5f46b9597a3b/MANIFEST

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [grpc-default-executor-124] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Loading manifest for retrieval token /tmp/beam-artifact-staging/combinefnstest0testcomposedcombine-jenkins-0103152437-e9962670_be439ed5-5daa-4d80-a298-cd16bad6a34f/MANIFEST

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [grpc-default-executor-103] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/viewtest0testwindowediterablesideinput-jenkins-0103152442-7fb17f_f64069c9-643c-4784-9bee-5f46b9597a3b/MANIFEST has 186 artifact locations
    [grpc-default-executor-103] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/viewtest0testwindowediterablesideinput-jenkins-0103152442-7fb17f_f64069c9-643c-4784-9bee-5f46b9597a3b/MANIFEST -> 186 artifacts

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [grpc-default-executor-124] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/combinefnstest0testcomposedcombine-jenkins-0103152437-e9962670_be439ed5-5daa-4d80-a298-cd16bad6a34f/MANIFEST has 186 artifact locations
    [grpc-default-executor-124] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/combinefnstest0testcomposedcombine-jenkins-0103152437-e9962670_be439ed5-5daa-4d80-a298-cd16bad6a34f/MANIFEST -> 186 artifacts

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at [4]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007fcebd9dc000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
#
#

Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f8d5c5f3000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007fcebeff0000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput STANDARD_ERROR
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f8c654d7000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
    [CHAIN MapPartition (MapPartition at [4]PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$14/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory - Still waiting for startup of environment jenkins-docker-apache.bintray.io/beam/java for worker id 1
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 12288 bytes[thread 140525945423616 also had an error] for committing reserved memory.

# An error report file with more information is saved as:
# <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/hs_err_pid30823.log>
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 12288 bytes for committing reserved memory.
# An error report file with more information is saved as:
# <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/hs_err_pid30822.log>
[thread 140240972773120 also had an error]
Could not stop org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@71629a83.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message [MethodInvocation method: stop()].
	at org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:34)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:31)
	at org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:133)
	at org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:34)
	at org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:73)
	at org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
	at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
	at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test Executor 1' finished with non-zero exit value 137
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
	at org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:155)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
	... 10 more

org.apache.beam.sdk.transforms.ViewTest > testWindowedIterableSideInput SKIPPED

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine SKIPPED

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 51 mins 41.469 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 55m 10s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/wnm5dr4t24yiq

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


Mime
View raw message