Fariz Hajiyev
01/18/2023, 7:29 AMCaused 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:
<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?