Come posso avviare l'interfaccia web di Gestione lavori Flink quando si esegue Flink da un IDE

Question

Vorrei accedere all'interfaccia Web di Flink quando lo avvio localmente dall'IDE.

Ho bisogno di questo perché mi piacerebbe accedere ai contatori (accumulatori) di Flink.

Answer 1

Per avviare l'interfaccia web quando si avvia Flink localmente, è necessario abilitare l'interfaccia Web nello FlinkMiniCluster. FlinkMiniCluster è la classe che gestisce l'avvio di tutti i servizi Flink localmente.

Il seguente snipped consentirà l'interfaccia web per una StreamExecutionEnvironment:

// set up the execution environment 
Configuration conf = new Configuration(); 
conf.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true); 
final StreamExecutionEnvironment env = LocalStreamEnvironment.createLocalEnvironment(8, conf);