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]

Reply via email to