Hello, I am getting the following exception while ...
# troubleshooting
f
Hello, I am getting the following exception while running Stateful functions (locally, on my Windows): The app starts running normally, I can see numerous Flink logs from dispatcher, ingress, etc. and suddenly it crashes, upon receival of the first proto from kinesis, I guess:
Copy code
Caused by: java.lang.NoSuchMethodError: org.apache.flink.statefun.sdk.reqreply.generated.TypedValue$Builder.setValue(Lcom/google/protobuf/ByteString;)Lorg/apache/flink/statefun/sdk/reqreply/generated/TypedValue$Builder;
	at org.apache.flink.statefun.flink.io.common.AutoRoutableProtobufRouter.typedValuePayload(AutoRoutableProtobufRouter.java:72)
	at org.apache.flink.statefun.flink.io.common.AutoRoutableProtobufRouter.route(AutoRoutableProtobufRouter.java:51)
	at org.apache.flink.statefun.flink.io.common.AutoRoutableProtobufRouter.route(AutoRoutableProtobufRouter.java:36)
	at org.apache.flink.statefun.flink.core.translation.IngressRouterOperator.processElement(IngressRouterOperator.java:81)
	at org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:112)
I am using Statefun dependencies of version 3.1.0, and Flink dependencies of version 1.13.1 I have this protobuf dependency in my pom:
Copy code
<dependency>
   <groupId>com.google.protobuf</groupId>
   <artifactId>protobuf-java</artifactId>
   <version>3.21.12</version>
</dependency>
Tried all versions starting from 3.8.0 to 3.21.12, same error. Can't try lower than 3.8.0 because the java proto files in the project won't compile. "statefun-flink-io" transitively brings in protobuf 3.7.1, so I tried excluding it, but no success either, same error. Tried statefun 3.1.1, with Flink 1.13.1, same error. Tried statefun 3.2.0, with Flink 1.14.0, same error. I opened
TypedValue
proto class (from "External Libraries" of IDEA) and it has
Builder
inner class with
setValue(ByteString value)
public method, Any idea what I am doing wrong?