pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.get_execution_plan

StreamExecutionEnvironment.get_execution_plan() → str

Creates the plan with which the system will execute the program, and returns it as a String using a JSON representation of the execution data flow graph. Note that this needs to be called, before the plan is executed.

If the compiler could not be instantiated, or the master could not be contacted to retrieve information relevant to the execution planning, an exception will be thrown.

Returns

The execution plan of the program, as a JSON String.