Hi all. Expect to have such a mode of submission. Build the job directly in the Environment, and then submit the job in yarn mode. Just like RemoteStreamEnvironment, as long as you specify the parameters of the yarn cluster (host, port) or yarn configuration directory and HADOOP_USER_NAME, you can use the topology built by Env to submit the job . This submission method is best to minimize the transmission of resources required by yarn to start flink-jobmanager and taskmanagerrunner to ensure that flink can deploy job on the yarn cluster as quickly as possible. The simple demo as shown in the picture .the parameter named 'env' containes all the operators about job ,like sources,maps,etc..
Thank you for your attention.