Flink programs can run distributed on clusters of many machines. There are two ways to send a program to a cluster for execution:
The command line interface lets you submit packaged programs (JARs) to a cluster (or single machine setup).
Please refer to the Command Line Interface documentation for details.
The remote environment lets you execute Flink Java programs on a cluster directly. The remote environment points to the cluster on which you want to execute the program.
If you are developing your program as a Maven project, you have to add the
flink-clients
module using this dependency:
The following illustrates the use of the RemoteEnvironment
:
Note that the program contains custom user code and hence requires a JAR file with the classes of the code attached. The constructor of the remote environment takes the path(s) to the JAR file(s).