如何监视flink应用程序?

vmpqdwk3  于 2021-06-24  发布在  Flink
关注(0)|答案(0)|浏览(279)

我知道从ui监视flink应用程序的一种方法是添加累加器并在ui中查看它们,如下所述。还有别的办法吗?
声明计数器:

  1. private LongCounter receivedEvents = new LongCounter()

初始化计数器:

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

此处更新:

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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题