Actually, you do not need to start a Flink cluster beforehand. Because a local cluster will be started in the same process with CliFrontend automatically. The local cluster means "all-in-one-process". "start-cluster-sh" will start one JobManager process and one TaskManager process. It is a standalone cluster.
Compared to the above example, the only change is to update the WindowJoin.jar to your own user jar path. Best, Yang Salva Alcántara <salcantara...@gmail.com> 于2021年1月15日周五 下午4:57写道： > Hi Yang, > > Thanks for your reply. I've given it a try within my container (I > copy-pasted the Dockerfile for it) but running `flink run --target local > my.jar` results in a different error for me: > > "org.apache.flink.client.program.ProgramInvocationException: The main > method > caused an error: Could not create actor system" > > Before executing `flink run --target local my.jar` I have started a flink > cluster via `start-cluster-sh`... > > Salva > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
