Storm拓扑未提交

2023-12-24

我已经配置了我的机器zookeeper,nimbus,supervisor运行正常,并且我的拓扑在LocalCluster中工作

LocalCluster cluster = new LocalCluster();
cluster.submitTopology("SendPost", conf, builder.createTopology());
Utils.sleep(10000000000l);
cluster.killTopology("SendPost");
cluster.shutdown();

现在我想尝试提交我的拓扑但它不起作用

/usr/local/storm/bin$ ./storm jar /home/winoria/Desktop/Storm/storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar com.winoria.post.PostTopology Post

我收到以下错误

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/usr/local/storm/lib/logback-classic-1.0.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/winoria/Desktop/Storm/storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
Running: java -client -Dstorm.options= -Dstorm.home=/usr/local/storm -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib -Dstorm.conf.file= -cp /usr/local    /storm/storm-netty-0.9.0.1.jar:/usr/local/storm/storm-console-logging-0.9.0.1.jar:/usr/local/storm/storm-core-0.9.0.1.jar:/usr/local/storm/lib/httpcore-4.1.jar:/usr/local/storm/lib/carbonite-1.5.0.jar:/usr/local/storm/lib/mockito-all-1.9.5.jar:/usr/local/storm/lib/commons-io-1.4.jar:/usr/local/storm/lib/commons-fileupload-1.2.1.jar:/usr/local/storm/lib/jgrapht-0.8.3.jar:/usr/local/storm/lib/ring-jetty-adapter-0.3.11.jar:/usr/local/storm/lib/jzmq-2.1.0.jar:/usr/local/storm/lib/asm-4.0.jar:/usr/local/storm/lib/logback-core-1.0.6.jar:/usr/local/storm/lib/tools.nrepl-0.2.3.jar:/usr/local/storm/lib/compojure-1.1.3.jar:/usr/local/storm/lib/json-simple-1.1.jar:/usr/local/storm/lib/ring-devel-0.3.11.jar:/usr/local/storm/lib/commons-logging-1.1.1.jar:/usr/local/storm/lib/httpclient-4.1.1.jar:/usr/local/storm/lib/reflectasm-1.07-shaded.jar:/usr/local/storm/lib/commons-exec-1.1.jar:/usr/local/storm/lib/guava-13.0.jar:/usr/local/storm/lib/clout-1.0.1.jar:/usr/local/storm/lib/objenesis-1.2.jar:/usr/local/storm/lib/slf4j-api-1.6.5.jar:/usr/local/storm/lib/clojure-1.4.0.jar:/usr/local/storm/lib/jetty-6.1.26.jar:/usr/local/storm/lib/hiccup-0.3.6.jar:/usr/local/storm/lib/clj-stacktrace-0.2.2.jar:/usr/local/storm/lib/log4j-over-slf4j-1.6.6.jar:/usr/local/storm/lib/tools.logging-0.2.3.jar:/usr/local/storm/lib/ring-core-1.1.5.jar:/usr/local/storm/lib/zookeeper-3.3.3.jar:/usr/local/storm/lib/math.numeric-tower-0.0.1.jar:/usr/local/storm/lib/disruptor-2.10.1.jar:/usr/local/storm/lib/minlog-1.2.jar:/usr/local/storm/lib/core.incubator-0.1.0.jar:/usr/local/storm/lib/servlet-api-2.5-20081211.jar:/usr/local/storm/lib/netty-3.6.3.Final.jar:/usr/local/storm/lib/ring-servlet-0.3.11.jar:/usr/local/storm/lib/clj-time-0.4.1.jar:/usr/local/storm/lib/snakeyaml-1.11.jar:/usr/local/storm/lib/commons-codec-1.4.jar:/usr/local/storm/lib/tools.cli-0.2.2.jar:/usr/local/storm/lib/logback-classic-1.0.6.jar:/usr/local/storm/lib/servlet-api-2.5.jar:/usr/local/storm/lib/kryo-2.17.jar:/usr/local/storm/lib/joda-time-2.0.jar:/usr/local/storm/lib/curator-client-1.0.1.jar:/usr/local/storm/lib/libthrift7-0.7.0-2.jar:/usr/local/storm/lib/tools.macro-0.1.0.jar:/usr/local/storm/lib/jline-0.9.94.jar:/usr/local/storm/lib/clojure-complete-0.2.3.jar:/usr/local/storm/lib/curator-framework-1.0.1.jar:/usr/local/storm/lib/commons-lang-2.5.jar:/usr/local/storm/lib/junit-3.8.1.jar:/usr/local/storm/lib/jetty-util-6.1.26.jar:/home/winoria/Desktop/Storm/storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar:/usr/local/storm/conf:/usr/local/storm/bin -Dstorm.jar=/home/winoria/Desktop/Storm/storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar com.winoria.post.PostTopology Post
SLF4J: Detected both log4j-over-slf4j.jar AND slf4j-log4j12.jar on the class path, preempting StackOverflowError. 
SLF4J: See also http://www.slf4j.org/codes.html#log4jDelegationLoop for more details.
Exception in thread "main" java.lang.ExceptionInInitializerError
at org.apache.log4j.Logger.getLogger(Logger.java:39)
at org.apache.log4j.Logger.getLogger(Logger.java:43)
at com.rapportive.storm.spout.AMQPSpout.<clinit>(AMQPSpout.java:67)
at com.winoria.post.PostTopology.main(PostTopology.java:33)
Caused by: java.lang.IllegalStateException: Detected both log4j-over-slf4j.jar AND slf4j-    log4j12.jar on the class path, preempting StackOverflowError. See also http://www.slf4j.org/codes.html#log4jDelegationLoop for more details.
at org.apache.log4j.Log4jLoggerFactory.<clinit>(Log4jLoggerFactory.java:49)
... 4 more

