在Storm中禁用自动背压

Question

在Storm的早期版本中，似乎可以通过将topology.backpressure.enable设置为false来禁用自动背压。但是，在最新版本的Storm（我使用的是Storm 2.1.0）中，此选项已删除（或尚未完全删除）。在Config的源代码中，我看到了以下代码片段：

Config

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

在Storm上对自动背压的任何评论/评论，将不胜感激。

Answer 1

您不能完全禁用它，但是您可以很少进行背压检查，以至于它实际上禁用了该功能。尝试将

/**
 * 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";

设置为较大的数字。

有关更多上下文，请参见topology.backpressure.check.millis和the backpressure update code。您可以在JIRA问题上找到有关新背压设计backpressure tracker所做工作的更多信息，该文档中还包含该功能的设计文档。