[jira] [Created] (BEAM-8914) state handlerNotFound exception

["Kyle Weaver (Jira)" <ji...@apache.org>]

Kyle Weaver created BEAM-8914:
---------------------------------

             Summary: state handlerNotFound exception
                 Key: BEAM-8914
                 URL: https://issues.apache.org/jira/browse/BEAM-8914
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Kyle Weaver
            Assignee: Maximilian Michels


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)




--
This message was sent by Atlassian Jira
(v8.3.4#803005)