You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/09/14 07:53:42 UTC
Build failed in Jenkins: beam_PostCommit_Python_PVR_Flink_Gradle #9
See <https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/9/display/redirect?page=changes>
Changes:
[mxm] [BEAM-5337] Fix flaky test UnboundedSourceWrapperTest#testValueEmission
------------------------------------------
[...truncated 6.28 MB...]
[grpc-default-executor-1] INFO sdk_worker.__init__ - Creating insecure control channel.
[grpc-default-executor-1] INFO sdk_worker.__init__ - Control channel established.
[grpc-default-executor-1] INFO sdk_worker.__init__ - Initializing SDKHarness with 12 workers.
[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 1
[grpc-default-executor-1] INFO sdk_worker.run - Got work 1
[grpc-default-executor-1] INFO sdk_worker.run - Got work 4
[grpc-default-executor-1] INFO sdk_worker.run - Got work 3
[grpc-default-executor-1] INFO sdk_worker.run - Got work 2
[grpc-default-executor-1] INFO sdk_worker.run - Got work 6
[grpc-default-executor-1] INFO sdk_worker.run - Got work 5
[grpc-default-executor-1] INFO sdk_worker.run - Got work 8
[grpc-default-executor-1] INFO sdk_worker.run - Got work 7
[grpc-default-executor-1] INFO sdk_worker.create_state_handler - Creating channel for localhost:45787
[grpc-default-executor-1] INFO data_plane.create_data_channel - Creating channel for localhost:35003
[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client connected.
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataOutputOperation >
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/Reshuffle/ReshufflePerKey/Map(reify_timestamps) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/Reshuffle/AddRandomKeys output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataOutputOperation >
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/Split output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/Reshuffle/ReshufflePerKey/Map(reify_timestamps) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation Create/Read/Split output_tags=['out'], receivers=[ConsumerSet[Create/Read/Split.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation Create/Read/Reshuffle/AddRandomKeys output_tags=['out'], receivers=[ConsumerSet[Create/Read/Reshuffle/AddRandomKeys.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/Reshuffle/AddRandomKeys output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DoOperation Create/Read/Reshuffle/ReshufflePerKey/Map(reify_timestamps) output_tags=['out'], receivers=[ConsumerSet[Create/Read/Reshuffle/ReshufflePerKey/Map(reify_timestamps).out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DataOutputOperation >
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/Split output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Create/Read/Split output_tags=['out'], receivers=[ConsumerSet[assert_that/Create/Read/Split.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[Source: Collection Source -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: Collection Source -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (18d36f0318a3f7eaf8cc0d5bc4e3035c) switched from RUNNING to FINISHED.
[Source: Collection Source -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Source: Collection Source -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (18d36f0318a3f7eaf8cc0d5bc4e3035c).
[Source: Collection Source -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task Source: Collection Source -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (18d36f0318a3f7eaf8cc0d5bc4e3035c) [FINISHED]
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Create/Read/Reshuffle/AddRandomKeys output_tags=['out'], receivers=[ConsumerSet[assert_that/Create/Read/Reshuffle/AddRandomKeys.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Create/Read/Reshuffle/ReshufflePerKey/Map(reify_timestamps) output_tags=['out'], receivers=[ConsumerSet[assert_that/Create/Read/Reshuffle/ReshufflePerKey/Map(reify_timestamps).out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DataOutputOperation >
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task Source: Collection Source -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem 18d36f0318a3f7eaf8cc0d5bc4e3035c.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Collection Source -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (18d36f0318a3f7eaf8cc0d5bc4e3035c) switched from RUNNING to FINISHED.
[grpc-default-executor-1] INFO sdk_worker.run - Got work 9
[Source: Collection Source -> 31assert_that/Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: Collection Source -> 31assert_that/Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (7bd0a3171fe7f4e07af6c1160c32f523) switched from RUNNING to FINISHED.
[Source: Collection Source -> 31assert_that/Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Source: Collection Source -> 31assert_that/Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (7bd0a3171fe7f4e07af6c1160c32f523).
[Source: Collection Source -> 31assert_that/Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task Source: Collection Source -> 31assert_that/Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (7bd0a3171fe7f4e07af6c1160c32f523) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task Source: Collection Source -> 31assert_that/Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem 7bd0a3171fe7f4e07af6c1160c32f523.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Collection Source -> 31assert_that/Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (7bd0a3171fe7f4e07af6c1160c32f523) switched from RUNNING to FINISHED.
[grpc-default-executor-1] INFO sdk_worker.run - Got work 10
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataOutputOperation >
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <FlattenOperation assert_that/Group/Flatten >
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Group/pair_with_0 output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/ReadSplits output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/Reshuffle/RemoveRandomKeys output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Create/Read/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps) output_tags=['out'], receivers=[ConsumerSet[assert_that/Create/Read/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Create/Read/Reshuffle/RemoveRandomKeys output_tags=['out'], receivers=[ConsumerSet[assert_that/Create/Read/Reshuffle/RemoveRandomKeys.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Create/Read/ReadSplits output_tags=['out'], receivers=[ConsumerSet[assert_that/Create/Read/ReadSplits.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Group/pair_with_0 output_tags=['out'], receivers=[ConsumerSet[assert_that/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <FlattenOperation assert_that/Group/Flatten receivers=[ConsumerSet[assert_that/Group/Flatten.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataOutputOperation >
[assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (bcd7b6a4910844b37ba44d81e48bf9a8) switched from RUNNING to FINISHED.
[assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (bcd7b6a4910844b37ba44d81e48bf9a8).
[assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (bcd7b6a4910844b37ba44d81e48bf9a8) [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 assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 bcd7b6a4910844b37ba44d81e48bf9a8.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 74assert_that/Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (bcd7b6a4910844b37ba44d81e48bf9a8) switched from RUNNING to FINISHED.
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataOutputOperation >
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation WindowInto(WindowIntoFn) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation Map(<lambda at fn_api_runner_test.py:269>) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/ReadSplits output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/Reshuffle/RemoveRandomKeys output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation Create/Read/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps) output_tags=['out'], receivers=[ConsumerSet[Create/Read/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation Create/Read/Reshuffle/RemoveRandomKeys output_tags=['out'], receivers=[ConsumerSet[Create/Read/Reshuffle/RemoveRandomKeys.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation Create/Read/ReadSplits output_tags=['out'], receivers=[ConsumerSet[Create/Read/ReadSplits.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation Map(<lambda at fn_api_runner_test.py:269>) output_tags=['out'], receivers=[ConsumerSet[Map(<lambda at fn_api_runner_test.py:269>).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation WindowInto(WindowIntoFn) output_tags=['out'], receivers=[ConsumerSet[WindowInto(WindowIntoFn).out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataOutputOperation >
[Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 62Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 62Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (5dceae31e433cabc591f54dc416fbf50) switched from RUNNING to FINISHED.
[Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 62Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 62Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (5dceae31e433cabc591f54dc416fbf50).
[Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 62Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 62Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (5dceae31e433cabc591f54dc416fbf50) [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 Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 62Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem 5dceae31e433cabc591f54dc416fbf50.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create/Read/Reshuffle/ReshufflePerKey/GroupByKey -> 62Create/Read/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 -> ToKeyedWorkItem (1/1) (5dceae31e433cabc591f54dc416fbf50) switched from RUNNING to FINISHED.
[grpc-default-executor-1] INFO sdk_worker.run - Got work 11
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataOutputOperation >
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <FlattenOperation assert_that/Group/Flatten >
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Group/pair_with_1 output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/ToVoidKey output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/WindowInto(WindowIntoFn) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation Map(<lambda at fn_api_runner_test.py:272>) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation Map(<lambda at fn_api_runner_test.py:272>) output_tags=['out'], receivers=[ConsumerSet[Map(<lambda at fn_api_runner_test.py:272>).out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/WindowInto(WindowIntoFn) output_tags=['out'], receivers=[ConsumerSet[assert_that/WindowInto(WindowIntoFn).out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/ToVoidKey output_tags=['out'], receivers=[ConsumerSet[assert_that/ToVoidKey.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Group/pair_with_1 output_tags=['out'], receivers=[ConsumerSet[assert_that/Group/pair_with_1.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <FlattenOperation assert_that/Group/Flatten receivers=[ConsumerSet[assert_that/Group/Flatten.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataOutputOperation >
[grpc-default-executor-0] INFO sdk_worker.run - Got work 12
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DataOutputOperation >
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <FlattenOperation assert_that/Group/Flatten >
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Group/pair_with_1 output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation assert_that/ToVoidKey output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation assert_that/WindowInto(WindowIntoFn) output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation Map(<lambda at fn_api_runner_test.py:272>) output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DoOperation Map(<lambda at fn_api_runner_test.py:272>) output_tags=['out'], receivers=[ConsumerSet[Map(<lambda at fn_api_runner_test.py:272>).out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/WindowInto(WindowIntoFn) output_tags=['out'], receivers=[ConsumerSet[assert_that/WindowInto(WindowIntoFn).out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/ToVoidKey output_tags=['out'], receivers=[ConsumerSet[assert_that/ToVoidKey.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Group/pair_with_1 output_tags=['out'], receivers=[ConsumerSet[assert_that/Group/pair_with_1.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <FlattenOperation assert_that/Group/Flatten receivers=[ConsumerSet[assert_that/Group/Flatten.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataOutputOperation >
[GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (966d54265e1855dd05ff3a4a783b6c89) switched from RUNNING to FINISHED.
[GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (966d54265e1855dd05ff3a4a783b6c89).
[GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (966d54265e1855dd05ff3a4a783b6c89) [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 GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 966d54265e1855dd05ff3a4a783b6c89.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1) (d674adc8f1f0c645f53a21a9561be83c) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/1) (d674adc8f1f0c645f53a21a9561be83c).
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/1) (d674adc8f1f0c645f53a21a9561be83c) [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 ToKeyedWorkItem d674adc8f1f0c645f53a21a9561be83c.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (966d54265e1855dd05ff3a4a783b6c89) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/1) (d674adc8f1f0c645f53a21a9561be83c) switched from RUNNING to FINISHED.
[grpc-default-executor-1] INFO sdk_worker.run - Got work 13
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Match output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Unkey output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Group/Map(_merge_tagged_vals_under_key) output_tags=['out']>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - start <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DataInputOperation receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Group/Map(_merge_tagged_vals_under_key) output_tags=['out'], receivers=[ConsumerSet[assert_that/Group/Map(_merge_tagged_vals_under_key).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Unkey output_tags=['out'], receivers=[ConsumerSet[assert_that/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]>
[grpc-default-executor-1] INFO bundle_processor.process_bundle - finish <DoOperation assert_that/Match output_tags=['out'], receivers=[ConsumerSet[assert_that/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=0]]>
[grpc-default-executor-1] INFO sdk_worker.run - No more requests from control plane
[grpc-default-executor-1] INFO sdk_worker.run - SDK Harness waiting for in-flight requests to complete
[grpc-default-executor-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[grpc-default-executor-0] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-0] INFO sdk_worker.close - Closing all cached gRPC state handlers.
[grpc-default-executor-0] INFO sdk_worker.run - Done consuming work.
[grpc-default-executor-0] INFO sdk_worker_main.main - Python sdk harness exiting.
[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client hanged up.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] WARN org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase - Error cleaning up environment url: "jenkins-docker-apache.bintray.io/beam/python:latest"
java.lang.IllegalStateException: call already closed
at org.apache.beam.vendor.guava.v20.com.google.common.base.Preconditions.checkState(Preconditions.java:444)
at org.apache.beam.vendor.grpc.v1.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:172)
at org.apache.beam.vendor.grpc.v1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:358)
at org.apache.beam.runners.fnexecution.state.GrpcStateService.close(GrpcStateService.java:54)
at org.apache.beam.runners.fnexecution.GrpcFnServer.close(GrpcFnServer.java:83)
at org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase$WrappedSdkHarnessClient.$closeResource(JobBundleFactoryBase.java:327)
at org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase$WrappedSdkHarnessClient.close(JobBundleFactoryBase.java:327)
at org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase.lambda$createEnvironmentCache$0(JobBundleFactoryBase.java:147)
at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.processPendingNotifications(LocalCache.java:1963)
at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.runUnlockedCleanup(LocalCache.java:3562)
at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.postWriteCleanup(LocalCache.java:3538)
at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$Segment.clear(LocalCache.java:3309)
at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache.clear(LocalCache.java:4322)
at org.apache.beam.repackaged.beam_runners_java_fn_execution.com.google.common.cache.LocalCache$LocalManualCache.invalidateAll(LocalCache.java:4937)
at org.apache.beam.runners.fnexecution.control.JobBundleFactoryBase.close(JobBundleFactoryBase.java:185)
at org.apache.beam.runners.flink.translation.functions.FlinkDefaultExecutableStageContext.close(FlinkDefaultExecutableStageContext.java:46)
at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.closeActual(ReferenceCountingFlinkExecutableStageContextFactory.java:185)
at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.access$200(ReferenceCountingFlinkExecutableStageContextFactory.java:161)
at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory.release(ReferenceCountingFlinkExecutableStageContextFactory.java:149)
at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory.scheduleRelease(ReferenceCountingFlinkExecutableStageContextFactory.java:109)
at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory.access$300(ReferenceCountingFlinkExecutableStageContextFactory.java:40)
at org.apache.beam.runners.flink.translation.functions.ReferenceCountingFlinkExecutableStageContextFactory$WrappedContext.close(ReferenceCountingFlinkExecutableStageContextFactory.java:181)
at org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator.$closeResource(ExecutableStageDoFnOperator.java:188)
at org.apache.beam.runners.flink.translation.wrappers.streaming.ExecutableStageDoFnOperator.close(ExecutableStageDoFnOperator.java:203)
at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:438)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:323)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:703)
at java.lang.Thread.run(Thread.java:748)
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (6ddb2f81c1ab4d6c2b4f258c7cda1c51) switched from RUNNING to FINISHED.
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (6ddb2f81c1ab4d6c2b4f258c7cda1c51).
[assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (6ddb2f81c1ab4d6c2b4f258c7cda1c51) [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 assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 6ddb2f81c1ab4d6c2b4f258c7cda1c51.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - assert_that/Group/GroupByKey -> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0 (1/1) (6ddb2f81c1ab4d6c2b4f258c7cda1c51) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job test_windowing_1536911617.7 (1133fce1c87ca06febd65c880ed9241e) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 1133fce1c87ca06febd65c880ed9241e.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 1133fce1c87ca06febd65c880ed9241e reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job test_windowing_1536911617.7(1133fce1c87ca06febd65c880ed9241e).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 1133fce1c87ca06febd65c880ed9241e.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection c5b52f2713f84aa0c8643928d9607a65: JobManager is shutting down..
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager ad4ae8b7f15ba76683b4965a78c648ba@akka://flink/user/jobmanager_37 for job 1133fce1c87ca06febd65c880ed9241e from the resource manager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher7f92c52d-b638-4583-8f2b-85f6391b3f0b.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher7f92c52d-b638-4583-8f2b-85f6391b3f0b.
[flink-akka.actor.default-dispatcher-5] 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{fcda61277780bbca39c363e995489632}, jobId: 1133fce1c87ca06febd65c880ed9241e).
[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-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 1133fce1c87ca06febd65c880ed9241e from job leader monitoring.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager a93c29c58880375605be76c90671db95 from the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 1133fce1c87ca06febd65c880ed9241e with leader id ad4ae8b7f15ba76683b4965a78c648ba lost leadership.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 1133fce1c87ca06febd65c880ed9241e.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_36.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-18e97659-b809-4bbd-b98b-bd5f219083c9
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher7f92c52d-b638-4583-8f2b-85f6391b3f0b.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_36.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:42221
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 1720 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@2107cac8
.
----------------------------------------------------------------------
Ran 22 tests in 58.913s
OK (skipped=5)
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 1 mins 0.833 secs.
FAILURE: Build failed with an exception.
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/ws/src/sdks/python/build.gradle'> line: 309
* What went wrong:
Execution failed for task ':beam-sdks-python:flinkCompatibilityMatrixBatch'.
> Process 'command 'sh'' finished with non-zero exit value 139
* 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.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 10m 6s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/mzy7rceh4h3qa
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Jenkins build is back to normal :
beam_PostCommit_Python_PVR_Flink_Gradle #10
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/10/display/redirect?page=changes>