You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Daniel Oliveira (JIRA)" <ji...@apache.org> on 2018/11/02 22:25:00 UTC
[jira] [Updated] (BEAM-5916) Python PostCommit
python:flinkCompatibilityMatrixBatchDOCKER fails
[ https://issues.apache.org/jira/browse/BEAM-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Daniel Oliveira updated BEAM-5916:
----------------------------------
Description:
[https://scans.gradle.com/s/xkcq5m7lh4udq/console-log?task=:beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER]
{noformat}
======================================================================
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)
{noformat}
was:
https://scans.gradle.com/s/xkcq5m7lh4udq/console-log?task=:beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER
======================================================================
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)
> Python PostCommit python:flinkCompatibilityMatrixBatchDOCKER fails
> ------------------------------------------------------------------
>
> Key: BEAM-5916
> URL: https://issues.apache.org/jira/browse/BEAM-5916
> Project: Beam
> Issue Type: Bug
> Components: test-failures
> Reporter: Henning Rohde
> Assignee: Ankur Goenka
> Priority: Major
>
> [https://scans.gradle.com/s/xkcq5m7lh4udq/console-log?task=:beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER]
>
> {noformat}
> ======================================================================
> 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)
> {noformat}
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)