Hello! I was trying to run the python greeter example <https://github.com/apache/flink-statefun/tree/release-2.2.2/statefun-examples> from the statefun example o my own flink cluster (where I use to deploy regular flink jobs) and I follow all setup steps listed here <https://github.com/apache/flink-statefun/blob/release-2.2.2/tools/docker/build-stateful-functions.sh> (which specifies that the core and distribution jar should be copied to flink home directory). But it looks like I'm missing some dependencies as I'm getting message like this (see below). I try to copy over the .jar file under the launcher but it doesn't help much. Any advice on how to fix this?
LED. Diagnostics org.apache.flink.util.FlinkException: Could not create the DispatcherResourceManagerComponent. at org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory.create(DefaultDispatcherResourceManagerComponentFactory.java:256) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:219) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:172) at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:171) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:520) at org.apache.flink.statefun.flink.launcher.StatefulFunctionsClusterEntryPoint.main(StatefulFunctionsClusterEntryPoint.java:99) Caused by: java.lang.IllegalStateException: Unable to locate the launcher jar at org.apache.flink.statefun.flink.launcher.StatefulFunctionsJobGraphRetriever.createPackagedProgram(StatefulFunctionsJobGraphRetriever.java:114) at org.apache.flink.statefun.flink.launcher.StatefulFunctionsJobGraphRetriever.retrieveJobGraph(StatefulFunctionsJobGraphRetriever.java:91) at org.apache.flink.runtime.dispatcher.runner.JobDispatcherLeaderProcessFactoryFactory.createFactory(JobDispatcherLeaderProcessFactoryFactory.java:55) at org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunnerFactory.createDispatcherRunner(DefaultDispatcherRunnerFactory.java:51) at org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory.create(DefaultDispatcherResourceManagerComponentFactory.java:194) ... 6 more Thanks! Le
