知识点
相关文章
更多最近更新
更多storm的KeeperException$NoNodeException错误
2019-03-02 23:52|来源: 网路
在storm0.8.1中,如果一个topology开的并发和worker比较大的时候,偶尔会报KeeperException$NoNodeException错:
在storm-0.8.3的版本中已经修复,但是storm-0.8.3并没有发行的版本,可以通过编译自己的storm-0.8.1版本来修复这个问题:
1、使用storm-0.8.3版本的storm.trident.topology.state.RotatingTransactionalState来替换storm-0.8.1的RotatingTransactionalState类
2、重新编译strom源码
3、把新的jar包替换集群中的storm包
ps:从storm-0.8.3的修改日志可以看出RotatingTransactionalState这个类修复了改问题,也给出了出现这个错误的原因:
转自:http://www.cnblogs.com/frady/p/3357001
相关问答
更多-
我也遇到过这个问题。 我的问题是运行时间太短。动物园管理员没有足够的时间来正确关闭。查看下面的代码: builder.createTopology()); try { Thread.sleep(20000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } cluster.shutd ...
-
尝试添加环境变量: CHROOT=/kafka_0.9 Zookeeper还允许您添加一个“chroot”路径,该路径将使该群集的所有kafka数据显示在特定路径下。 这是在同一个zookeeper集群上设置多个Kafka集群或其他应用程序的一种方法。 要做到这一点,以hostname1:port1,hostname2:port2,hostname3:port3 / chroot / path的形式给出一个连接字符串,将所有这个集群的数据放在路径/ chroot / path下。 请注意,您必须在启动代理之 ...
-
建立风暴启动者:得到错误“POM for storm-core missing”(building storm-starter: getting error “POM for storm-core missing”)[2023-03-01]
我遇到了同样的问题,并从storm-user邮件列表档案中找到了答案,请参阅 http://mail-archives.apache.org/mod_mbox/storm-user/201404.mbox/%3C72091F29-8109-4A1C-A79D-DDD2D871737B%40petrolink.com%3E I encountered the same problem, and found the answer from storm-user mailing list archives, re ... -
由于mongoDB版本,我遇到了这个错误。 我在我的pom.xml中改变了这个,事情进展顺利。
org.mongodb mongo-java-driver 3.0.1 -
来自Apache Storm Trident和Kafka集成的Spout错误(Spout Error from Apache Storm Trident and Kafka Integration)[2022-05-01]
你的堆栈跟踪表明你正在访问https://issues.apache.org/jira/browse/STORM-3046 。 Your stack trace indicates that you are hitting https://issues.apache.org/jira/browse/STORM-3046. -
Storm:如何在发生异常时自动重新提交拓扑?(Storm: How to resubmit topology automatically when it occurs exception?)[2021-10-05]
你应该做的第一件事是谷歌搜索导致连接丢失错误的原因 。 然后转到storm的日志文件并查看导致错误的代码行。 正确的做法是找出导致错误的原因。 但是,如果您想要更快的临时解决方案,那么使用Storm的REST API来终止拓扑。 然后,您可以使用普通Java程序或任何语言的脚本从命令行重新启动拓扑。 The first thing you should have done is to google for what causes the connection loss error. Then go to s ... -
我终于来了! 我只是简单了,我创建了一个非常简单的redis bolt,它发布了内容,我监视了redis数据库,它正在运行。 我的工作螺栓: public class RedisBolt implements IRichBolt { protected String channel = "Somriures"; // protected String configChannel; protected OutputCollector collector ...
-
Apache Storm Nimbus错误:无法找到或加载主类(Apache Storm Nimbus Error: Could not find or load main class)[2022-07-26]
在系统变量的路径中使用PROGRA~1而不是Program文件 。 例如: C:\Program Files\Java\jdk1.6.0_45 ==> C:\PROGRA~1\Java\jdk1.6.0_45 Use PROGRA~1 instead of Program files in System variables' path. For example: C:\Program Files\Java\jdk1.6.0_45 ==> C:\PROGRA~1\Java\jdk1.6.0_45 -
我昨天得到了答案,我需要的是将localhost更改为127.0.0.1,然后我在终端上启动Redis数据库,在监视器的第二个终端上启动,我的发布方法正在运行。 I came with the answer yesterday, what I needed is to change the localhost to 127.0.0.1, then I launched the Redis database on a terminal, on a second terminal the monitor, an ...
-
看起来像带有bin文件夹的“Storm.cmd”具有错误的主管路径类路径。 在cmd文件中,路径显示为:CLASS = org.apache.storm.daemon.supervisor 而将它与python脚本进行比较时,路径为:klass =“org.apache.storm.daemon.supervisor.Supervisor” 我们将storm.cmd更新为与python中的相同,然后它工作了。 希望有所帮助 It looks like "Storm.cmd" withing the bin ...