apache-storm

0热度

1回答

因此，Apache Storm + Trident提供了完全一次的语义。想象我有以下拓扑：在存储器 TridentSpout -> SumMoneyBolt -> SaveMoneyBolt -> Persistent Storage. CalculateMoneyBolt总和的货币值，然后将结果传递给SaveMoneyBolt应的最终值保存到远程存储/数据库。现在，我们计算这些值并仅存储一

0热度

2回答

Storm Nimbus无法正常工作

我是Apache Storm的新手，目前我正在开发一个使用风暴的项目。在试图理解风暴的基础知识的同时，我遇到了灵光和监督员。我开始建立一个远程集群。我编辑了storm.yaml文件并将nimbus和zookeeper设置为localhost。我尝试在我的本地机器上运行我的灵气，动物园管理员。我使用“风暴灵气”启动灵气，但灵气没有启动，而我的动物园管理员正在运行。 enter image descr

0热度

1回答

风暴雨云守护进程错误

我试图在我的Ubuntu上运行Apache风暴。为此，我应该运行nimbus守护进程。问题是，当我键入命令风暴灵气，它给了我一个错误： ERROR StatusLogger File not found in file system or classpath: /usr/lib/storm/cluster.xml ERROR StatusLogger Reconfiguration failed

0热度

1回答

org.apache.storm.multilang.NoOutputException：管道到子进程似乎被破坏！蟒蛇：无法打开文件[错误2]没有这样的文件或目录

每当我尝试在本地运行我的风暴拓扑我得到以下错误： java.lang.RuntimeException: org.apache.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: python: can't open file

1热度

1回答

流媒体应用程序的时间序列窗口

我们正在开发使用Kafka，storm和redis的数据管道应用程序。来自不同系统的实时事件将发布给Kafka，风暴根据配置的规则进行事件处理。状态由redis管理。我们有不同的事件处理之前实现不同WAIT_TIME的要求。我们正在寻找以下选项。我们最初看着风暴窗[滑动或翻滚窗口]，但提供选项仅配置固定的时间间隔。我们需要基于规则的不同wait_time 我们正在探索将事件存储在redis缓存

0热度

4回答

阿帕奇风暴不能访问UI

我的Apache风暴-1.1.0，试图获得在localhost风暴UI：8080，有这样的： org.apache.storm.utils.NimbusLeaderNotFoundException：无法从种子主机[localhost]找到领导灵魂。您是否为config nimbus.seeds指定了一个有效的nimbus主机列表？在org.apache.storm.utils.NimbusC

0热度

1回答

风暴杀拓扑名[-w等待时间-秒]

我要杀死与等待时间秒= 1秒 storm kill topology-name [-w 1] 为该语法是正确的拓扑结构？否则，如何使用-w标志？给出任何示例以等待时间秒来杀死风暴拓扑？

1热度

1回答

喷口类中的我的失败方法只适用于第一个螺栓，从第二个螺栓到其不工作。

注： Bolt1包含前三个素数（2,3,5）的列表。 Bolt2包含第二组素数（7,11,13）的列表。在Bolt3中，只检查数字是否为素数。从第一个螺栓，我能够从喷口类调用Fail（），但从第二个螺栓向前，我不能从喷口类调用Fail（）。拓扑类： ...... TopologyBuilder builder = new TopologyBuilder(); bui

2热度

1回答

如何使用Twitter Heron与Storm Flux

我正在尝试将项目从apache-storm迁移到twitter-heron。经过很多努力，我能够摆脱大部分错误，例如使用className: "org.apache.storm.kafka.ZkHosts"而不是className: "storm.kafka.ZkHosts"。但是，我坚持提交拓扑。我使用Flux将拓扑提交给风暴。当我在ZkState中创建一个CuratorFramework对象

0热度

1回答

在本地运行Storm拓扑时出错

我想在localmode中运行Storm拓扑来测试它。该项目实质上是从卡夫卡壶中取出一些日志，进行一些预处理操作，然后将内容打印在屏幕上。以下是我的拓扑代码： import org.apache.storm.*; import org.apache.storm.generated.*; import org.apache.storm.kafka.*; import org.apache.s