粗体1.py：import time
# overrides storm.Bolt.processimport json
# overrides storm.Bolt.process
def process(selfBolt
浏览 2提问于2015-12-02得票数 0
回答已采纳
假设我们有以下拓扑而bolt 是最后一个，它将信息保存在数据库中，因此不需要发出任何元组。:77) at storm.petrel.GenericTopology.main(ComponentCommon.java:552)
浏览 0提问于2017-03-26得票数 0
1回答
java.lang.IllegalArgumentException: HBase configuration not found using key 'null' <classpathScope>compile</classpathScope>
<mainClass
浏览 0提问于2016-04-06得票数 0
" 1, "ui.childopts" "-Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" "-Xmx1024m", "storm.cluster.mode" "local", &q
浏览 1提问于2015-05-19得票数 2
org.apache.kafka.common.serialization.StringSerializer");KafkaBolt bolt:149) ~[storm-core-1.0.5.jar:1.0.5]
at org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper.getMessageFromTuple(FieldNam
浏览 0提问于2017-11-03得票数 0
我想在我的风暴拓扑中设置一个螺栓的任务数量。但我找不到办法在clojure里做到这一点。我在文件里也没有看到螺栓规格的任何东西。我是不是遗漏了什么？为了对我的应用程序进行微调，我需要一种设置任务数量的方法。这个是可能的吗？
浏览 7提问于2016-04-24得票数 1
回答已采纳
我试图通过使用Multilang协议来理解Storm拓扑中的消息序列，并使用可靠的消息传递。我一直有一些问题，当Storm报告一个错误时，说“不存在或已经被标记的元组”。”，元组：“Hello”，“World”} end-> BoltA { id：“6524”，元组：“Hello”，“World”} endBoltA -> Storm {命令: emit，id：“43”，锚点：“6
浏览 4提问于2014-06-19得票数 1
回答已采纳
我刚开始使用Storm，我刚刚开始了一个数据架构师培训课程，正是在这个背景下，我面临着今天带来我的问题。是否有一个Storm参数可以通过检索确认来强制编写元组？
浏览 2提问于2020-01-24得票数 0
回答已采纳
在mongodb中使用Apache Storm 2.1.0时，我在Bolt执行中出现错误： java.lang.NullPointerException at org.apache.storm.mongodb.bolt.MongoLookupBolt.execute(MongoL
浏览 20提问于2020-11-02得票数 0
: "blockprocessing-bolt" constructorArgs- id: "transprocessing-bolt"
className: "org.apache.storm.flux.wrappers.bolts.FluxShellBolt"- id: "mong
浏览 0提问于2018-05-26得票数 0
回答已采纳
<init>(PluginsService.java:115) ~[storm_es_bolt-0.0.1-SNAPSHOT.jar:?]<init>(Node.java:146) ~[storm_es_bolt-0.0.1-SNAPSHOT.jar:?]
at org.elasticsearch.node.Node.<init>(Node.java:128) ~[storm_es_bolt-0.0.1-SNAPSHOT.jar:?]at my
浏览 5提问于2016-02-27得票数 0
(FluxBuilder.java:84)at org.apache.storm.flux.Flux.maincomponents: className: "storm.kafka.bolt.selector.DefaultTopicSelector" - "s
浏览 4提问于2015-08-20得票数 0
回答已采纳
我一直在为我们的实验室项目使用Storm进行测试。当我使用Storm bolt执行一些计算任务时，我发现在Storm外部运行计算所用的时间大约是Storm bolt execute()方法内部时间的十分之一。double count =rd.nextDouble(); count *= rd.nextDouble();上面的代码在Storm内完成花费了大约1000毫秒，而在S
浏览 0提问于2017-08-08得票数 0
1回答
;import org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat;
import org.apache.storm.hdfs.bolt.format.DelimitedR
浏览 3提问于2019-03-29得票数 0
1回答
} 聚合的第一步如下： Aggregates.group("$shop", Accumulators.addToSet("batch", "$batch")) 输出： { "_id" : "Q4", "batch" : ["5647", "2314"]} 现在-给定如下所示的另一个集合inventory，我们需要使用$in在上面的"batch"中
浏览 13提问于2020-01-28得票数 0
回答已采纳
我需要在LocalCluster模式下运行多个storm项目。ProjectA->TopologyA->Spout1(listing to some stream X )->Bolt1->Bolt2ProjectC->TopologyC->Spout1(listing to some stream Z )-&g
浏览 4提问于2018-04-26得票数 0
;import org.apache.storm.hdfs.bolt.AbstractHdfsBolt;import org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat;
import org.apac
浏览 3提问于2014-11-03得票数 5
我从克隆了Storm源代码的最新版本(主版)。我正在使用Ubuntu 14.02。INFO b.s.u.ShellProcess - Storm multilang serializer: backtype.storm.multilang.JsonSerializer171302 [Thread-1226-__acker] INFO b.s.d.executor - Prepared bolt __acker- Preparin
浏览 0提问于2015-08-03得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号