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

Reply via email to