Is this a flake? I don't see this in master atm.
-Max
On 27.06.20 02:59, Alex Amato wrote:
Hi,
I was wondering if this is something wrong with my PR
<https://github.com/apache/beam/pull/12084> or an issue in master.
Thanks for your help.
Seeing this in my PR's presubmit
https://ci-beam.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Commit/5382/
Logs
<https://scans.gradle.com/s/7nu4katdr26bq/console-log/raw?task=:sdks:python:test-suites:portable:py2:flinkCompatibilityMatrixBatchLOOPBACK>
======================================================================
ERROR: test_external_transforms (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
==================== Timed out after 60 seconds. ====================
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",
line 204, in test_external_transforms
assert_that(res, equal_to([i for i in range(1, 10)]))
# Thread: <Thread(read_grpc_client_inputs, started daemon 140197933086464)>
File "apache_beam/pipeline.py", line 547, in __exit__
self.run().wait_until_finish()
# Thread: <Thread(Thread-212, started daemon 140198486710016)>
File "apache_beam/runners/portability/portable_runner.py", line 543, in
wait_until_finish
self._observe_state(message_thread)
File "apache_beam/runners/portability/portable_runner.py", line 552, in
_observe_state
for state_response in self._state_stream:
# Thread: <_Worker(Thread-110, started daemon 140197924693760)>
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",
line 413, in next
return self._next()
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",
line 697, in _next
# Thread: <_MainThread(MainThread, started 140200366741248)>
_common.wait(self._state.condition.wait, _response_ready)
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_common.py",
line 138, in wait
_wait_once(wait_fn, MAXIMUM_WAIT_TIMEOUT, spin_cb)
File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_common.py",
line 103, in _wait_once
wait_fn(timeout=timeout)
# Thread: <Thread(read_state, started daemon 140198503495424)>
File "/usr/lib/python2.7/threading.py", line 359, in wait
_sleep(delay)
File "apache_beam/runners/portability/portable_runner_test.py", line 82, in
handler
raise BaseException(msg)
BaseException: Timed out after 60 seconds.
# Thread: <_Worker(Thread-18, started daemon 140198537066240)>
------------------------------------
# Thread: <Thread(Thread-207, started daemon 140199451412224)>
----------------------------------
# Thread: <_Worker(Thread-19, started daemon 140198528673536)>
Ran 82 tests in 461.409s
FAILED (errors=1, skipped=15)
