Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Duplicate
-
None
-
None
Description
====================================================================== ERROR: test_pardo_unfusable_side_inputs (_main_.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "apache_beam/runners/portability/fn_api_runner_test.py", line 254, in test_pardo_unfusable_side_inputs equal_to([('a', 'a'), ('a', 'b'), ('b', 'a'), ('b', 'b')])) File "apache_beam/pipeline.py", line 425, in _exit_ self.run().wait_until_finish() File "apache_beam/runners/portability/portable_runner.py", line 242, in wait_until_finish beam_job_api_pb2.GetJobStateRequest(job_id=self._job_id)): File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_VR_Flink/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/grpc/_channel.py", line 367, in next return self._next() File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_VR_Flink/src/sdks/python/build/gradleenv/local/lib/python2.7/site-packages/grpc/_channel.py", line 349, in _next self._state.condition.wait() File "/usr/lib/python2.7/threading.py", line 340, in wait waiter.acquire() File "apache_beam/runners/portability/portable_runner_test.py", line 69, in handler raise BaseException(msg) ==================== Timed out after 30 seconds. ==================== BaseException: Timed out after 30 seconds. [...] Segmentation fault (core dumped)
Attachments
Issue Links
- duplicates
-
BEAM-5467 Python Flink ValidatesRunner job issues
- Resolved