问题标签 [apache-storm-flux]

当我尝试部署使用 Flux 开发的 Apache Storm jar 时，出现以下错误 enter link description here

我的 Flux 文件在这里 输入链接描述

我们有一些用 1.0.6 编写的 Storm 拓扑，并且正在测试将它们转换为 2.2.0。

在 1.0.6 中，我们有如下类，用于在 IDE 中运行/调试：

在 2.2.0 世界中做同样的事情没有运气，POM 有：

尝试了一些事情（将“--local”更改为“local”等），但最新尝试出现以下错误。是否仍然可以使用 Flux.main() 来复制 1.0.6 中发生的事情（如果是这样，将感谢语法帮助）还是我们需要以编程方式切换到另一种方式？

我几乎没有需要使用stormcrawler 抓取的网址。根据[链接] https://medium.com/analytics-vidhya/web-scraping-and-indexing-with-stormcrawler-and-elasticsearch-a105cb9c02ca[/link ]我跟着所有步骤，并在我的弹性中被刮掉并加载了内容。

根据上面的博客，他使用 Flux 命令将拓扑注入 ES。

这会将 url 注入 ES。我在 Flux 中跟随同一个类并创建了一个主类

并通过 maven run pythonstorm.py jar target/stormcrawlertest-1.0-SNAPSHOT.jar com.my.sitescraper.main.SiteScraper 清理和打包这不是向 ES 注入任何 url。

我错过了什么。

我们有一个 topology.message.timeout.secs = 300 秒的拓扑。最近，我们遇到了一个问题，即 spout 后的第一个 bolt 的容量达到了 ~2。bolt 开始处理元组的速度非常慢（它在 spout 发出元组 5 分钟后开始处理元组）。几分钟后，spout 发出元组，但在 bolt 开始处理之前，元组超时。

奇怪的是元组失败与发出之间的时间差是 10 分钟。

预期元组应该在 5 分钟后失败（配置为 300 秒）。

关于为什么没有真正考虑配置超时的任何想法/信息都会非常有帮助。是否有任何其他配置会影响元组超时？