构建 Storm 时 Zookeeper 出现 ClassNotFoundException

2023-12-04

我是 java 和 Storm 的新手，所以请原谅任何明显的错误。我正在尝试使用水槽连接器进行风暴但它因以下错误而崩溃：

java.lang.reflect.InvocationTargetException
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297)
    at java.lang.Thread.run(Thread.java:744)
Caused by: java.lang.ExceptionInInitializerError
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:270)
    at clojure.lang.RT.loadClassForName(RT.java:2056)
    at clojure.lang.RT.load(RT.java:419)
    at clojure.lang.RT.load(RT.java:400)
    at clojure.core$load$fn__4890.invoke(core.clj:5415)
    at clojure.core$load.doInvoke(core.clj:5414)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at clojure.core$load_one.invoke(core.clj:5227)
    at clojure.core$load_lib.doInvoke(core.clj:5264)
    at clojure.lang.RestFn.applyTo(RestFn.java:142)
    at clojure.core$apply.invoke(core.clj:603)
    at clojure.core$load_libs.doInvoke(core.clj:5302)
    at clojure.lang.RestFn.applyTo(RestFn.java:137)
    at clojure.core$apply.invoke(core.clj:603)
    at clojure.core$require.doInvoke(core.clj:5381)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at backtype.storm.cluster$loading__4784__auto__.invoke(cluster.clj:1)
    at backtype.storm.cluster__init.load(Unknown Source)
    at backtype.storm.cluster__init.<clinit>(Unknown Source)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:270)
    at clojure.lang.RT.loadClassForName(RT.java:2056)
    at clojure.lang.RT.load(RT.java:419)
    at clojure.lang.RT.load(RT.java:400)
    at clojure.core$load$fn__4890.invoke(core.clj:5415)
    at clojure.core$load.doInvoke(core.clj:5414)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at clojure.core$load_one.invoke(core.clj:5227)
    at clojure.core$load_lib.doInvoke(core.clj:5264)
    at clojure.lang.RestFn.applyTo(RestFn.java:142)
    at clojure.core$apply.invoke(core.clj:603)
    at clojure.core$load_libs.doInvoke(core.clj:5302)
    at clojure.lang.RestFn.applyTo(RestFn.java:137)
    at clojure.core$apply.invoke(core.clj:603)
    at clojure.core$require.doInvoke(core.clj:5381)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at backtype.storm.daemon.nimbus__init.load(Unknown Source)
    at backtype.storm.daemon.nimbus__init.<clinit>(Unknown Source)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:270)
    at clojure.lang.RT.loadClassForName(RT.java:2056)
    at clojure.lang.RT.load(RT.java:419)
    at clojure.lang.RT.load(RT.java:400)
    at clojure.core$load$fn__4890.invoke(core.clj:5415)
    at clojure.core$load.doInvoke(core.clj:5414)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at clojure.core$load_one.invoke(core.clj:5227)
    at clojure.core$load_lib.doInvoke(core.clj:5264)
    at clojure.lang.RestFn.applyTo(RestFn.java:142)
    at clojure.core$apply.invoke(core.clj:603)
    at clojure.core$load_libs.doInvoke(core.clj:5302)
    at clojure.lang.RestFn.applyTo(RestFn.java:137)
    at clojure.core$apply.invoke(core.clj:603)
    at clojure.core$require.doInvoke(core.clj:5381)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at backtype.storm.testing$loading__4784__auto__.invoke(testing.clj:1)
    at backtype.storm.testing__init.load(Unknown Source)
    at backtype.storm.testing__init.<clinit>(Unknown Source)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:270)
    at clojure.lang.RT.loadClassForName(RT.java:2056)
    at clojure.lang.RT.load(RT.java:419)
    at clojure.lang.RT.load(RT.java:400)
    at clojure.core$load$fn__4890.invoke(core.clj:5415)
    at clojure.core$load.doInvoke(core.clj:5414)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at clojure.core$load_one.invoke(core.clj:5227)
    at clojure.core$load_lib.doInvoke(core.clj:5264)
    at clojure.lang.RestFn.applyTo(RestFn.java:142)
    at clojure.core$apply.invoke(core.clj:603)
    at clojure.core$load_libs.doInvoke(core.clj:5302)
    at clojure.lang.RestFn.applyTo(RestFn.java:137)
    at clojure.core$apply.invoke(core.clj:605)
    at clojure.core$use.doInvoke(core.clj:5392)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at backtype.storm.LocalCluster$loading__4784__auto__.invoke(LocalCluster.clj:1)
    at backtype.storm.LocalCluster__init.load(Unknown Source)
    at backtype.storm.LocalCluster__init.<clinit>(Unknown Source)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:270)
    at clojure.lang.RT.loadClassForName(RT.java:2056)
    at clojure.lang.RT.load(RT.java:419)
    at clojure.lang.RT.load(RT.java:400)
    at clojure.core$load$fn__4890.invoke(core.clj:5415)
    at clojure.core$load.doInvoke(core.clj:5414)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at clojure.lang.Var.invoke(Var.java:415)
    at backtype.storm.LocalCluster.<clinit>(Unknown Source)
    at com.storm.WordCountTopology.main(WordCountTopology.java:97)
    ... 6 more
Caused by: java.lang.ClassNotFoundException: org.apache.zookeeper.server.NIOServerCnxn$Factory
    at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:190)
    at backtype.storm.zookeeper$loading__4784__auto__.invoke(zookeeper.clj:1)
    at backtype.storm.zookeeper__init.load(Unknown Source)
    at backtype.storm.zookeeper__init.<clinit>(Unknown Source)
    ... 96 more

我的 pom 文件

<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/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.storm</groupId>
    <artifactId>my-storm</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>jar</packaging>
    <name>my-storm</name>
    <url>http://maven.apache.org</url>
    <properties>
        <flume.version>1.3.0-cdh4.2.1</flume.version>
        <hadoop.version>2.0.0-cdh4.2.1</hadoop.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>
    <repositories>
        <repository>
            <id>clojars.org</id>
            <url>http://clojars.org/repo</url>
        </repository>
        <repository>
            <id>cdh-maven-repo</id>
            <name>CDH Maven Repository</name>
            <url>https://repository.cloudera.com/content/repositories/releases/</url>
        </repository>
    </repositories> 
    <dependencies>
        <dependency>
            <groupId>storm</groupId>
            <artifactId>storm</artifactId>
            <version>0.8.2</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>3.8.1</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.flume</groupId>
            <artifactId>flume-ng-embedded-agent</artifactId>
            <version>${flume.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flume</groupId>
            <artifactId>flume-ng-core</artifactId>
            <version>${flume.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                        <artifactId>slf4j-api</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.flume</groupId>
            <artifactId>flume-ng-configuration</artifactId>
            <version>${flume.version}</version>
        </dependency>
            <dependency>
                <groupId>org.apache.flume</groupId>
                <artifactId>flume-ng-node</artifactId>
                <version>${flume.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.hadoop</groupId>
                <artifactId>hadoop-common</artifactId>
                <version>${hadoop.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.5</version>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
                <version>1.5.8</version>
            </dependency>
        </dependencies>
       <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>2.3.2</version>
                <configuration>
                    <source>1.7</source>
                    <target>1.7</target>
                </configuration>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-release-plugin</artifactId>
                <version>2.0-beta-9</version>
            </plugin>
        </plugins>
    </build>
</project>



 $uname -a :Linux 2.6.32-358.23.2.el6.x86_64 #1 SMP Thu Oct 17 10:27:22 CEST 2013 x86_64 x86_64 x86_64 GNU/Linux
    $locate zookeeper
       .m2/repository/org/apache/zookeeper/zookeeper/3.4.5-cdh4.2.1/zookeeper-3.4.5-cdh4.2.1.pom

你能解释一下我错过了什么吗？

看来关键就在这里：

Caused by: java.lang.ClassNotFoundException: org.apache.zookeeper.server.NIOServerCnxn$Factory

这似乎是由于使用版本造成的3.4.5 of zookeeper。您是否尝试过降级到某个版本3.3.6?

branch-3.3 包含该内部类NIOServerCnxn$工厂但是branch-3.4有NIOServerCnxnFactory instead

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

Java

apachezookeeper

apachestorm

构建 Storm 时 Zookeeper 出现 ClassNotFoundException 的相关文章

如何编写 Hibernate HQL 查询来删除所有“孙子”元素？

我有学校里面有团体里面有学生我想删除特定学校的所有学生在 SQL 中我可以编写以下查询 DELETE FROM students1 WHERE students1 group id IN SELECT id FROM group1
设置 SWT Shell 的默认字体

有没有办法为整个 Shell 设置默认字体以便任何新控件都将使用相同的字体看来现在我必须为我创建的每个控件设置字体这导致了太多的冗余默认使用的字体由平台选择请参阅中的其他信息类字体 SWT 标准小部件工具包 http book
使用 jpql 和 jpa 从日期字段中提取年份

我想从数据库中的一行中提取年份部分以便将其与值进行比较这是我的功能 public List
无法实例化接收器 com.parse.GcmBroadcastReceiver

我正在编写一个使用 GCM 通知和解析推送的离子应用程序这个应用程序正在使用这些插件 com ionic keyboard 1 0 3 Keyboard com phonegap plugins PushPlugin 2 4 0 Push
@OneToMany 与 @JoinTable 错误

我试图理解 OneToMany with JoinTable 对于这样的场景我正在使用 JPA 2 1 Hibernate 5 0 4 和 Oracle 11 XE 当我打电话时userDao save user 下面的代码我有 jav
如何识别 Java 中的不可变对象

在我的代码中我正在创建一个对象集合这些对象将由各种线程以只有在对象不可变的情况下才安全的方式访问当尝试将新对象插入到我的集合中时我想测试它是否是不可变的如果不是我将抛出异常我能做的一件事是检查一些众所周知的不可变类型 priv
RSA SignatureException：签名长度不正确

我在签署 rsa 签名时遇到问题我有一个用私钥加密的签名然而当我尝试使用公钥验证它时遇到问题我得到以下异常 java security SignatureException Signature length not correct
如何在 Struts 2 OGNL 中将参数传递给方法调用

我想使用属性作为对象方法的参数
支持通过 OAuth 进行 Facebook/Twitter 身份验证的 CAS 服务器

我正在寻找一个支持 Facebook Twitter 通过 OAuth 进行单点登录身份验证的 CAS 服务器我检查过 JASIG CAS 服务器但它看起来不支持它们我的 java web 应用程序基于 Spring Security
Java 泛型：如何为泛型类型指定类类型？

我有一个 POJO 指定为 MyClass u where U是泛型类型参数我正在尝试编写一个接受类引用的实用方法Class u
C# 中的协变和逆变

首先我要说的是我是一名正在学习 C 编程的 Java 开发人员因此我会将我所知道的与我正在学习的进行比较我已经使用 C 泛型几个小时了我已经能够在 C 中重现我在 Java 中知道的相同内容除了几个使用协变和逆变的示例我正在读
使用Java开发跨平台，不同平台字体缩放不同

我正在为我的大学制作一些软件需要一个 GUI 在它的第一个版本中我让它使用系统外观因此它看起来像 Linux Mac Windows 中的本机应用程序我发现这很麻烦因为我必须根据操作系统使所有 JLabel 具有不同的大小无论分
HTTP PUT 在 Java 中上传文件

Edit 我想我已经弄清楚如何执行二进制数据部分仔细检查代码但我很确定我做对了现在当我尝试按照中所述完成上传时遇到新错误Vimeo API 文档 http vimeo com api docs upload streaming Ed
Java ConcurrentModificationException [重复]

这个问题在这里已经有答案了当删除倒数第二个元素时没有 ConcurrentModificationException List
在Java中多次读取System.in会导致IOException？

我正在尝试创建一个小命令行游戏来强化我在过去几个月中在 Java 中学到的一些东西我正在尝试创建一个名为 readInput 的方法它返回一个我可以一次又一次调用的字符串第一次它工作正常但第二次它会导致 IO Exception 如
我们可以有虚假中断吗？

我正在创建一个任务轮询器每分钟都会查找任务它看起来像这样 public class Poller private final ExecutorService e Executors newSingleThreadExecutor pub
Selenium - 等待网络流量

我们将 Selenium 与 Java API 和一些 Javascript 用户扩展一起使用我们在应用程序中使用了大量 AJAX 调用我们的许多测试随机失败因为有时 AJAX 调用完成得比其他时候慢因此页面未完全加载我们通过等待
将带有 webapp 的 WAR 部署到 Maven 中央存储库是否有意义？

这样做有意义吗如果是我在哪里可以找到使用简单的 Web Hello World 执行此操作的示例当人们从 Maven 执行 Web 应用程序时他们会使用 Jetty 来运行它吗我想 tomcat 太重了任何帮助将不胜感激谢谢
如何从spark中的hbase表中获取所有数据

我在 hbase 中有一个大表名称为 UserAction 它具有三个列族歌曲专辑歌手我需要从歌曲列族中获取所有数据作为 JavaRDD 对象我尝试了这段代码但效率不高有更好的解决方案来做到这一点吗 static Spa
Integer.parseInt 引发的 NumberFormatException

嘿我在学校上编码课但老师没有很好地解释所以我们必须在网上查找我所做的信息但我无法找到代码中的错误你能帮我吗 char end s do System out println Tipo de boleto char boleto c

随机推荐

测量线程的上下文切换时间

我想计算上下文切换时间并且我正在考虑使用互斥体和条件变量在两个线程之间发出信号以便一次只有一个线程运行我可以用CLOCK MONOTONIC测量整个执行时间和CLOCK THREAD CPUTIME ID测量每个线程运行的时间那么上
如何在 IBM MQ JMS 接口上使用 JMS 属性？

我正在使用带有 MQ 6 0 2 的 MQ JMS 接口似乎只支持预定义的属性而不支持任意的属性例如我可以正确地getJMSCorrelationID getJMSPriority 等等但是当我在发件人上设置任意属性时 mess
如何查看Google Play服务版本？

在我的应用程序中我需要检查 Google Play 服务版本安装在用户设备中是否可以如果是的话我该怎么做我找到了简单的解决方案 int v getPackageManager getPackageInfo GoogleApiAv
CMSIS 库是否应该包含在版本控制中？ [复制]

这个问题在这里已经有答案了通常我曾经在版本控制中包含芯片供应商 ST 提供的设备特定标头和源以及 CMSIS Core 标头数量不多也没有更新的习惯我使用STM32微控制器但我不使用立方体框架 or the 标准外设库最近我
jQuery 获取 XML 中的匹配节点

一点背景知识我使用 XSLT 在页面上呈现一些 XML 但我们决定使其更具交互性所以现在我正在执行 jQuery ajax 调用来返回 XML 并在 JavaScript 中解析它我已经能够使用类似的代码从中提取特定节点 var qp
为什么不能使用 Q_OBJECT 宏进行编译（链接）？

我用 PyQt 制作了一个项目的原型并使其在那里工作现在我尝试将其转换为 C 但遇到了一些问题如果我不放入 Q OBJECT 宏它会编译并运行但如果我将其注释掉则会出现以下错误 Undefined symbols vtable f
将一组数据行绑定到 datagridview

我尝试了以下代码但 datagridview 中没有显示任何内容有什么建议么 string strFilterOption dtcolnPurchaseProductExpProductNo 270 dgvProductExp Data
当视图样式设置为详细信息时，如何在 Winforms ListView 中显示图标和文本？

我只想有两列例如 Item Value icon Gold 10 icon Silver 2 icon Iron 1 这可能吗或者我需要为图标添加另一列吗查看文档以了解SmallImageList of the ListView控制和
C语言中删除文件中的一个字符

如何使用C程序从文件中删除几个字符我找不到它的任何预定义函数为了理解目的我试图通过套接字发送一个文件如果成功发送 N 个字节我想从文件中删除这些字节最后该文件将为空还有其他方法可以有效地做到这一点吗谢谢普拉迪普如果它们
d3 单击创建圆并单击删除

我试图单击一个圆圈将其删除但单击画布将创建一个圆圈我确实想从数据中实际删除圆圈及其对象而不是仅仅使其透明单击圆圈时调用该函数 function removeElement d d3 select this remove 通过单击圆圈
有什么方法可以获取 Firebase Auth 用户 UID 吗？

我希望通过 Node JS 或 Javascript API 从 Firebase 获取身份验证用户 Auth Users UID 我附上了它的屏幕截图以便您了解我在寻找什么希望你们能帮我解决这个问题 Firebase 3 中的身份验证
如何在 iPhone 上旋转 Quartz 绘制的文本

I want to draw some texts using Quartz Now the app draws but I want it to show as 0123456789 Is there any way to show it
.NET TIFF 文件：无需第三方库即可将 RGB 转换为 CMYK？

继续我之前的问题是否以及如何可以基于 RGBTIFF文件并使用标准 NET 3 5 功能将其转换为 CMYK 这可能吗实际上有一种方法使用 System Windows Media Imaging 命名空间目前似乎只适用于 TIFF
将“const wchar_t *”转换为“unsigned char *”

在 C 中是否可以将 const wchar t 转换为 unsigned char 我怎样才能做到这一点 wstring dirName unsigned char dirNameA unsigned char dirName c st
在没有 refspec 参数的情况下运行 git push、pull 和 fetch

来自 Loeliger 2ed 的 Git 版本控制如果您根本不指定 refspec 会怎样 git push命令如何 Git 知道要做什么或将数据发送到哪里吗首先如果没有给命令明确的远程 Git 会假设你想使用原点没有参考规范
如何创建 UI 设计器实用程序？

我需要创建一个实用程序用户可以在其中创建自己的数据输入屏幕用户应该能够拖放普通的 UI 控件 TextBox RadioButton CheckBox ListBox ComboBox and Image 到任何容器并根据需要进行排列
kable 显示 html 代码而不是 html 表格

我试图使用 kable 生成一张漂亮的表格然而 kable 只是返回了 html 代码而不是 r 笔记本中的表格本身 R 版本 3 5 0 Mac 上的 R 版本 1 1 453 Test 1 r library knitr dt lt
在 PHP 中使用命名空间 URI 生成 XML

如何使用 DOM 通过 php 制作这个简单的 xml 欢迎提供完整代码
Database.Logger.Level 枚举值在版本 11.0.0 中不可访问

6 月 30 日更新此问题已在版本 11 0 2 中得到纠正在 Firebase 版本 11 0 0 之前枚举值数据库记录器级别可以直接访问使用 10 2 6 编译的示例是 FirebaseDatabase getInstanc
构建 Storm 时 Zookeeper 出现 ClassNotFoundException

我是 java 和 Storm 的新手所以请原谅任何明显的错误我正在尝试使用水槽连接器进行风暴但它因以下错误而崩溃 java lang reflect InvocationTargetException at sun reflect

构建 Storm 时 Zookeeper 出现 ClassNotFoundException

构建 Storm 时 Zookeeper 出现 ClassNotFoundException 的相关文章

随机推荐

热门标签