在使用Storm 1.1.0和我的拓扑时，我遇到了一个问题，当拓扑有一个具有高延迟的Bolt时，Storm会重新调度或让螺栓和喷嘴崩溃。在3分钟内工作“很好”(在Bolt中只有2000个已破解的元组)。然后Bolts延迟上升到60-100ms而不是10ms，Storm开始“重新分配”(Log in the Nimbus)执行器。那么UI中的所有统计数据都将变为0。因为我是在实际拓扑的Spout中处理文件，所以不能重新打开这些文件。我在
浏览 6提问于2017-08-18得票数 0
一旦它处理了所有的msg，它就不会等待更多的msg和崩溃。如何使风暴拓扑只处理最新的消息."
className: "org.apache.storm.spout.SchemeAsMultiScheme"spouts:
浏览 0提问于2018-05-26得票数 0
回答已采纳
:392)at org.apache.storm.flux.FluxBuilder.buildSpout(FluxBuilder.java:361)at org.apache.s
浏览 4提问于2015-08-20得票数 0
回答已采纳
在mongodb中使用Apache Storm 2.1.0时，我在Bolt执行中出现错误： java.lang.NullPointerException at org.apache.storm.mongodb.bolt.Mon
浏览 20提问于2020-11-02得票数 0
1回答
;import org.apache.storm.StormSubmitter;
import org.apache.storm.tuple.Values;
import org.apache.storm.kafka.bolt.K
浏览 3提问于2019-03-29得票数 0
我已经设置了storm拓扑(1 worker)，其中spout(在java中)从redis出队(使用blpop)事件并传输到bolts。线程，50-bolt线程)。在集群中没有看到网络延迟/丢包。平均处理延迟为100ms。如何在生产中找到原因来修复它。storm_jedis.RedisQueueSpout (:use [backtype.storm clojure config]) {"1
浏览 10提问于2018-09-05得票数 1
回答已采纳
Version Info: "org.apache.storm" % "storm-kafka-client我试着调优配置，比如这些螺栓的并行度，max-spout-pending，等等，看看我能从中得到多大的规模。经过一些配置后，config/result如下所示：
浏览 0提问于2018-10-27得票数 1
1回答
-1",new MySpout(),1); .shuffleGrouping("SPOUT在风暴-核心-1.0.1.jar:1.0.1在org.apache.storm.utils.Utils.getSetComponentObject(Utils.java:430) ~风暴-核心-1.0.1线程-15错误o.a.s.d.worker -服务器初始化错误
浏览 1提问于2016-07-14得票数 2
回答已采纳
;import org.apache.storm.generated.StormTopology;import org.apache.storm.task.OutputCollector;
import org.apache.s
浏览 8提问于2019-10-02得票数 0
回答已采纳
假设我们有以下拓扑而bolt 是最后一个，它将信息保存在数据库中，因此不需要发出任何元组。:441) at org.apache.storm.generated.Compone
浏览 0提问于2017-03-26得票数 0
1回答
我正在尝试使用ActiveMQ队列作为Apache Storm Spout。
我使用"INDIVIDUAL_ACK“策略。在我的想法中，我计划定期触发session.recover()，以重新发送不会被确认的消息( Bolt处理链中的错误)。但是如果我这样做了，所有与Storm tuple相对应的当前正在处理的消息都将被重新发送。我会试着限制这种现象。理想情况下，我希望设置一个延迟参数，所有较早发送的消息都不应重新发送此延迟(此延迟还应与<e
浏览 2提问于2016-05-19得票数 0
如果我将TOPOLOGY_MAX_SPOUT_PENDING设置为1，那么这一切都能工作，但是一次只能处理一个元组，Bolt1 &2最终等待Bolt4准备就绪。spout.py：import random
def nextTuple(selfSpout()
浏览 2提问于2015-12-02得票数 0
回答已采纳
import java.util.Map;import org.apache.storm.ILocalCluster;import org.apache.storm.generated.StormTopology;
import org.apache.storm.spout</
浏览 1提问于2017-02-28得票数 0
回答已采纳
;import org.apache.storm.hdfs.bolt.AbstractHdfsBolt;import org.apache.storm.hdfs.bolt.format.De
浏览 3提问于2014-11-03得票数 5
conf.put("kafka.broker.config", props); KafkaBolt bolt", kafkaSpout); builder.se
浏览 2提问于2016-08-31得票数 2
2回答
如何利用Twitter与风暴通量
、、、、
经过很长时间的挣扎，我能够摆脱大部分的错误，比如使用className: "org.apache.storm.kafka.ZkHosts"而不是className: "storm.kafka.ZkHosts我的萤火虫components: className: "org.apache.storm.kafka.ZkHosts"
浏览 4提问于2017-07-17得票数 2
回答已采纳
/storm-kafka "0.9.5"] [org.apache.kafkaStormSubmitter LocalCluster spout.SchemeAsMultiScheme]
[storm.kafka ZkHosts SpoutConf
浏览 3提问于2015-11-02得票数 1
回答已采纳
这是构建拓扑的代码： config.setDebug(true); builder.setBolt("word-spitter", new WordSpitterBolt()).shuffleGrouping("line-reader-spout:149) ~[storm-core-1.0.5.jar:1.0.5]
浏览 0提问于2017-11-03得票数 0
但是我收到的错误是'INFO org.apache.storm.zookeeper.server.SessionTrackerImpl - SessionTrackerImpl exited loop!import java.util.Arrays; import backtype.storm.LocalCluster;import backtype.storm.topology.TopologyBuilder;
浏览 0提问于2017-04-19得票数 0
1回答
风暴创建拓扑
、、
(NIOServerCnxn.java:228) [storm-core-1.0.0.jar:1.0.0]import org.apache.storm.tuple.Values;
//impo
浏览 2提问于2016-04-14得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号