Re: Moving from single-node, Maven examples to cluster execution

All right, I figured I’d have to do shading, but hadn’t gotten around to experimenting. I’ll try it out. Prez Cannady p: 617 500 3378 e: revp...@opencorrelate.org GH: https://github.com/opencorrelate LI: https://www.li

Re: Moving from single-node, Maven examples to cluster execution

Hi Prez, You need to build a jar with all your dependencies bundled inside. With maven you can use maven-assembly-plugin for this, or with SBT there's sbt-assembly. Once you've done this, you can login to the JobManager node of your Flink cluster, copy the jar across and use the Flink command lin

Moving from single-node, Maven examples to cluster execution

Having a hard time trying to get my head around how to deploy my Flink programs to a pre-configured, remote Flink cluster setup. My Mavenized setup uses Spring Boot (to simplify class path handling and generate pretty logs) to execute provision a StreamExecutionEnvironment with Kafka sources an