ckchow commented on issue #25374:
URL: https://github.com/apache/beam/issues/25374#issuecomment-1786120280
I think I might be being bit by this while using
RunInference.with_exception_handling, even though in that code the default
seems to be `use_subprocess=False`. I'm seeing occasional logs like the
following from the google dataflow service:
```
Error processing instruction process_bundle-7777374602412410313-190.
Original traceback is
Traceback (most recent call last):
File "apache_beam/runners/common.py", line 1423, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 839, in
apache_beam.runners.common.PerWindowInvoker.invoke_process
File "apache_beam/runners/common.py", line 932, in
apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
File
"/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 439, in __getitem__
self._cache[target_window] = self._side_input_data.view_fn(raw_view)
File "/usr/local/lib/python3.8/site-packages/apache_beam/pvalue.py", line
393, in <lambda>
lambda iterable: from_runtime_iterable(iterable, view_options))
File "/usr/local/lib/python3.8/site-packages/apache_beam/pvalue.py", line
514, in _from_runtime_iterable
head = list(itertools.islice(it, 2))
File
"/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 1251, in _lazy_iterator
self._underlying.get_raw(state_key, continuation_token))
File
"/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 1060, in get_raw
response = self._blocking_request(
File
"/usr/local/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 1105, in _blocking_request
raise RuntimeError(response.error)
RuntimeError: Instruction id was not registered.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]