【Flink修改Web应用的端口号】

Flink修改Web应用的端口号

 

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

if(env instanceof LocalStreamEnvironment){

Field field =env.getClass().getSuperclass().getDeclaredField("configuration");  

field.setAccessible(true);

Configuration configuration = (Configuration) field.get(env);

configuration.setString("rest.bind-port", "23090");

} else{

//RemoteStreamEnvironment

}