我要在配置为单个本地群集的计算机上部署Storm拓扑。拓扑部署成功。但是，我从Sigar库收到一个错误，指出无法获取进程ID以在我的拓扑上使用CPUMetric。.jar库复制到apache-storm/lib文件夹。:1.2.2]
at org.apache.storm.utils.Utils.newInstance(Utils.java:192) ~[
浏览 25提问于2019-03-13得票数 0
回答已采纳
我正在尝试将Storm拓扑部署到本地独立群集。我将包含到我的项目的Github repo的链接，这样你就可以看到我的代码…… 我有一个在本地模式下运行的simple Storm topology，我让它tweaked to deploy到Dockerized/IRichSpout 从this question看来，在构建topology.jar时，我只需要将storm-core作为<em
浏览 14提问于2021-01-11得票数 0
我已经设置了一个单节点集群，并尝试将我的示例拓扑部署到其中。为此，我创建了一个示例项目，并向其中添加了一个简单的拓扑。0.9.5.jar'.core/0.9.5/d2bf27db853347dcf66990
浏览 0提问于2015-10-14得票数 0
根据，当我们将Storm拓扑部署到生产集群时，我们必须从Maven中排除Storm的jar，因为它已经在类路径中了，如果不这样做，就会出现类似于multiple default.yaml in classpath的错误。配置maven并构建jar时，仍然包含org.apache.storm jar，jar中有一个default.
浏览 0提问于2018-02-02得票数 1
回答已采纳
2回答
我正在尝试在HDFSBolt中实现Storm。我想从基本的TestWordSpout开始，所以使用了Storm提供的Storm。这是我的topology public static void main(String[] args) throws Exception" xsi:schemaLocation="http://maven.apache.
浏览 0提问于2016-02-04得票数 0
回答已采纳
1回答
当我试图提交拓扑时，我发现at backtype.storm.utils.Utils.findAndReadConfigFile(StormSubmitter.java:40)
at
浏览 1提问于2015-10-26得票数 7
回答已采纳
我想在本地集群上运行storm拓扑以进行测试。我的代码需要一些C++和python库。我在哪里指定它的JAVA_LIBRARY_PATH？我在eclipse上运行它。我将storm作为maven的依赖项包括在内。<dependency>
浏览 3提问于2014-08-13得票数 0
我正在使用Apache Storm 0.9.4。我设置了一个5节点集群，它运行得很好。(实际上，5个主管在5个不同的物理节点上充当码头容器。)项目来使用Netbeans提交一个拓扑。-1.0.jar jp.soushi.teststorm.MyTopology ->是可以的。- Finished submitting topology: MyTopology
我使用Storm检查了拓扑结构。并确保/usr/lib/
浏览 9提问于2015-04-28得票数 1
回答已采纳
我正在为storm (storm-project.net)开发拓扑。我有两个远程集群:暂存和生产。我在客户端(我的笔记本电脑，我在上面编写代码)上有两个storm.yaml文件，它们分别指向不同的远程集群production.storm.yaml和staging.storm.yaml。不幸的是，我所知道的在它们之间切换的唯一方法是在通过"stor
浏览 7提问于2013-10-05得票数 6
我正在使用storm jar类向‘`nimbus’提交拓扑。它在本地运行良好，但在远程集群上，它说它无法加载主类。SLF4J: Found binding in [jar:file:/usr/local/storm-0.9.0.1/lib/logback-classic-1.0.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4
浏览 3提问于2014-02-27得票数 4
1回答
我的拓扑结构完全是在我的文档化服务中的一个本地集群上工作的，但是现在我将它移到一个生产集群中，这就有一个问题了。我为Storm集群创建提交拓扑的服务似乎运行得很好，代码在PostConstruct中看起来很像KafkaSpoutConfig.builder在UI
浏览 0提问于2018-09-11得票数 0
回答已采纳
1回答
我是Apache Storm的新手，我正在尝试创建storm中的拓扑，可以用于流的实时处理。<clinit>(RT.java:330)我正在尝试开发Kafka - CEP拓扑，其中我使用Kafka作为喷嘴，我的CEP实例作为storm拓扑中的螺栓。下面是我的主要KafkaCEPTopology代码和pom.xml以供
浏览 7提问于2019-02-25得票数 0
2回答
在将喷口声明从单个字段输出更改为两个之后，集群似乎还记得以前的输出声明。日志状态中的错误但现在它有了新的宣言。问题有什么方法可以澄清风暴群的历史吗？还是清除历史生成的序列化对象？为了保持理智，这里是喷口输出。
浏览 2提问于2015-07-22得票数 1
回答已采纳
我正在进行的项目有一个使用Tika的WebUI (WAR)和另一个也使用Tika的应用程序(JAR)。我使用了上的Tika故障排除提示Tika version: Apache Tika 1.22Tika detector type org.a
浏览 1提问于2019-11-15得票数 1
, defaultConf.get(Config.STORM_THRIFT_TRANSPORT_PLUGIN));
当在本地集群上运行此拓扑时(没有nimbus配置)，一切都正常。因此，这个异常向我表明Submitter需要某种类型的jar。在做了一些研究之后，我发现我必须在代码中设置以下属性，以便以编程方式提交jar。System.setProperty("storm.jar", "p
浏览 3提问于2015-11-29得票数 1
回答已采纳
因此，我试图找出如何安装和安装风暴/风暴爬虫与ES和Kibana，如描述的。我从来没有在我的本地机器上安装Storm，因为我以前和Nutch一起工作过，我也从未在本地安装过Hadoop .我想风暴可能也是一样的(也许不是？)
我想开始用风暴爬行器代替现在的纳奇。看起来，如果我只是下载一个发行版并将/bin添加到我的路径中，我就可以只使用与远程集群进行对话。似乎我需要根据设置一个开发环境，让我能够在
浏览 0提问于2018-08-23得票数 0
回答已采纳
当遵循starter 中的指南时，我无法实际运行任何拓扑结构--比如ExclamationTopology。有没有人知道我为什么会犯这个错误，以及在我的设置中应该改变什么？相反，我使用Maven设置了一个新项目，将storm-core添加为依赖项，遵循通用指南。然后，在Eclipse中，我能够从storm导入正确的包来执行示例，比如ExclamationTopology。我使用相同的</em
浏览 3提问于2016-02-19得票数 8
回答已采纳
我的Storm类使用Redis queue来收集数据。我试着用我的Storm jar但我得到了以下异常： at java.lang.ClassLoader.loadClass(ClassLoad
浏览 0提问于2014-09-03得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
