I think I've seen this sometimes as a flake. Best -P. On Tue, Jun 30, 2020 at 11:23 AM Maximilian Michels <[email protected]> wrote:
> 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) > > >
