我在bolt中注册自定义度量,代码如下,context.registermetric(“et”,\u executedtuple,2),这段代码只计算bolt发出的元组数,然后在拓扑中注册metricconsumer。
但是我只是每10秒得到一个executedtuple,我只是认为度量应该每2秒发送一次(timebucketsizeinsecs)。
也许你知道怎么解决这个问题!
我在bolt中注册自定义度量,代码如下,context.registermetric(“et”,\u executedtuple,2),这段代码只计算bolt发出的元组数,然后在拓扑中注册metricconsumer。
但是我只是每10秒得到一个executedtuple,我只是认为度量应该每2秒发送一次(timebucketsizeinsecs)。
也许你知道怎么解决这个问题!
暂无答案!
目前还没有任何答案,快来回答吧!