Forgot to include the user mailing list in my previous email. On Fri, Oct 15, 2021 at 12:27 PM Igal Shilman <i...@apache.org> wrote:
> Hello, > > Is there a specific reason you are using the 2.x branch? This is quite old > and most importantly it is not compatible with the 3.x branch. > If you are starting a new project, I'd highly recommend starting with > StateFun 3.1. > > Igal. > > > On Thu 14. Oct 2021 at 08:34, Le Xu <sharonx...@gmail.com> wrote: > >> 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 >> >> >>
