Apache Storm 0.10.0: не могу каждый раз получать свои пользовательские метрики BucketSizeInSecs
Я регистрирую свои пользовательские метрики в своем болте, код, подобный этому, context.registerMetric("et", _executedTuple, 2), этот код просто подсчитывает количество кортежей, выпущенных болтом, и я регистрирую metricconsumer в своей топологии.
Но я просто получаю executeTuple каждые десять секунд, я просто думаю, что метрика должна отправляться каждые 2 секунды (timeBucketSizeInSecs).
Возможно, вы знаете, как решить проблему!