[BEAM-5642] test_pardo_state_only flaky (times out)

• Type: Bug
• Status: Resolved
• Priority: P1
• Resolution: Abandoned
• Fix Version/s: Missing
• Component/s: sdk-py-core
• Labels: beam-fixit flake
• Assignee: Unassigned
• Reporter: Ahmet Altay
• Created: 04/Oct/18 04:08
• Updated: 13/Jan/22 21:52
• Resolved: 20/Mar/21 02:09

Description

https://builds.apache.org/job/beam_PreCommit_Python_Commit/1577/consoleFull

 
16:43:20 ======================================================================16:43:20 ERROR: test_pardo_state_only (apache_beam.runners.portability.portable_runner_test.PortableRunnerTest)16:43:20 ----------------------------------------------------------------------16:43:20 Traceback (most recent call last):16:43:20 File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py", line 265, in test_pardo_state_only*16:43:20* equal_to(expected))16:43:20 File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/pipeline.py", line 423, in _exit16:43:20 self.run().wait_until_finish()16:43:20 File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/runners/portability/portable_runner.py", line 242, in wait_until_finish*16:43:20* beam_job_api_pb2.GetJobStateRequest(job_id=self._job_id)):16:43:20 File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/target/.tox/py3/lib/python3.5/site-packages/grpc/_channel.py", line 363, in __next_16:43:20 return self._next()16:43:20 File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/target/.tox/py3/lib/python3.5/site-packages/grpc/_channel.py", line 348, in _next*16:43:20* self._state.condition.wait()16:43:20 File "/usr/lib/python3.5/threading.py", line 293, in wait*16:43:20* waiter.acquire()16:43:20 File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/apache_beam/runners/portability/portable_runner_test.py", line 68, in handler*16:43:20* raise BaseException(msg)16:43:20 BaseException: Timed out after 30 seconds.16:43:20 -------------------- >> begin captured stdout << ---------------------