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)
