我有一个Apache Storm Topology，可以接受来自多个Kafka主题的消息。builder.setSpout(SPOUT_ONE_ID, kafkaSpout_A, 1);builder.setBolt(BOLT_ID, myBolt, 1).shuffleGrouping(SPOUT_ONE_ID).shuffleGrouping(SPOUT_TWO_ID);
浏览 13提问于2016-08-11得票数 0
回答已采纳
我正在使用pyleus --verbose local xyz_topology.jar运行风暴拓扑“storm-1.0.0, pyleus-0.3.0, centos-6.6”并得到错误
Running: java -client -Ddaemon.name-2.5.jar:/usr/local&
浏览 3提问于2016-05-15得票数 1
2回答
在这些版本之间，storm将所有包名从backtype更改为org.apache。在这种情况下，最好的策略是什么？有什么地方发布的maven技巧可以自动更改包名吗？
浏览 2提问于2016-08-25得票数 2
回答已采纳
(StormSubmitter.java:273)at org.apache.storm.generated.Nimbus$Client.recv_submitTopology(Nimbus.java:306)
at org.apache.storm.generated.Nimbus(StormSubmitter.java:326
浏览 4提问于2019-06-12得票数 0
2回答
我使用Java类向Storm集群提交拓扑，我还计划使用Java类来扼杀拓扑。但是按照的说法，下面的命令是用来杀死拓扑的，并且没有Java (这是有充分理由的)。storm kill {stormname}另外，如何获得风暴群中运行拓扑的状态？
浏览 4提问于2013-12-27得票数 10
回答已采纳
我想在Apache storm运行时，在一个新的jar文件中添加新的逻辑。向它提供新jars的方法是将它们复制到它的extlib。问题是当storm运行时，这个库中的jars被它锁定，并且新的jars不会被加载。它似乎在加载时读取jar类，并且不能在运行时重新读取它们。谁能给我一个关于如何在运行时向Storm添加新jars的提示？
浏览 13提问于2019-01-23得票数 0
我已经建立了一个项目，试图运行标准的"ExclamationTopology“在内存中的风暴版本，由IntelliJ IDE触发。这就是我的POM.xml： </plugin> </build>
连同我的拓扑的示例源代码topologyName = args[0];
浏览 1提问于2018-02-25得票数 0
回答已采纳
我们有一个运行着3个节点和多个拓扑的storm集群。我们在java 1.8.0_162中使用apache-storm-1.2.2 目前我们有一个问题，一个随机拓扑在错误发生后在随机时间停止发射，并且Netty服务器不可用。因为我们没有改变storm bolts发出或执行数据的逻辑，所以我们目前不知道如何抛出这样的错误。此外，为什么整个拓扑在出现这样的错误后停止工作，这也是值得怀疑的。(Server.java:134) ~[storm-
浏览 41提问于2019-09-24得票数 0
在运行风暴拓扑以读取Kafka主题并将数据写入Hive表时，我正在获取IllegalAccesserror :错误详细信息如下所示：我的风暴拓扑代码： public static final String KAFKA_SPOUT_ID = "kafka-spoutversion>0.0.1-SNAPSHOT</ver
浏览 19提问于2016-03-19得票数 4
我要在配置为单个本地群集的计算机上部署Storm拓扑。我已经将conf/storm.yaml配置为使用storm.scheduler: "org.apache.storm.scheduler.resource.ResourceAwareScheduler"拓扑部署成功。但是，我从Sigar库收到一个错误，指出无法获取进程ID以在我的拓扑上使用CPUMetric。.jar库复制到apache-sto
浏览 25提问于2019-03-13得票数 0
回答已采纳
2回答
我已经在我的机器上配置了Storm。Zookeeper、Nimbus和Supervisor运行正常。现在我想向这个storm提交一个拓扑。我正在尝试使用storm jar。但是我不能提交它。
浏览 1提问于2013-09-19得票数 7
回答已采纳
我是Apache Storm的新手，正在尝试建立一个多节点集群。我的zookeeper和Nimbus运行在一台机器上，而supervisors运行在另一台机器上。在配置阶段，我会将拓扑提交给我的主管。在我的集群设置中，机器之间的连接可能会丢失一段时间。那么，即使失去了与nimbus/zookeeper的连接，我的主管也会独立工作吗？
向您致敬，Remya
浏览 0提问于2016-01-14得票数 1
这是我第一次使用Apache，我有以下问题。对于我的应用程序，我有这样的要求:对于使用我的应用程序的每个用户来说，拓扑图是不同的，而且每个用户也可以有多个拓扑图。因此，我的想法是使用拓扑生成器动态创建拓扑图。, defaultConf.get(Config.STORM_THRIFT_TRANSPORT_PLUGIN));
当在本地集群上运行此拓扑时(没有nimbus配置)，一切都正常。它只是一个库，包含了我所有可用的螺栓和喷口，但我仍
浏览 3提问于2015-11-29得票数 1
回答已采纳
由于某些原因，当我试图在Storm集群上运行拓扑时，会出现以下错误： at kafka.utils.Logging$class.logger(Logging.scala下面是我包含的依赖项：
<dependencies&g
浏览 5提问于2015-10-10得票数 5
回答已采纳
6回答
我们在伪模式下执行Storm拓扑。但是Storm没有显示正在运行的拓扑信息。
重新启动的暴风UI进程也没有用。是否需要特殊的配置来显示storm中运行的拓扑？
浏览 3提问于2015-02-12得票数 2
回答已采纳
我担心如何使其实时拓扑。我想如果我修改源文件意味着添加一条新记录，它应该出现在我的目标文件中，我将如何做到这一点，而不重新部署我的拓扑在cluster.What上，否则我需要配置以实现此behavior.Below是本地提交拓扑的代码
浏览 2提问于2013-10-22得票数 0
我正在尝试风暴分析呈现import backtype.storm.tuple.Fields
浏览 31提问于2017-08-25得票数 1
回答已采纳
我偶然发现声称将Samza与Storm进行了对比，但它似乎只解决了实现细节问题。
这两个分布式计算引擎的用例有什么不同？每个工具适合哪种类型的工作？
浏览 0提问于2015-03-18得票数 31
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
