Как запустить веб-интерфейс диспетчера заданий Flink при запуске Flink из среды IDE

Я хотел бы получить доступ к веб-интерфейсу Flink при его локальном запуске из IDE.

Мне это нужно, потому что я хотел бы получить доступ к счетчикам (аккумуляторам) Flink.


apache-flink
person Robert Metzger    schedule 01.02.2016    source источник

Ответы (2)


arrow_upward
18
arrow_downward

Чтобы запустить веб-интерфейс при локальном запуске Flink, мы должны включить веб-интерфейс в файле FlinkMiniCluster. FlinkMiniCluster - это класс, управляющий запуском всех служб Flink локально.

Включите зависимость:

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
  <version>${flink.version}</version>
</dependency>

Следующий фрагмент кода активирует веб-интерфейс для StreamExecutionEnvironment:

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

Вы также можете использовать RestOptions для настройки сервера:

conf.setInteger(RestOptions.PORT, 8082);
person Robert Metzger    schedule 01.02.2016
comment
apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ - person Georg Heiler; 02.12.2017

arrow_upward
1
arrow_downward

Помимо кода в приведенном выше ответе, в файле pom также требуется следующая зависимость.

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
        <version>${flink.version}</version>
    </dependency>
person Debajyoti Pathak    schedule 30.05.2018