如何使用Apache storm作为复杂事件处理器
Apache Storm是一个开源的分布式实时计算系统，可以用作复杂事件处理器（CEP）。它提供了高度可扩展的、容错的、实时的数据流处理能力，适用于处理大规模的实时数据流。
使用Apache Storm作为复杂事件处理器的步骤如下：
- 安装和配置Apache Storm：首先，需要下载并安装Apache Storm，并配置相关的环境变量。可以从官方网站（https://storm.apache.org/）下载最新版本的Apache Storm，并按照官方文档进行安装和配置。
- 编写Topology：Topology是Apache Storm中的计算逻辑，用于定义数据流的处理流程。可以使用Java、Python或Clojure等编程语言来编写Topology。Topology由Spout和Bolt组成，Spout用于从数据源获取数据流，Bolt用于对数据流进行处理和转换。
- 定义数据流：在Topology中，需要定义数据流的来源和目的地。可以使用Spout来从消息队列、数据库、文件系统等数据源获取数据流，然后通过Bolt进行处理，并将结果发送到消息队列、数据库等目的地。
- 配置和启动Storm集群：在使用Apache Storm之前，需要配置和启动Storm集群。可以使用Storm的配置文件来指定集群的拓扑结构、资源分配、任务调度等参数。然后，使用Storm命令行工具来启动集群。
- 监控和调优：一旦Storm集群启动，可以使用Storm的监控工具来监控集群的运行状态和性能指标。如果发现性能瓶颈或问题，可以通过调整Topology的拓扑结构、调整资源分配等方式进行优化。
Apache Storm作为复杂事件处理器的优势包括：
- 实时性能：Apache Storm具有低延迟和高吞吐量的特点，能够实时处理大规模的数据流。
- 可扩展性：Apache Storm可以水平扩展，通过增加节点来处理更大规模的数据流。
- 容错性：Apache Storm具有容错机制，能够自动处理节点故障，并保证数据处理的可靠性。
- 灵活性：Apache Storm提供了丰富的API和插件机制，可以根据需求进行定制和扩展。
Apache Storm作为复杂事件处理器的应用场景包括：
- 金融行业：可以用于实时交易监控、欺诈检测、风险管理等。
- 物联网：可以用于实时数据分析、设备监控、智能城市等。
- 广告和营销：可以用于实时广告投放、用户行为分析、个性化推荐等。
- 电信行业：可以用于实时网络监控、故障诊断、流量优化等。
腾讯云提供了一些与Apache Storm相关的产品和服务，包括：
- 云服务器（CVM）：用于搭建Apache Storm集群的虚拟机实例。链接地址：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版（CMYSQL）：用于存储和管理Apache Storm的元数据和状态信息。链接地址：https://cloud.tencent.com/product/cdb_mysql
- 云监控（Cloud Monitor）：用于监控Apache Storm集群的运行状态和性能指标。链接地址：https://cloud.tencent.com/product/monitoring
请注意，以上仅为腾讯云提供的一些相关产品和服务，其他云计算品牌商也可能提供类似的产品和服务。
相关·内容
我正试着在m windows 7 64位机器上设置apache storm。我的配置如下：
zoo.cfg
tickTime=2000
initLimit=5
syncLimit=2
dataDir=C:/Server-Local/zookeeper-3.4.9/data
clientPort=2181
storm.yaml
storm.zookeeper.servers:
- "localhost"
storm.local.dir: "C:/Server-Local/apache-storm-1.0.3/data"
nimbus.host: "lo
浏览 6提问于2017-03-14得票数 0
2回答
我已经完成了我的Storm测试拓扑，在我在Html代码上创建一个d3脚本之前，它从文本文件中读取数据。我希望它现在直接从Storm拓扑中读取数据(可能是螺栓？)但我不知道该怎么做。我正在使用霍顿工作沙箱进行测试，任何帮助都将不胜感激。
提前感谢！
我找到了一个红色的风暴包裹，我正试着用它。它允许您设置一个写在redis上的螺栓，我已经设置了节点。我现在的问题是，eclipse找不到java代码的导入和头‘ve上的导入，我已经下载了这个包。我当前的java螺栓和导入是：
package Storm.practice.Storm.Prova;
import backtype.storm.Confi
浏览 4提问于2015-11-17得票数 1
回答已采纳
我尝试了几个配置参数，甚至没有运气地使用withLocalModeOverride。我在这里错过了什么？
这里有一个示例应用程序，在30岁以后，计数器被重置，一切都重新启动。如果我能提供更多的细节，请告诉我。
用法：
mvn package
java -jar target/Test-0.1.0.jar
src/main/java/Test.java
package storm.test;
import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.generate
浏览 8提问于2019-10-02得票数 0
回答已采纳
我最近遇到了Apache Mesos，并成功地在Mesos上部署了我的Storm拓扑。
我想尝试在Apache Marathon上运行Storm拓扑/Hadoop作业(使用mesos-storm框架直接在Apache Mesos上运行Storm有问题)。
我找不到任何教程/文章可以列出如何从Apache Marathon启动Hadoop/Spark任务的步骤。
如果任何人能提供关于这个主题的任何帮助或信息(可能是启动storm/hadoop作业的Marathon的Json作业定义)，那就太好了。
非常感谢
浏览 2提问于2014-12-08得票数 2
如何在不访问apache nifi接口的情况下启动我创建的数据流。是否可以通过运行.bat文件来触发run？我是apache nifi的新手，对apache nifi的局限性一无所知。
我将数据流保存为模板，并希望在不访问apache nifi界面的情况下启动它。
浏览 0提问于2019-10-27得票数 0
我的目标是与发布者和使用者一起创建一个分布式应用程序，在其中我使用CEP处理数据流，以生成事件使用者的事件通知。
Esper和Apache Storm有什么区别？
我能否实现Storm只使用Esper的功能，以及何时应该考虑将Esper与Storm集成？
我很困惑，我以为Esper提供了同样的功能。
浏览 8提问于2017-03-07得票数 3
回答已采纳
我通过遵循安装了ApacheStorm1.0，但是我无法从互联网访问Storm。访问本地主机:8080会产生以下错误：
org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader nimbus from seed hosts [localhost]. Did you specify a valid list of nimbus hosts for config nimbus.seeds?
at org.apache.storm.utils.NimbusClient.getConfiguredClient
浏览 4提问于2016-04-20得票数 14
回答已采纳
3回答
我最近一直在研究基于事件的系统，并了解到使用Apache Storm等框架进行复杂的事件处理。我知道，当您处理大量数据流，并且希望检测数据中的某些事件时，CEP是理想的选择，我们向CEP引擎提供查询来检测事件。
如果每分钟产生的数据流不是很大，但是您有一组更大的查询提供给CEP，那该怎么办呢？在这种情况下，CEP仍然是理想的吗？如果不是，最好的方法是什么？
浏览 6提问于2014-09-04得票数 0
在向集群提交风暴拓扑时，我收到此错误。
6653 [main] INFO backtype.storm.daemon.supervisor - Starting supervisor with id 8ee90770-957a-40c7-a70b-fd7399cab6a1 at host Ritesh-RM
6706 [main] INFO backtype.storm.StormSubmitter - Jar not uploaded to master yet. Submitting jar...
6711 [main] INFO backtype.storm.StormSubmit
浏览 2提问于2015-09-15得票数 3
我试图将一个简单的python螺栓集成到使用Apache storm和Storm Crawler SDK创建的已配置的Storm拓扑中。我是按照提供的说明操作的
但我经常收到错误：
java.lang.Exception: Shell Process Exception: Traceback (most recent call last):
File "D:\<PATH>\storm.py", line 217, in run
tup = readTuple()
File "D:\<PATH>\storm.py", lin
浏览 0提问于2018-06-05得票数 1
2回答
我们正在尝试从Storm 0.10.0升级到1.0.2，我们的项目使用
在不同版本之间，backtype.storm包名称被storm-community更改为org.apache.storm包名称。
作为我们升级的一部分，我们不得不将storm-kafka的版本也改为1.0.2
但是当我在storm上运行拓扑时，我得到了关于旧版本中缺少类的错误：
apache-storm-1.0.2/bin/storm \
jar \
$jarFile \
org.apache.storm.flux.Flux \
$yamlFile \
--remote
+- Apache Stor
浏览 9提问于2016-09-13得票数 1
我正在使用pyleus --verbose local xyz_topology.jar运行风暴拓扑“storm-1.0.0, pyleus-0.3.0, centos-6.6”并得到错误
线程"main“java.lang.NoClassDefFoundError中的异常:backtype/storm/拓扑/IRichBolt
Running: java -client -Ddaemon.name= -Dstorm.options= -Dstorm.home=/usr/local/apache-storm-1.0.0
-Dstorm.log.dir=/usr/local/ap
浏览 3提问于2016-05-15得票数 1
我试图在我的项目中实现Storm-Crawler，但我需要使用Cassndra和Gradle。我喜欢使用Storm-Crawler和ElasticSearch堆栈，但在这种情况下，我不得不使用这个解决方案。我尝试了几次使用gradle构建uber jar，但都没有成功。有人在gradle中构建了Storm-Crawler拓扑吗？我将Apache-Storm配置为使用Cassandra，但是如何将Strom-Crawler中的数据放入Cassandra？
浏览 14提问于2020-04-12得票数 0
我要在配置为单个本地群集的计算机上部署Storm拓扑。我已经将conf/storm.yaml配置为使用storm.scheduler: "org.apache.storm.scheduler.resource.ResourceAwareScheduler"。拓扑部署成功。但是，我从Sigar库收到一个错误，指出无法获取进程ID以在我的拓扑上使用CPUMetric。下面是我用来获取指标的拓扑配置： config.registerMetricsConsumer(LoggingMetricsConsumer.class);
Map<String, String> wor
浏览 25提问于2019-03-13得票数 0
回答已采纳
1回答
Im配置了Apache Storm 0.9.2。我运行了nimbus，supervisor和UI，我都还好。我配置了Maven，Java。
我想从运行示例"storm-starter“
当我运行："mvn clean install -DskipTests=true“时，我遇到了这个错误。
Storm .............................................. SUCCESS [ 3.983 s]
[INFO] maven-shade-clojure-transformer .................... SUCCESS [
浏览 0提问于2015-02-17得票数 1
当我尝试使用下面的方法调用getstream来保存一个活动(JSON)时，我会得到以下异常。此异常偶尔发生。我们怎么解决这个问题？
JSON：(activityTask)
{
"processingType": "PERSIST_AND_NOTIFY",
"carbookBaseActivity": {
"actor": "7d8d59d1-1997-4213-81c0-32de463466f6",
"verb": "favorite"
浏览 3提问于2017-04-20得票数 1
回答已采纳
我想在Windows8上设置Apache Storm，但我不确定这是否是最好的选择，以及需要什么才能做到这一点。或者你会推荐使用Ubuntu在VM (VMware播放器)上安装Storm吗？最后，我想在EC2云上横向扩展Apache Storm。
谢谢你提前给我的提示！
浏览 4提问于2016-07-17得票数 1
当遵循starter 中的指南时，我无法实际运行任何拓扑结构--比如ExclamationTopology。
mvn clean install -DskipTests=true成功运行，从顶级Storm执行，mvn package在storm-examples级别运行。
当我试图运行storm jar target/storm-starter-2.0.0-SNAPSHOT.jar org.apache.storm.starter.ExclamationTopology时，会得到以下错误：
Error: A JNI error has occurred, please check your i
浏览 3提问于2016-02-19得票数 8
回答已采纳
1回答
我想在亚马逊的EMR上运行yahoo`s的项目。在EMR上，主管本地目录无法创建。我想可能是连接问题还是未经许可。你能给我一些建议吗？谢谢你的帮助。
2017-03-01 11:38:02服务器mk-监控器java.io.IOException初始化错误:无法创建目录/mnt/纱，/mnt1/yarn/usercache/yarn/appcache/application_1488367739843_0002/container_1488367739843_0002_01_000006/storm/storm-1.0.1/storm-local/supervisor在org.apache.s
浏览 1提问于2017-03-04得票数 0
假设我们有以下拓扑
spout A -> bolt B -> bolt C -> bolt E
而bolt 是最后一个，它将信息保存在数据库中，因此不需要发出任何元组。如何实现这样的解决方案，
如果我没有定义output_fields，那么我会得到异常
Exception in thread "main" java.io.IOException: org.apache.storm.thrift.protocol.TProtocolException: Required field 'output_fields' is unset! Struct
浏览 0提问于2017-03-26得票数 0
提交一个简单的第一个Storm Topology让我抓狂。首先，当我试图在安装storm的远程VM上运行它时，连接被拒绝。我明白，我必须在本地集群上运行它。 下面是我的几行代码： public void execTopology_alt() throws Exception {
final TopologyBuilder tp = new TopologyBuilder();
tp.setSpout("kafka_spout", new KafkaSpout<>(KafkaSpoutConfig.builder(this.bootstrap
浏览 14提问于2019-06-16得票数 1
回答已采纳
我想在intellij中使用风暴起动器
正如官方网站所说的那样，我配置严格
但是智力告诉我很多依赖是找不到的
Dependency 'org.apache.storm:storm-clojure:2.0.1-SNAPSHOT' not found
Dependency 'org.apache.storm:storm-clojure-test:2.0.1-SNAPSHOT' not found
Dependency 'org.apache.storm:storm-client:2.0.1-SNAPSHOT' not found
Dependency
浏览 1提问于2019-02-26得票数 0
回答已采纳
研究风暴爬行器1.10和ES 6.4.2。在爬行过程完成后，当我检查记录时，爬虫正在抓取具有相同标题和描述的、https、和http url，如何告诉爬虫只抓取其中一个url。
Title: About Apache storm
Description:A Storm application is designed as a "topology" in the shape of a directed acyclic graph (DAG) with spouts and bolts acting as the graph vertices. Edges on the graph
浏览 0提问于2018-12-03得票数 0
风暴版本: 1.2.2平台: Windows 2008
我已经有了一个linux服务器和一个Windows服务器上的风暴集群。这两台服务器都部署了nimbus和监督员服务。我开始了一个拓扑图，然后我杀了它。我发现Windows服务器错误退出上的监视进程，Windows服务器上的工作进程仍然处于活动状态。
它表明：
错误:无法终止pid xxx进程，只能终止此进程(使用\F选项)。
错误消息从以下图片翻译而来：
我不知道有这个错误，我已经用谷歌搜索一些答案，但什么也没有发现，所以我发送这条消息给你。我希望你能帮助我。
更新日期为2018/12/24
我发现，工作人员将启动一个拓扑进程，首
浏览 0提问于2018-12-21得票数 0
回答已采纳
1回答
现在我想在一个污点中使用Drools，它在LocalCluster中正常工作，但是当我把它放到生产集群中时，它有错误。污点是：
public class DealLostBolt extends BaseRichBolt {
private static final long serialVersionUID = 1L;
private static final Logger LOGGER = LoggerFactory.getLogger("DEAL_LOST_BOLT");
private OutputCollector colle
浏览 6提问于2017-09-13得票数 0
回答已采纳
当使用StormCrawler原型2.1.0运行ElasticSearch时，结合ApacheStormVersion2.2.0和OpenJDK 11，在运行默认拓扑时会出现以下错误：
10:51:54.160 [main-SendThread(localhost:2000)] WARN o.a.s.s.o.a.z.ClientCnxn - Session 0x0 for server localhost/<unresolved>:2000, unexpected error, closing socket connection and attempting reconnect
浏览 4提问于2021-04-28得票数 0
1回答
我是apache和kafka的新手，我试着通过OpenClassroom.The原理提供的课程来学习这些概念，通过python程序将消息发送到kafka服务器，并通过storm拓扑的主类中定义的kafka喷口检索消息。问题是我不明白螺栓是如何检索消息的。据我所知，这是在ParsingBolt类中使用以下代码行完成的：JSONObject obj = (JSONObject)jsonParser.parse(input.getStringByField("value"));。唯一的问题是，我不明白我们如何知道消息包含在value字段中。下面可以找到main类和parsing bo
浏览 21提问于2022-06-13得票数 0
回答已采纳
1回答
我使用Apache Storm的滑动窗口技术来获取24小时窗口长度和1小时滑动间隔长度的数据。当第一个TupleWindow到达时，TupleWindow中的每个元组都会启动一个聚合过程。
我的聚合过程会一直等到下一个TupleWindow到达。一旦TupleWindow到达，聚合过程就会启动，并消耗大量资源。我想知道Apache Storm是否有能力实时发送数据(而不是等到窗口的最后一项到达)。在这种情况下，我可以实时聚合所有内容
有相应的配置吗？
谢谢
浏览 21提问于2018-02-13得票数 1
同时尝试学习如何使用storm。我决定编译我自己的著名WordCount拓扑实例，看看它是如何做到的。代码与示例代码100%相同。()
但是，每当我尝试运行jar时，我都会收到错误消息，说我无法找到或装入主类。我可以运行与storm捆绑在一起的默认示例jar，没有任何问题(就像下面这样)，所以它不应该是调用语法问题。
bin/storm jar lib/"name".jar "classpath"
Maven创建jar没有任何问题，最初我以为我没有在pom文件中正确排除storm依赖，但它应该是这样的，对吧？
<dependencies>
&
浏览 2提问于2016-10-28得票数 0
我有一个在本地集群上运行良好的拓扑。但是，当我试图在生产集群上运行它时，会发生以下情况：
尼布斯起来了
暴风的UI上升了
我用的两名工人都用完了
动物园起来了
我与之激荡
风暴jar myjar.jar MyClass
Nimbus提交拓扑
拓扑和工人出现在暴风用户界面中。
但：
尽管其状态是活动的，但拓扑仍未启动。
拓扑的日志文件没有出现在员工中.
我在supervisor.log上的工作人员中有以下日志
2016-04-15 13:18:19.831 o.a.s.d.supervisor [WARN] There was a connection pro
浏览 4提问于2016-04-15得票数 5
Apache Kafka:分布式消息传递系统
Apache Storm:实时消息处理
我们如何在实时数据管道中使用这两种技术来处理事件数据？
在实时数据管道方面，在我看来两者做的工作是一样的。我们如何在数据管道上使用这两种技术？
浏览 35提问于2014-02-16得票数 109
回答已采纳
我想使用kundera框架将一个对象插入到cassandra中，但是我收到了以下错误：
java.lang.RuntimeException: java.lang.ClassCastException: java.lang.String cannot be cast to [B
at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:448) ~[storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.utils.D
浏览 1提问于2016-05-10得票数 0
我目前正在学习如何使用apache和apache，通过遵循OpenClassRoom提供的课程，我的问题非常类似于我们可以找到的和.I试图用这些帖子上提供的信息来解决我的问题，但是没有任何改变，我仍然有同样的错误。
我可以在eclipse上编译代码，并且可以使用mvn package命令，没有任何问题。我把我找到的所有信息都放到了kafka和storm的pom.xml里。任何建议都会对我有很大帮助。您可以找到下面的pom和代码。
The pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<proje
浏览 5提问于2022-05-30得票数 1
回答已采纳
1回答
我试图用JoinBolt将两个卡夫卡数据流(使用卡夫卡喷口)连接成一个数据流，并使用下面的代码片段()
它说，JoinBolt的每个传入数据流都必须是在单个字段上分组的字段。流只应使用其上为FieldsGrouped的字段与其他流连接。
代码片段：
KafkaSpout kafka_spout_1 = SpoutBuilder.buildSpout("127.0.0.1:2181","test-topic-1", "/spout-1", "spout-1");//String zkHosts, String topic,
浏览 1提问于2018-08-22得票数 0
回答已采纳
2回答
我正在设置一个Apache系统，但在使程序持续运行方面遇到了问题。我已经在三台服务器上设置了风暴，但它只在一台服务器上持续工作。我认为问题就在指挥的道路上。
我一直在使用风暴起动器来设置程序，并在本地使用RollingTopWords进行了测试。当我运行以下命令$ storm jar storm-starter-*.jar storm.starter.RollingTopWords时，计算机暂停一秒钟，然后得到以下错误：
无法找到或加载主类storm.starter.RollingTopWords
jar存储在目录/apache/storm/examples/starter/targe
浏览 3提问于2015-06-01得票数 1
在mongodb中使用Apache Storm 2.1.0时，我在Bolt执行中出现错误： java.lang.NullPointerException
at org.apache.storm.mongodb.common.mapper.SimpleMongoLookupMapper.toTuple(SimpleMongoLookupMapper.java:46)
at org.apache.storm.mongodb.bolt.MongoLookupBolt.execute(MongoLookupBolt.java:70)
at org.apache.storm.e
浏览 20提问于2020-11-02得票数 0
这是一个默认配置，就像在示例中一样，没有任何更改。我只是想让这个基本的例子起作用。
我正在尝试运行Storm 1.2.2中的示例。我构建了storm-starter项目，并尝试使用以下命令行执行：
storm jar target/storm-starter-1.2.2.jar org.apache.storm.starter.ExclamationTopology -local
但是，我得到了以下异常：
apara:storm-starter aparansky$ storm jar target/storm-starter-1.2.2.jar org.apache.storm.starte
浏览 3提问于2018-06-15得票数 0
我已经在本地设置了一个Apache集群，并提交了一个在Storm UI中可见的拓扑。一旦一切都启动并运行，我将在ui.log文件中获得以下异常。这个错误在某种程度上与storm-kafka-monitor有关，这是一个bash脚本，我正在windows上运行这个脚本。
任何帮助都将不胜感激。(预先谢谢:)
2018-06-05 11:26:20.293 o.a.s.u.TopologySpoutLag qtp1185188034-26 [WARN] Exception thrown while getting lag for spout id: kafka-spout and spout cl
浏览 2提问于2018-06-05得票数 0
回答已采纳
我的项目由一些依赖项组成，这些依赖项拉动了相同的公共依赖项。
公共依赖项storm-kafka具有新版本1.0.2和旧版本0.10.0
在构建一个阴影jar时，我在我的fat jar中看到了两个版本的类，不知何故，在执行过程中，较旧的版本被拾取了，这给出了一个ClassNotFoundError，因为与较旧版本相关的其他依赖项不在那里。
jar -xvf my_shaded_fat_jar.jar
find . -name KeyValueSchemeAsMultiScheme.class
./org/apache/storm/kafka/KeyValueSchemeAsMultiScheme
浏览 3提问于2016-09-13得票数 17
我正在尝试将ExclamationTopology示例提交到一个单一节点集群中，并获得以下错误
Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.TApplicationException: Internal error processing beginFileUpload
at org.apache.storm.StormSubmitter.submitJarAs(StormSubmitter.java:507)
at org.apache.storm.StormSub
浏览 4提问于2019-11-25得票数 1
我正在使用Flux拓扑定义文件设计Apache拓扑。问题是我不知道如何:-
创建一个发送到多个螺栓的流(语法似乎只包含一个“to：”行)。
从单个螺栓发出多个命名流。这在Apache Storm中是完全合法的。我担心流的名称:行被声明为‘可选-不使用’，因此Flux似乎不支持Storm的这个特性？
浏览 2提问于2016-02-23得票数 1
1回答
Supervisor.log中的错误消息:风暴监控器猫不能同时创建stormClusterState，它在zk.The nimbus进程的/zk.The/zk.The目录中是空的，但是监督者不能start.why？
org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:663)~storm-client-2.3.0.jar:2.3.0 at org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:667)~storm-client-2.3.0.jar
浏览 12提问于2022-02-15得票数 0
我是Storm Flux上的新手，现在对如何在Storm Flux中配置通用参数感到困惑。例如，org.apache.storm.kafka.spourt.KafkaSpout的定义如下：
public class KafkaSpout<K, V> extends BaseRichSpout {
....
}
这里有一个使用这个类的示例YAML文件：
components:
- id: "onlyValueRecordTranslator"
className: "org.apache.storm.flux.examp
浏览 7提问于2018-05-29得票数 0
我已经使用docker组合安装了Apache-Storm。
docker-compose.yml：
kafka:
image: spotify/kafka
ports:
- "9092:9092"
- "2181:2181"
environment:
ADVERTISED_HOST: 172.16.8.37
ADVERTISED_PORT: 9092
nimbus:
command: --daemon nimbus drpc
image: fhuz/docker-storm
p
浏览 1提问于2016-11-15得票数 3
回答已采纳
当我在运行风暴拓扑的机器上运行ps aux | grep java时，我可以看到2个Java进程正在运行。
ps -ef | grep java | grep "storm"
UID PID PPID C STIME TTY TIME CMD
test-3p-s+ 10857 10661 0 Apr12 ? 1-02:21:25 java -server -Ddaemon.name=supervisor -Dstorm.options= -Dstorm.home=/usr/share/apache-storm -Dstorm.
浏览 8提问于2022-10-31得票数 0
当我试图使用()方法和kundera框架将表保存到cassandra时，我会收到以下错误：
18976 [Thread-15-localhostAMQPbolt0-executor[2 2]] INFO c.i.c.c.CassandraClientBase - Returning cql query INSERT INTO "pieces"("width","depth","height","idpiece") VALUES(10.0,12.0,11.0,'1') .
18998 [T
浏览 9提问于2016-05-11得票数 0
回答已采纳
我正在尝试将Storm拓扑提交到群集，但不断收到相同的错误： Exception in thread "main" java.lang.NoClassDefFoundError: kafka/api/OffsetRequest
at org.apache.storm.kafka.KafkaConfig.<init>(KafkaConfig.java:48)
at org.apache.storm.kafka.trident.TridentKafkaConfig.<init>(TridentKafkaConfig.java:30)
浏览 23提问于2020-01-28得票数 1
回答已采纳
2回答
我有一个Java代码，其中我使用Maven和本地系统添加了JAR。现在，当我在一个不同的系统上运行它时，本地的JAR丢失了。如何将所有内容添加到Maven并删除本地类路径？
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v
浏览 8提问于2016-02-18得票数 1
回答已采纳
1回答
当我的应用程序在编译时找不到maven中列出的依赖类时，我在运行时遇到了一个问题。应用程序编译时没有问题。
应用程序如下
package com.ender.storm;
import backtype.storm.Config;
import backtype.storm.LocalCluster;
import backtype.storm.topology.TopologyBuilder;
public class HelloStorm {
public static void main(String[] args) throws Exception{
Co
浏览 2提问于2015-01-29得票数 1
回答已采纳
我们有一个运行着3个节点和多个拓扑的storm集群。我们在java 1.8.0_162中使用apache-storm-1.2.2 目前我们有一个问题，一个随机拓扑在错误发生后在随机时间停止发射，并且Netty服务器不可用。这可能会在几个小时或几天后发生。 因为我们没有改变storm bolts发出或执行数据的逻辑，所以我们目前不知道如何抛出这样的错误。此外，为什么整个拓扑在出现这样的错误后停止工作，这也是值得怀疑的。 似乎某些HashMap的反序列化有问题。但是我们不知道这是怎么发生的。 这里是其中一个工作者的错误，它导致了失败： 2019-09-24 14:31:02.414 o.a.s.
浏览 41提问于2019-09-24得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
