Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-8914

state handlerNotFound exception

Details

    Description

      When I run :sdks:python:test-suites:portable:py37:portableWordCountBatch (or py2) locally I get the following exception:

      [grpc-default-executor-1] ERROR sdk_worker._execute - Error processing instruction 18. Original traceback is
      Traceback (most recent call last):
      File "apache_beam/runners/common.py", line 812, in apache_beam.runners.common.DoFnRunner.process
      File "apache_beam/runners/common.py", line 609, in apache_beam.runners.common.PerWindowInvoker.invoke_process
      File "apache_beam/runners/common.py", line 632, in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window
      File "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/bundle_processor.py", line 285, in _getitem_
      self._cache[target_window] = self._side_input_data.view_fn(raw_view)
      File "/usr/local/google/home/kcweaver/go/src/github.com/apache/beam/sdks/python/apache_beam/pvalue.py", line 335, in <lambda>
      lambda iterable: from_runtime_iterable(iterable, view_options))
      File "/usr/local/google/home/kcweaver/go/src/github.com/apache/beam/sdks/python/apache_beam/pvalue.py", line 435, in _from_runtime_iterable
      head = list(itertools.islice(it, 2))
      File "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py", line 683, in _materialize_iter
      self._underlying.get_raw(state_key, continuation_token)
      File "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py", line 555, in get_raw
      continuation_token=continuation_token)))
      File "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py", line 589, in _blocking_request
      raise RuntimeError(response.error)
      RuntimeError: java.lang.IllegalStateException
      at org.apache.beam.runners.fnexecution.state.StateRequestHandlers$StateKeyTypeDelegatingStateRequestHandler.handlerNotFound(StateRequestHandlers.java:224)
      at org.apache.beam.runners.fnexecution.state.StateRequestHandlers$StateKeyTypeDelegatingStateRequestHandler.handle(StateRequestHandlers.java:206)
      at org.apache.beam.runners.fnexecution.state.GrpcStateService$Inbound.onNext(GrpcStateService.java:130)
      at org.apache.beam.runners.fnexecution.state.GrpcStateService$Inbound.onNext(GrpcStateService.java:118)
      at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onMessage(ServerCalls.java:249)
      at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.ForwardingServerCallListener.onMessage(ForwardingServerCallListener.java:33)
      at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.Contexts$ContextualizedServerCallListener.onMessage(Contexts.java:76)
      at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:297)
      at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:738)
      at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
      at org.apache.beam.vendor.grpc.v1p21p0.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      at java.lang.Thread.run(Thread.java:748)

      Attachments

        Activity

          People

            mxm Maximilian Michels
            ibzib Kyle Weaver
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: