我正在建立一个ApacheStorm系统,但是在使程序持续运行方面有问题。我已经在三个服务器上建立了Storm,但是它只在一个服务器上持续运行。我认为问题出在命令的路径上。
我一直在使用Storm启动器来设置程序,并在本地使用RollingTopWords进行了测试。当我运行以下命令$Storm罐子Storm启动器-*。jarstorm.starter.RollingTopWords
时,计算机会停止一秒钟,然后我得到以下错误:
无法找到或加载主类Storm。开胃菜。RollingTopWords
jar存储在/apache/storm/examples/storm starter/target目录中。如果我能提供任何其他有用的信息,请告诉我,因为我现在感到有点绝望。
以下是程序不工作的全部输出。
正在运行:/usr/lib/jvm/java-1.7.0-openjdk-amd64/bin/java-client-Dstorm。选项=-Dstorm。home=/home/scix3/apache/storm-Dstorm。日志dir=/home/scix3/apache/storm/logs-Djava。图书馆path=/usr/local/lib:/opt/local/lib:/usr/lib-Dstorm。conf.file=-cp/home/scix3/apache/storm/lib/kryo-2.21。jar:/home/scix3/apache/storm/lib/core。孵化器-0.1.0。jar:/home/scix3/apache/storm/lib/commons-fileupload-1.2.1。jar:/home/scix3/apache/storm/lib/ring-servlet-0.3.11。jar:/home/scix3/apache/storm/lib/clj-stacktrace-0.2。jar:/home/scix3/apache/storm/lib/jline-2.11。jar:/home/scix3/apache/storm/lib/servlet-api-2.5。jar:/home/scix3/apache/storm/lib/disruptor-2.10.1。jar:/home/scix3/apache/storm/lib/log4j-over-slf4j-1.6.6。jar:/home/scix3/apache/storm/lib/clojure-1.5.1。jar:/home/scix3/apache/storm/lib/commons-exec-1.1。jar:/home/scix3/apache/storm/lib/logback-core-1.0.13。jar:/home/scix3/apache/storm/lib/jetty-util-6.1.26。jar:/home/scix3/apache/storm/lib/slf4j-api-1.7.5。jar:/home/scix3/apache/storm/lib/carbonite-1.4.0。jar:/home/scix3/apache/storm/lib/compojure-1.1.3。jar:/home/scix3/apache/storm/lib/minlog-1.2。jar:/home/scix3/apache/storm/lib/commons-lang-2.5。jar:/home/scix3/apache/storm/lib/tools。宏-0.1.0。jar:/home/scix3/apache/storm/lib/reflectsam-1.07-shaded。jar:/home/scix3/apache/storm/lib/tools。cli-0.2.4。jar:/home/scix3/apache/storm/lib/math。数字-tower-0.0.1。jar:/home/scix3/apache/storm/lib/logback-classic-1.0.13。jar:/home/scix3/apache/storm/lib/tools。日志-0.2.3。jar:/home/scix3/apache/storm/lib/asm-4.0。jar:/home/scix3/apache/storm/lib/jetty-6.1.26。jar:/home/scix3/apache/storm/lib/snakeyaml-1.11。jar:/home/scix3/apache/storm/lib/hiccup-0.3.6。jar:/home/scix3/apache/storm/lib/clj-time-0.4.1。jar:/home/scix3/apache/storm/lib/jgrapht-core-0.9.0。jar:/home/scix3/apache/storm/lib/clout-1.0.1。jar:/home/scix3/apache/storm/lib/chill-java-0.3.5。jar:/home/scix3/apache/storm/lib/commons-io-2.4。jar:/home/scix3/apache/storm/lib/joda-time-2.0。jar:/home/scix3/apache/storm/lib/storm-core-0.9.4。jar:/home/scix3/apache/storm/lib/objeness-1.2。jar:/home/scix3/apache/storm/lib/commons-logging-1.1.3。jar:/home/scix3/apache/storm/lib/ring-core-1.1.5。jar:/home/scix3/apache/storm/lib/ring-jetty-adapter-0.3.11。jar:/home/scix3/apache/storm/lib/commons-codec-1.6。jar:/home/scix3/apache/storm/lib/json-simple-1.1。jar:/home/scix3/apache/storm/lib/ring-devel-0.3.11。jar:storm starter-。jar:/home/scix3/apache/storm/conf:/home/scix3/apache/storm/bin-Dstorm。jar=Storm起动器-。罐子Storm。开胃菜。RollingTopWords错误:无法找到或加载主类storm。开胃菜。RollingTopWords
要检查问题是否是Storm找不到罐子,您可以尝试发行
storm jar /fullpath/my-storm-jar.jar Classname
你能确定的其他事情很少
错误的主要问题无法找到或加载主类storm.starter.RollingTopWords
Cloud be。
启动配置
。构建jar时必须非常小心,它要求您选择目标文件夹和启动配置(启动配置应该是同一个项目)在远程集群中使用Stormsubmitter
之前,检查一下它是否正常工作localcluster
Apache Kafka:分布式消息传递系统 Apache Storm:实时消息处理 我们如何在实时数据管道中使用这两种技术来处理事件数据? 在实时数据管道方面,我觉得两者做的工作是一样的。如何在数据管道上同时使用这两种技术?
下面是我成功运行两三天后持续获得的异常的详细信息。有人能指导我吗?
我正在使用这两个实时数据流框架处理器。我找遍了所有的地方,但我找不到这两个框架之间有很大的区别。特别是,我想知道他们是如何工作的基础上的数据或拓扑等大小。
我正在做一个学术项目,涉及传感器的流数据。我已经包围了苍鹭(Storm的接班人)和尼菲。两者都支持内置背压,这对我的项目至关重要。Apache Nifi和Heron之间的主要区别是什么? 哪款更适合物联网应用?
我在Apache Storm拓扑上运行了一个性能测试,并注意到kinesis-spout中的“failed”计数非常高(几乎占了元组的1/3)。这个数值是多少?