请帮助我............ 提前致谢


我使用 cassandra 和 cassandra-all 版本 1.6.1 将 log4j 和 slf4j-log4j12 声明为编译时依赖项,因此我添加了以下依赖项,我的拓扑工作起来就像魅力一样!

<dependencies>
<dependency>
<groupId> org.apache.cassandra</groupId>
<artifactId>cassandra-all</artifactId>
<version>1.1.6</version>

<exclusions>
  <exclusion> 
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
  </exclusion>
  <exclusion> 
    <groupId>log4j</groupId>
    <artifactId>log4j</artifactId>
  </exclusion>
</exclusions> 

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

Storm拓扑未提交 的相关文章

随机推荐

  • CPU 中的相关负载重新排序

    我一直在阅读内存屏障 软件黑客的硬件视图 http www puppetmastertrading com images hwViewForSwHackers pdf 保罗 E 麦肯尼 Paul E McKenney 撰写的一篇非常受欢迎的
  • 电子邮件上的 CSS

    有没有人找到一种在以编程方式生成的电子邮件中嵌入 CSS 的好方法 我发现的最好方法是将样式代码放入资源文件中并在代码中调用它 一个例子是 Dim objBuilder objBuilder New StringBuilder objBui
  • 如何关闭本地 firebase 模拟器?

    目前我使用以下命令初始化 firebase 模拟器 firebase emulators start 经过一段时间的研究后 我想停止它 那么我怎样才能停止模拟器呢 查看端口被哪个进程占用sudo lsof i tcp
  • 从 htaccess 中的 URL 中删除不需要的字符

    我们当前的 htaccess 设置正确地将 URL 转换为这样 site com page php sid Friend 到 site com Friend 然而 由于不相关的疏忽 我们几乎所有的 URL 都被双索引为 site com F
  • phpmyadmin:创建一个函数

    我正在尝试在我的 phpmyadmin 中创建一个函数 不起作用 这是我的语法 DELIMITER CREATE FUNCTION fixString input varchar RETURNS varchar BEGIN declare
  • 如何在 TypeORM queryBuilder 中显示生成的 SQL/原始 SQL

    我开发了typeorm querybuilder 为了调试的目的 我想显示生成的 SQL 查询 我测试过printSql 方法 但它没有显示任何 SQL 查询 const Result await this attendanceReposi
  • R Keras:将tensorflow张量转换为R数组

    我正在使用 R Keras 我可以通过执行以下命令来获取中间层的输出 layer output lt get layer mymodel index 1 output 其中 mymodel 是 Keras 模型 问题是layer outpu
  • 更新拉丝面积图的 y 轴

    我正在使用 d3 js 并且我正在通过修改来处理拉丝面积图这个例子 http bl ocks org 1667367 除了根据画笔改变 x 轴之外 我还希望根据画笔内数据的 y 值重新绘制图表的 y 轴 类似于 我已经使该功能正常工作 但只
  • Spring boot @DataJpaTest排除过滤器不起作用

    我有这个测试 RunWith SpringRunner class DataJpaTest excludeFilters Filter type FilterType REGEX pattern io rainrobot adwisdom
  • @PostConstruct 拦截器与 @Named @ViewScoped 未调用

    我仔细阅读了有关的文章拦截器 http docs jboss org weld reference 1 0 0 en US html interceptors html在接缝 焊接文档中并实施了InterceptorBinding Inte
  • 如何通过代码设置另存为对话框的目录?

    基本上 我编写了一些代码 用于监听应用程序内弹出的 另存为 对话框 当它弹出时 它会按下 保存 所有这些都是通过代码实现的 这很好用 但是我需要能够在保存之前将文件路径设置为我想要的路径 到目前为止 这是我的代码 using System
  • 常量的 k 前缀从何而来?

    常量以前缀开头是一种很常见的做法k e g k pi 但什么是k mean 难道只是这样c已经意味着char 这是一个历史上的奇怪现象 在喜欢盲目应用他们不理解的编码标准的团队中仍然是常见的做法 很久以前 大多数商业编程语言都是弱类型的 自
  • 哪些Google API可以通过服务帐号授权访问?

    我从 Google API 文档推断 并非所有广告的 Google 服务都可供服务帐户使用 例如在服务帐户的公告中 这是文本的一部分 服务帐户目前受以下 Google 支持 开发者服务 谷歌云存储 谷歌预测API 谷歌网址缩短器 谷歌 OA
  • 如何将一个流读入另一个流? [复制]

    这个问题在这里已经有答案了 FileInputStream in new FileInputStream myFile ByteArrayOutputStream out new ByteArrayOutputStream 问题 我怎样才能
  • Cassandra 集群 - 数据密度(每个节点的数据大小) - 寻求反馈和建议

    我正在考虑 Cassandra 集群的设计 用例将存储大行的时间序列数据的微小样本 使用 KairosDB 数据几乎是不可变的 非常罕见的删除 无更新 这部分工作得很好 然而 几年后 数据将相当大 最大大小将达到数百 TB 考虑到复制因子
  • 带弹出框/工具提示的 R 闪亮 valueBox

    我尝试从闪亮的仪表板为 valueBox 制作弹出框 工具提示 但到目前为止没有任何效果 我尝试使用shinyBS 例如popify函数 但随后收到错误警告 tagAssert中的错误 需要具有类 shiny tag 的对象 当我使用 ad
  • 使用 Cloud SQL 避免每日高额费用

    所以我处于开发模式 在开发后的 10 天内 我有了一个300 向 Google 计费 我做了什么 创建一个测试表 并向其中添加记录 文本和数字 我想说 从我的 Mac 执行了多个查询每天100个 持续6天 与周围有一张桌子100k 行 6
  • 如何在 Tkinter 画布上旋转多边形?

    我正在努力使用 Python 和 Tkinter 创建 asteroids 版本 当按下左或右箭头键时 船需要旋转 这艘船在 Tkinter 画布上是一个三角形 我无法想出调整三角形坐标的公式 我相信这与 sin 和 cos 有关 尽管我不
  • Meteor.js 在没有日志的情况下被杀死

    尝试运行 Meteor js 的示例 派对 示例失败 没有留下任何日志 meteor run parties gt Meteor server running on http localhost 3000 Killed 看起来由于某种原因崩
  • Storm拓扑未提交

    我已经配置了我的机器zookeeper nimbus supervisor运行正常 并且我的拓扑在LocalCluster中工作 LocalCluster cluster new LocalCluster cluster submitTop