它运行良好，直到提交： storm jar target/storm-starter-*.jar org.apache.storm.starter.RollingTopWords production-topology失败，错误为 Running: java -client -Ddaemon.name= -Dstorm.options= -Dstorm.home=/usr/local/Cellar/storm/1.2.2
浏览 11提问于2019-05-22得票数 1
我有一个动物园管理员，一个Nimbus和两个监督员，我提交了一个罐子，其中两个拓扑将通过StormSubmitter通过一个单一的主要方法提交StormSubmitter.submitTopology("B", conf, bTopology);}
一旦我提交这个罐子在“风暴罐”启动后，
浏览 0提问于2014-10-30得票数 0
回答已采纳
6回答
我们在伪模式下执行Storm拓扑。但是Storm没有显示正在运行的拓扑信息。
重新启动的暴风UI进程也没有用。是否需要特殊的配置来显示storm中运行的拓扑？
浏览 3提问于2015-02-12得票数 2
回答已采纳
我有一个在本地集群上运行良好的拓扑。但是，当我试图在生产集群上运行它时，会发生以下情况：
风暴jar myjar.jar MyClassNimbus提交拓扑
尽管其状态是活动的，但拓扑仍未启动。
拓扑的日志文件没有出现在员工中.
浏览 4提问于2016-04-15得票数 5
2回答
在将喷口声明从单个字段输出更改为两个之后，集群似乎还记得以前的输出声明。例如至这个喷口已经被序列化了。这也被记住了。Tuple created with wrong number of fields. Expected 1 fields but got 2 fields问题有什么方法可以澄清风暴群
浏览 2提问于2015-07-22得票数 1
回答已采纳
1回答
我在网上到处搜索，我找到的最多的是这两篇文章：
其他搜索结果告诉我，这是不可能的，也不是必需的，因为Nimbus不是集群中的关键节点。但我希望是更好的。
浏览 1提问于2016-03-31得票数 1
我使用springboot和storm来做一个演示，它在本地模式下工作，但在提交jar时在集群模式下报告错误 .static void main(String[] args) { // 定义一个拓扑filterBolt", "spoutId");
浏览 31提问于2019-05-22得票数 1
我正在设计一个apache storm拓扑(使用streamparse)，它使用一个spout (apache kafka spout)和一个并行大于1的螺栓构建，可以批量读取kafka spout中的消息并将消息持久化到如果批处理成功完成，我将手动提交apache kafka偏移量。streamp
浏览 2提问于2019-01-31得票数 0
我是Storm的新手，我已经在HDP机群上安装了一个storm on yarn，使用HDP storm on yarn页面上的说明和来自安丰的暴风纱git项目的风暴纱主。我能够让Nimbus运行，甚至提交拓扑，并在Storm上看到它们。然而，喷口和螺栓似乎不“工作”(发出的0元组数)。我尝试从supverviser日志中的“launching comman
浏览 1提问于2014-03-14得票数 0
1回答
和配置使用BaseRichBolt，一个KafkaSpout和两个螺栓-A，螺栓-B元组是锚定在螺栓-A一旦螺栓-B承认它将被认为是一个成功处理的元组和它将被提交。但是，问题是由于某种原因，一些失败消息在KafkaSpout中被复制。KafkaSpout在处理它时发出1000个元组，原因是有将近20个元组失败了(在bolt处)。这20个元组被连续地重放，在某个点上，工人被杀死，主管重新启动工人，这20个元组再次被重放，这一次，它成功地处理了，但它处理了多次(复制)。但是，我希望这些元组只能处理一次(成
浏览 0提问于2017-10-26得票数 0
我正在尝试将2个提交合并为1，所以我遵循了。我跑了在结果编辑器中，我将pick更改为squash，然后保存-退出，但rebase失败并显示以下错误交互式rebase已启动
如果没有以前的提交，不能‘
浏览 273提问于2010-04-02得票数 1266
回答已采纳
4回答
它类似于 package com.abc.newsclassification;
import StormBase.KnowledgeGraph.ClassifierBolt
浏览 2提问于2014-03-08得票数 1
</configuration> </plugins>连同我的拓扑的示例源代码args[0]; }为了能够通过Maven在IDE中本地运行拓扑
浏览 1提问于2018-02-25得票数 0
回答已采纳
我已经开发了一个chrome扩展，我想在我的网站上有。我有以下代码，但它似乎不起作用： <link rel="chrome-webstore-item" href="https://chrome.google.com/webstore/detail/-extension_ID-"> function ExtInstall() {
浏览 0提问于2012-01-21得票数 5
回答已采纳
我运行了一些java代码，它将上传示例中的风暴-启动-拓扑-0.9.6.jar，控制台显示：
535主信息C:\apachestorm096\examples\storm-starter\storm-starter-topologies-0.9.6.jar -将拓扑jar backtype.storm.StormSubmitter上传到指定位置：¨/usr/local/storm/data¨/nimbus/inbox/stormjar-8b5acdaf-e6ce-4b0
浏览 2提问于2015-12-26得票数 1
回答已采纳
1回答
com.digitalpebble.stormcrawler - DarchetypeArtifactId=storm-crawler-elasticsearch-archetype -DarchetypeVersion=LATEST当我运行此命令时，它显示我的拓扑已成功提交12T10:30:50Z 2020-06-12 10:31:
浏览 0提问于2020-06-13得票数 0
我正在通过CommandLineJobRunner实用程序运行作业(使用由maven shade插件生成的fat jar +依赖项)；作业随后在中途失败，因为"java堆内存限制已达到“，作业没有被标记为失败，但仍然显示为已启动状态。我想spring batch的优点之一是它能够从中断的位置重新启动作业，这是不是我在这里遗漏了什么？
浏览 1提问于2016-08-03得票数 5
回答已采纳
threads = 1;ktableCommitInterval= 10000;timeDuration=10; 拓扑问题： 提交间隔设置为10秒。高速缓存大小被设置为72MB。数据以字节为单位。状态存储已启用缓存。文档指出，kafka streams将数据推送到下游的操作语义取决于缓存大小或提交间隔，无论首先发生什么。但根据实验，提交立即发生了两次。观察结果是，提交间隔在应用程序启动
浏览 30提问于2020-01-21得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号