问题标签 [apache-storm-flux]

我正在使用 Flux YAML 拓扑定义文件设计 Apache Storm 拓扑。问题是我不知道如何：-

1. 创建一个发送到多个螺栓的流（语法似乎只包含一个“到：”行）。
2. 从单个螺栓发出多个命名流。这在 Apache Storm 中是完全合法的。我担心 Stream 'name:' 行被声明为 'optional - not used' 因此 Flux 似乎不支持 Storm 的这个功能？

我正在使用 Storm Flux (0.10.0) DSL 部署以下拓扑（简化为仅保留相关部分）：

如您所见，我使用的org.elasticsearch.storm.EsBolt其中一个螺栓具有以下构造函数（参见代码）：

应该调用最后一个，因为我在 constructorArgs 中传递了一个 String 和一个 Map。但是当我部署拓扑时，出现以下异常，好像 Flux 无法从类型（字符串、映射）中推断出正确的构造函数：

对可能发生的事情有任何想法吗？以下是Storm Flux 如何找到兼容的构造函数。神奇在于canInvokeWithArgs方法。

这些是 Flux 调试日志，您可以在其中看到 FluxBuilder 如何找到最合适的构造函数：

是否可以在运行时更改拓扑布局？我想在它处于活动状态时更改流分组和螺栓。

提交带有新拓扑布局的 yaml 文件表示它无法部署，因为它已经在运行。

我正在使用 Apache Storm 0.10.0

谢谢

我们正在执行一个 Storm 拓扑LocalCluster。Storm 拓扑执行良好并且能够连接 Storm UI (8090)。但是 Storm UI 没有显示正在运行的拓扑信息。

并提交如下：

我正在尝试在 apache-Storm 中使用并行概念。我想知道如何通过单个拓扑提交多个 spout。

这是我的单一拓扑提交代码

我最近开始使用Apache Storm 。我将 Storm 与Clojure Storm DSL和Leiningen一起使用。

风暴拓扑管理有一个非常酷的工具：Storm Flux。

我的问题是：当我使用 clojure 在 Storm 中编码时，如何使用 Flux？

我正在使用 Flux 1.0.0，并且已将拓扑重写为 YAML 文件。但是我有一些属性曾经是我使用 Storm 驱动程序运行的配置的一部分。

storm.Driver --config myConfig/config.conf

现在有了 Storm Flux，我怎样才能将属性注入config.conf到我的拓扑中？

我目前正在做java -cp myStormJar org.apache.sotrm.flux.Flux --local /src/main/resources/myTopology.yaml

我尝试使用--resources选项，后跟 conf 文件的路径，但它没有注入它。

请参阅这个 Storm-flux YAML 的片段：

使用这个脚本，Storm-UI 显示No. of executors=No。的任务。请建议如何指定编号。Flux YAML 中的任务？提前致谢。

我是 Storm Flux 的新手，现在对如何在 Storm Flux 中配置通用参数感到困惑。例如，org.apache.storm.kafka.sourt.KafkaSpout 定义如下：

还有一个使用此类的示例 YAML 文件：

我的问题是为什么 KafkaSpout 的通用参数没有任何配置？

谢谢！

我正在使用 Storm Flux 1.2.2来部署拓扑。我将记录翻译器传递给 KafkaSpoutConfig（来自 -> https://github.com/apache/storm/blob/master/flux/flux-examples/src/main/resources/kafka_spout.yaml），但得到以下异常：

通量 yaml 配置：

POM 配置：

谢谢