在暴风雨中禁用自动背压

Question

在早期版本的Storm中，似乎可以通过将topology.backpressure.enable设置为false来禁用自动背压。但是，对于Storm的最新版本(我正在使用Storm2.1.0)，这个选项已经被删除(或者还没有完全删除)。在Config的源代码中，我看到了以下代码片段：

/**
 * Whether to enable backpressure in for a certain topology.
 *
 * @deprecated: In Storm 2.0. Retained for enabling transition from 1.x. Will be removed soon.
 */
@Deprecated
@IsBoolean
public static final String TOPOLOGY_BACKPRESSURE_ENABLE = "topology.backpressure.enable";

有人知道如何禁用此功能吗？其目的是要对实验进行细粒度的控制，我希望避免此特性的副作用。

如有任何关于风暴自动背压的评论或评论，将不胜感激。

Answer 1

您不能完全禁用它，但是您可以使反压力检查发生得太少，以至于它有效地禁用了该功能。尝试将topology.backpressure.check.millis设置设置为大数字。

有关更多上下文，请参见背压更新代码和背压跟踪器。您可以在JIRA问题上找到关于为新的背压设计这里所做的工作的更多信息，其中也有针对该特性的设计文档。