我在我的bolt中注册了我的自定义指标，代码如下，context.registerMetric("et", _executedTuple, 2)，这段代码只计算了bolt发出的元组的数量，我在我的拓扑中注册了metricconsumer。
但我只是每十秒得到一次执行的元组，我只是认为应该每 2 秒发送一次指标（timeBucketSizeInSecs）。
也许你知道如何解决问题！
我在我的bolt中注册了我的自定义指标，代码如下，context.registerMetric("et", _executedTuple, 2)，这段代码只计算了bolt发出的元组的数量，我在我的拓扑中注册了metricconsumer。
但我只是每十秒得到一次执行的元组，我只是认为应该每 2 秒发送一次指标（timeBucketSizeInSecs）。
也许你知道如何解决问题！