beam-commits 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_Python_PVR_Flink_Gradle #6
Date Thu, 13 Sep 2018 23:51:31 GMT
See <https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/6/display/redirect?page=changes>

Changes:

[apilloud] [BEAM-4704] Disable enumerable rules, use direct runner

------------------------------------------
[...truncated 6.28 MB...]
[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]]>
[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
 >
[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) (4a8e3e9ac021dd141063799bfabe4a9d) 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) (4a8e3e9ac021dd141063799bfabe4a9d).
[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) (4a8e3e9ac021dd141063799bfabe4a9d) [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 -> 19Create/Read/Impulse.None/jenkins-docker-apache.bintray.io/beam/python:latest:0
-> ToKeyedWorkItem 4a8e3e9ac021dd141063799bfabe4a9d.
[flink-akka.actor.default-dispatcher-5] 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) (4a8e3e9ac021dd141063799bfabe4a9d) switched from RUNNING to FINISHED.
[grpc-default-executor-0] 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) (cdea398e199c538cf6b19038096c1945) 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) (cdea398e199c538cf6b19038096c1945).
[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) (cdea398e199c538cf6b19038096c1945) [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 cdea398e199c538cf6b19038096c1945.
[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) (cdea398e199c538cf6b19038096c1945) switched from RUNNING to FINISHED.
[grpc-default-executor-0] INFO sdk_worker.run - Got work 10
[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_0
output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/ReadSplits
output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/Reshuffle/RemoveRandomKeys
output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Create/Read/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)
output_tags=['out']>
[grpc-default-executor-0] 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-0] 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-0] 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-0] 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-0] 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-2] 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-2] 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-2] INFO bundle_processor.process_bundle - finish <DataOutputOperation
 >
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DataOutputOperation
 >
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation WindowInto(WindowIntoFn)
output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation Map(<lambda
at fn_api_runner_test.py:269>) output_tags=['out']>
[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) (cc0bfb65a338b8946809d41dd1bb9bed) 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) (cc0bfb65a338b8946809d41dd1bb9bed).
[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) (cc0bfb65a338b8946809d41dd1bb9bed) [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 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
cc0bfb65a338b8946809d41dd1bb9bed.
[flink-akka.actor.default-dispatcher-5] 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) (cc0bfb65a338b8946809d41dd1bb9bed) switched from RUNNING to FINISHED.
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/ReadSplits
output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/Reshuffle/RemoveRandomKeys
output_tags=['out']>
[grpc-default-executor-0] INFO bundle_processor.process_bundle - start <DoOperation Create/Read/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)
output_tags=['out']>
[grpc-default-executor-0] 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-0] 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-0] 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-0] 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-0] 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-0] 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-0] 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-0] 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) (04efab98ef5a1ef296af5373b9b66559) 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) (04efab98ef5a1ef296af5373b9b66559).
[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) (04efab98ef5a1ef296af5373b9b66559) [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 04efab98ef5a1ef296af5373b9b66559.
[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) (04efab98ef5a1ef296af5373b9b66559) switched from RUNNING to FINISHED.
[grpc-default-executor-0] INFO sdk_worker.run - Got work 11
[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-0] 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-0] 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-0] 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-0] 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-0] 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-0] 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-0] 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-0] 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) (260e0a8b7be38c0014aa274f04cfec73) 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) (260e0a8b7be38c0014aa274f04cfec73).
[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) (260e0a8b7be38c0014aa274f04cfec73) [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 GroupByKey
-> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0
260e0a8b7be38c0014aa274f04cfec73.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/1)
(c5c284e222e5142fcf113d07a0514565) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for ToKeyedWorkItem (1/1) (c5c284e222e5142fcf113d07a0514565).
[ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task ToKeyedWorkItem (1/1) (c5c284e222e5142fcf113d07a0514565) [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 ToKeyedWorkItem
c5c284e222e5142fcf113d07a0514565.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- GroupByKey -> 24GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0
(1/1) (260e0a8b7be38c0014aa274f04cfec73) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- ToKeyedWorkItem (1/1) (c5c284e222e5142fcf113d07a0514565) switched from RUNNING to FINISHED.
[grpc-default-executor-2] INFO sdk_worker.run - Got work 13
[grpc-default-executor-2] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Match
output_tags=['out']>
[grpc-default-executor-2] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Unkey
output_tags=['out']>
[grpc-default-executor-2] INFO bundle_processor.process_bundle - start <DoOperation assert_that/Group/Map(_merge_tagged_vals_under_key)
output_tags=['out']>
[grpc-default-executor-2] INFO bundle_processor.process_bundle - start <DataInputOperation
 receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder],
IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-2] INFO bundle_processor.process_bundle - finish <DataInputOperation
 receivers=[ConsumerSet[.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder],
IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]>
[grpc-default-executor-2] 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-2] 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-2] 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-2] INFO sdk_worker.run - No more requests from control plane
[grpc-default-executor-2] INFO sdk_worker.run - SDK Harness waiting for in-flight requests
to complete
[grpc-default-executor-2] INFO data_plane.close - Closing all cached grpc data channels.
[grpc-default-executor-2] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged
up for unknown endpoint.
[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) (5cbd5785e8f4c3670962f38eef8f9695) 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) (5cbd5785e8f4c3670962f38eef8f9695).
[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) (5cbd5785e8f4c3670962f38eef8f9695) [FINISHED]
[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 assert_that/Group/GroupByKey
-> 42assert_that/Group/GroupByKey/GroupByWindow.None/jenkins-docker-apache.bintray.io/beam/python:latest:0
5cbd5785e8f4c3670962f38eef8f9695.
[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) (5cbd5785e8f4c3670962f38eef8f9695) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
- Job test_windowing_1536882686.2 (1cc04250610496c08f5456872ca6f81d) switched from state RUNNING
to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator
- Stopping checkpoint coordinator for job 1cc04250610496c08f5456872ca6f81d.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore
- Shutting down
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher
- Job 1cc04250610496c08f5456872ca6f81d reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster
- Stopping the JobMaster for job test_windowing_1536882686.2(1cc04250610496c08f5456872ca6f81d).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster
- Close ResourceManager connection 563043c93c24beb767a2a0eaeb705310: JobManager is shutting
down..
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool
- Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcActor
- The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started
yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing
is started.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting
down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager
- Disconnect job manager 8ab026b17dc17ceca12aece01f644b16@akka://flink/user/jobmanager_37
for job 1cc04250610496c08f5456872ca6f81d from the resource manager.
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint
- Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Close JobManager connection for job 1cc04250610496c08f5456872ca6f81d.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher
- Stopping dispatcher akka://flink/user/dispatcher2b2dcc5d-0291-4996-9856-9f287cbd7c63.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher
- Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher2b2dcc5d-0291-4996-9856-9f287cbd7c63.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool
- Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
- Closing the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
- Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
- Unregister TaskManager a5769c39d6934ce69142b5da172f6930 from the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- JobManager for job 1cc04250610496c08f5456872ca6f81d with leader id 8ab026b17dc17ceca12aece01f644b16
lost leadership.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable
- Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0,
heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{805b46a2f0336d3f59504323a46fc07a}, jobId: 1cc04250610496c08f5456872ca6f81d).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService
- Remove job 1cc04250610496c08f5456872ca6f81d from job leader monitoring.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Close JobManager connection for job 1cc04250610496c08f5456872ca6f81d.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Stopping TaskExecutor akka://flink/user/taskmanager_36.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager
- Shutting down TaskExecutorLocalStateStoresManager.
[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.io.disk.iomanager.IOManager
- I/O manager removed spill file directory /tmp/flink-io-c47f2a6e-deab-4868-b670-3f55f0502280
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment
- Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher
- Stopped dispatcher akka://flink/user/dispatcher2b2dcc5d-0291-4996-9856-9f287cbd7c63.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService
- Stop job leader service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
- Stopped TaskExecutor akka://flink/user/taskmanager_36.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
- Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache
- Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache
- Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped
BLOB server at 0.0.0.0:40319
[flink-akka.actor.default-dispatcher-3] 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 2012 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@be62b8a6
.
======================================================================
ERROR: test_assert_that (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "apache_beam/runners/portability/portable_runner_test.py", line 174, in test_assert_that
    assert_that(p | beam.Create(['a', 'b']), equal_to(['a']))
  File "apache_beam/pipeline.py", line 414, in __exit__
    self.run().wait_until_finish()
  File "apache_beam/runners/portability/portable_runner.py", line 202, in wait_until_finish
    beam_job_api_pb2.GetJobStateRequest(job_id=self._job_id)):
  File "<https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/ws/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/grpc/_channel.py",>
line 366, in next
    return self._next()
==================== Timed out after 30 seconds. ====================
  File "<https://builds.apache.org/job/beam_PostCommit_Python_PVR_Flink_Gradle/ws/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/grpc/_channel.py",>
line 348, in _next

    self._state.condition.wait()
# Thread: <Thread(Thread-5, started daemon 140337741055744)>

# Thread: <Thread(wait_until_finish_read, started daemon 140337749448448)>

# Thread: <_MainThread(MainThread, started 140337901573888)>
  File "/usr/lib/python2.7/threading.py", line 340, in wait
    waiter.acquire()
  File "apache_beam/runners/portability/portable_runner_test.py", line 65, in handler
    raise BaseException(msg)
BaseException: Timed out after 30 seconds.

----------------------------------------------------------------------
Ran 22 tests in 92.646s

FAILED (errors=1, skipped=5)

> Task :beam-sdks-python:flinkCompatibilityMatrixStreaming FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreaming (Thread[Daemon worker,5,main]) completed.
Took 1 mins 34.598 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:flinkCompatibilityMatrixStreaming'.
> Process 'command 'sh'' finished with non-zero exit value 1

* 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 11m 20s
59 actionable tasks: 54 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/7kjcfivlei3mc

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

Mime
View raw message