Как контролировать Flink Applications? - PullRequest
0 голосов
/ 22 января 2020

Один из известных мне способов слежения за мобильными приложениями из пользовательского интерфейса - это добавление аккумуляторов и просмотр их в пользовательском интерфейсе, как описано ниже. Есть ли другой способ?

Объявить счетчик:

private LongCounter receivedEvents = new LongCounter() 

Инициализировать счетчик:

getRuntimeContext().addAccumulator(RECEIVED_COUNTER, receivedEvents);
getRuntimeContext().addAccumulator(ITEM_FETCH_ERROR_COUNTER, itemFetchError);

Обновить здесь:

receivedEvents.add(1l); 
anomalyTotalCount.add(1l);

enter image description here

...