我知道从ui监视flink应用程序的一种方法是添加累加器并在ui中查看它们,如下所述。还有别的办法吗?
声明计数器:
private LongCounter receivedEvents = new LongCounter()
初始化计数器:
getRuntimeContext().addAccumulator(RECEIVED_COUNTER, receivedEvents);
getRuntimeContext().addAccumulator(ITEM_FETCH_ERROR_COUNTER, itemFetchError);
此处更新:
receivedEvents.add(1l);
anomalyTotalCount.add(1l);
暂无答案!
目前还没有任何答案,快来回答吧!