code: public PythonStreamExecutionEnvironment create_remote_execution_environment(
  		String host, int port, String... jar_files) {
  		return new PythonStreamExecutionEnvironment(
  			StreamExecutionEnvironment.createRemoteEnvironment(host, port, jar_files), new Path(localTmpPath), scriptName);
  	}
docs: A thin wrapper layer over {@link StreamExecutionEnvironment#createRemoteEnvironment(String, int, String...)}.
  
  @param host The host name or address of the master (JobManager), where the
  program should be executed.
  @param port The port of the master (JobManager), where the program should
  be executed.
  @param jar_files The JAR files with code that needs to be shipped to the
  cluster. If the program uses user-defined functions,
  user-defined input formats, or any libraries, those must be
  provided in the JAR files.
  @return A remote environment that executes the program on a cluster.