You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Beam JIRA Bot (Jira)" <ji...@apache.org> on 2022/03/27 16:59:00 UTC
[jira] [Updated] (BEAM-13859) Test flake: test_split_half_sdf
[ https://issues.apache.org/jira/browse/BEAM-13859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Beam JIRA Bot updated BEAM-13859:
---------------------------------
Labels: flake stale-assigned (was: flake)
> Test flake: test_split_half_sdf
> -------------------------------
>
> Key: BEAM-13859
> URL: https://issues.apache.org/jira/browse/BEAM-13859
> Project: Beam
> Issue Type: Bug
> Components: test-failures
> Reporter: Kyle Weaver
> Assignee: Chamikara Madhusanka Jayalath
> Priority: P1
> Labels: flake, stale-assigned
>
> > raise RuntimeError(result.error)
> E RuntimeError: Traceback (most recent call last):
> E File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/data_plane.py", line 487, in input_elements
> E element = received.get(timeout=1)
> E File "/usr/lib/python3.7/queue.py", line 178, in get
> E raise Empty
> E _queue.Empty
> E
> E During handling of the above exception, another exception occurred:
> E
> E Traceback (most recent call last):
> E File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py", line 267, in _execute
> E response = task()
> E File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py", line 340, in <lambda>
> E lambda: self.create_worker().do_instruction(request), request)
> E File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py", line 581, in do_instruction
> E getattr(request, request_type), request.instruction_id)
> E File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py", line 618, in process_bundle
> E bundle_processor.process_bundle(instruction_id))
> E File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py", line 985, in process_bundle
> E expected_inputs):
> E File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/data_plane.py", line 490, in input_elements
> E raise RuntimeError('Channel closed prematurely.')
> E RuntimeError: Channel closed prematurely.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)