pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.execute_async

StreamExecutionEnvironment.execute_async(job_name: str = 'Flink Streaming Job') → pyflink.common.job_client.JobClient

Triggers the program asynchronously. The environment will execute all parts of the program that have resulted in a “sink” operation. Sink operations are for example printing results or forwarding them to a message queue. The program execution will be logged and displayed with a generated default name.

Parameters

job_name – Desired name of the job.

Returns

A JobClient that can be used to communicate with the submitted job, completed on submission succeeded.