注意:我使用的是Azure HDInsight Storm Linux集群。
有一个Storm UI,它提供了相当好的指标,但它没有给出螺栓之间的延迟。因此,我在每个螺栓的开头和结尾放入了一些日志语句。这样我就可以计算螺栓之间的时间了。不幸的是,这个值有时会返回负值...:/但这应该是不可能的。我使用四个工作进程( JVM ),所以我假设当消息从一个JVM传递到另一个JVM时,它们的系统时钟不同步。
有没有人能回答这些问题:
1) How to reliably get the transfer latency between bolts.
2) How to sync the system