![]() |
1
3
你的嘴根本不该睡觉。如果您在通话过程中没有发出任何信号,至少在我熟悉的1.0.0和Forward版本中,Storm将处理对Nextuple的呼叫之间的休眠。 见 https://github.com/apache/storm/blob/v1.2.2/storm-core/src/clj/org/apache/storm/daemon/executor.clj#L667 供参考。等待策略的默认实现在每次调用时休眠一个可配置的间隔(默认为1毫秒)。你可以用 https://github.com/apache/storm/blob/v1.2.2/storm-core/src/jvm/org/apache/storm/Config.java#L1886 或者把等待策略完全替换为 https://github.com/apache/storm/blob/v1.2.2/storm-core/src/jvm/org/apache/storm/Config.java#L1879 . 暴风2.0.0将有一个稍微不同的行为(逐渐更长的睡眠),但它是相同的基本理念。
我认为javadocfornextuple有误导性,所以我们应该修改它。我也不确定
如果你愿意,你可以在 https://issues.apache.org/jira/secure/Dashboard.jspa 解决此问题:) |
![]() |
a a · 为什么在这个可重入锁示例中需要引用计数? 3 年前 |
![]() |
Grant · goroutines有高空闲唤醒电话 3 年前 |
![]() |
hoaz · 如何安全地清理并发映射 7 年前 |
![]() |
Alanpatchi · int基元类型的volatile声明 7 年前 |