Hello Christopher, It seems to be like a version mismatch, which StateFun version are you using, and what is the Flink version of the cluster that you are trying to submit to?
StateFun 3.1.1 was built with Flink 1.13.5 StateFun 3.2.0 was built with Flink 1.14.3 The version needs to match, since the StateFun job is built on top of internal APIs, and unfortunately these APIs are not guaranteed to remain compatible across versions. This is one of the reasons, where it is generally recommended to use the community provided Docker images, as Flink and Statefun versions are compatible in a single image. Kind regards, Igal. On Wed, Feb 2, 2022 at 4:50 PM Christopher Gustafson <[email protected]> wrote: > Hi everyone, > > > I am trying to run a StateFun job as a jar in an existing cluster. But I > run into a large error which is caused by the following: > > Caused by: java.lang.AbstractMethodError: Method > org/apache/flink/statefun/flink/core/functions/ > FunctionGroupDispatchFactory > .setMailboxExecutor(Lorg/apache/flink/runtime/mailbox/MailboxExecutor;)V > is abstract > > > Any ideas what could be causing this issue? The job I am trying to run is > the shopping-cart from the StateFun playground. I am currently running it > by doing the following: > > > > 1. Add flink-statefun-distribution as a dependency to the maven project > 2. Add the module.yaml file to the resources folder > 3. Compile with mvn clean package > 4. Submit the jar including the dependencies to my cluster using: > ./bin/flink run -c > org.apache.flink.statefun.flink.core.StatefulFunctionsJob > > ~/Workspace/flink-statefun-playground/java/shopping-cart/target/shopping-cart-3.1.1-jar-with-dependencies.jar > > > Thanks in advance, > Christopher > >
