我正在将apache storm设置为分布式模式。我的Zookeeper工作得很好。我甚至无法启动apache storm nimbus。我关注的是：http://chennaihug.org/knowledgebase/storm-multinode-installation/ Zookeeper配置文件： tickTime=2000/java-8-oracle"
stor
浏览 22提问于2019-01-15得票数 0
回答已采纳
我已经在包含4台虚拟机的集群上部署了Apache Storm version 0.9.6。我正在使用kafka spout来读取kafka经纪人的数据。我在相同的虚拟机上部署kafka代理和storm节点。不幸的是，我得到了这个错误：
b.s.m.n.Client [ERROR] connection attempt 23 to Netty-Client-02.novalocal/208.113.164.1
浏览 19提问于2017-01-30得票数 0
2回答
storm-1.0.1storm.zookeper.servers:# nimbus.host: 1000在我的主管日志中，我看到了以下内容：
2016-08-26 19:22:28.023 o.a.s.d.supervisor(Trans
浏览 3提问于2016-08-27得票数 1
回答已采纳
1回答
风暴创建拓扑
、、
我正在尝试使用Eclipse在Linux中运行storm starter示例。我收到以下错误，并且从未调用过nexttuple函数。(NIOServerCnxn.java:228) [storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java
浏览 2提问于2016-04-14得票数 0
Nimbus提交拓扑
尽管其状态是活动的，但拓扑仍未启动。 [org.apache.storm.security.auth.ThriftClient <init> ThriftClient.java 69]因此，我认为我与
浏览 4提问于2016-04-15得票数 5
我在用卡夫卡的输入写“风暴记”。当我在IDEA上做项目时，我发现maven没有下载我需要的所有类(实际上大部分的类)。pom.xml是 <kafka.version>0.10.1.0</kafka.version>
<storm.version>1.0.2</storm.version</depende
浏览 7提问于2016-12-01得票数 0
回答已采纳
问题就像标题一样，集群启动后没有错误打印在supervisor日志中。每当提交jar时，supervistors的日志中都会报告无法连接本地主机nimbus的错误。这里是supervisor.log中的错误，另一个是access-supervisor.log中的错误
2018-08-21 17:10:23.643 o.a.s.l.AsyncLocalizer Asyncat org.apac
浏览 4提问于2018-08-21得票数 0
回答已采纳
我已经正确地安装了尼姆和监控器，而且没有出现错误，即使是maven清洁安装和编译也没有错误，即使我的0qm也是用jzmq正确设置的，我也通过./storm启动了尼姆，启动了我的主管。
运行:/usr/lib/jvm/java-7-OpenJDK-AMD 64/bin/java -client -Ddaemon.name= -Dstorm.opt
浏览 2提问于2016-02-20得票数 0
回答已采纳
我在10个虚拟机上设置了一个storm集群，并在storm UI页面上验证了所有10个supervisors都显示在那里。但是，当我使用bin/storm jar my.jar my.class --remote提交jar文件时，我在所有supervisor节点上看到了以下错误，并且所有supervisor节点都死了。20.381 b.s.d.supervisor [INFO] Shutting down supervisor 27e6171a-2e94-491f-b961-7770676603
浏览 0提问于2016-03-25得票数 1
我正在尝试将ExclamationTopology示例提交到一个单一节点集群中，并获得以下错误at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:274)
at org.apache.storm.StormSubmitter
浏览 4提问于2019-11-25得票数 1
localCluster.submitTopology("kafka-topology", new HashMap(), topologyBuilder.createTopology());} 我得到一个我不理解的错误at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:81) ~[storm-kafka-1.2.2.jar:1.2.2]at org.apache.
浏览 34提问于2019-06-10得票数 0
回答已采纳
当遵循starter 中的指南时，我无法实际运行任何拓扑结构--比如ExclamationTopology。有没有人知道我为什么会犯这个错误，以及在我的设置中应该改变什么？全错误输出：
/Library/Java/JavaVirtualMachines/jdk1.8.0_45.jdk/Contents/Home/bin/java -clie
浏览 3提问于2016-02-19得票数 8
回答已采纳
我们有一个运行着3个节点和多个拓扑的storm集群。我们在java 1.8.0_162中使用apache-storm-1.2.2 目前我们有一个问题，一个随机拓扑在错误发生后在随机时间停止发射，并且Netty服务器不可用。因为我们没有改变storm bolts发出或执行数据的逻辑，所以我们目前不知道如何抛出这样的错误。此外，为什么整个拓扑在出现这样的错误<
浏览 41提问于2019-09-24得票数 0
我发现Windows服务器错误退出上的监视进程，Windows服务器上的工作进程仍然处于活动状态。
org.apache.storm.shade.org.apache.commons.exec.ExecuteException:进程退出时出现了一个错误
浏览 0提问于2018-12-21得票数 0
回答已采纳
当使用StormCrawler原型2.1.0运行ElasticSearch时，结合ApacheStormVersion2.2.0和OpenJDK 11，在运行默认拓扑时会出现以下错误： at org.apache.storm.shade.org.apache.zookeeper.SaslServerPrincipal
浏览 4提问于2021-04-28得票数 0
1回答
Supervisor.log中的错误消息:风暴监控器猫不能同时创建stormClusterState，它在zk.The nimbus进程的/zk.The/zk.The目录中是空的，但是监督者不能start.whyorg.apache.storm的supervisor.log: ava.lang.Error: java.lang.RuntimeException: java.lan
浏览 12提问于2022-02-15得票数 0
在mongodb中使用Apache Storm 2.1.0时，我在Bolt执行中出现错误： java.lang.NullPointerException at org.apache.storm.utils.JCQueue.consume
浏览 20提问于2020-11-02得票数 0
其中一个主管中的worker正在连续重新启动，并获得Closedchannel异常。但是，如果在另一个环境中的另一个storm集群中运行相同的拓扑，它将在没有任何错误的情况下运行。下面是我在Storm UI中看到的错误。java.lang.RuntimeException: org.apache.storm.kafka.ZkCo
浏览 6提问于2017-03-17得票数 3
我正在尝试将Storm拓扑提交到群集，但不断收到相同的错误： Exception in thread "main" java.lang.NoClassDefFoundError: kafka/api/OffsetRequest at org.apache.
浏览 23提问于2020-01-28得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
