[
https://issues.apache.org/jira/browse/BEAM-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kyle Weaver closed BEAM-8914.
-----------------------------
Fix Version/s: Not applicable
Resolution: Workaround
> 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
> Priority: Major
> Labels: portability-flink
> Fix For: Not applicable
>
>
> 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)
