apache-storm相关内容
嗨,春靴专家- 我正在尝试创建一个Spring Boot Uber JAR,该JAR需要部署到一个阿帕奇风暴集群。但是,问题是Storm预期所有类文件都在JAR的根目录中,而打包的应用程序文件在使用“Spring-ot-maven-plugin”打包时位于“boot-INF/Class”下。 有没有办法让我的应用程序类直接打包到根目录下,而不是“Boot-INF/CLASSES”?
..
我正在尝试使用以下命令运行本地群集: storm local target/myjar.jar com.app.MyMainClass Storm响应此错误: WARN o.a.s.s.o.a.z.ClientCnxn - Session 0x0 for server localhost/:2000, unexpected error, closing s
..
我正在寻找如何在我的 scala 项目中的风暴 1.2.1 中从风暴螺栓中终止拓扑.从这个answer中,我编写了以下代码: 私有 def shutTopology(){导入 org.apache.storm.utils.Utils导入 org.apache.storm.utils.NimbusClientval conf = Utils.readStormConfigval nimbusCl
..
提交拓扑时的错误 java.net.ConnectException:连接被拒绝在 backtype.storm.utils.NimbusClient.(NimbusClient.java:36)在 backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:17) 这是我在 nimbus 日志文件中得到的
..
我有一个包含 2 个节点和 1 个 ZooKeeper 的 Storm 集群.由于以下错误,其中一名工人死亡.有没有人知道为什么 stormconf.ser 文件被删除了? 我使用的是 0.9.2 Storm 和 3.4.6 ZK 版本. o.a.c.f.s.ConnectionStateManager [INFO] 状态更改:已连接2015-01-31 01:23:06 o.a.c.f.
..
我正在尝试在我的 Macbook Pro 上设置 Apache Storm (1.0.2),但如果我尝试部署拓扑,显然会遇到超时问题.用户界面也挂了,吐出同样的异常. 3491 [main] INFO o.a.s.StormSubmitter - 为 MD5-digest 生成的 ZooKeeper 秘密负载:-8915636774701640550:-651075265796178588635
..
我们将 Storm 与 Kafka 和 ZooKeeper 一起使用.我们遇到过必须删除一些主题并使用不同名称重新创建它们的情况.除了现在读取新主题名称之外,我们的 Kafka 喷口保持不变.但是现在,当尝试从新主题读取时,spout 正在使用旧主题分区的偏移量.因此,my-topic-name 分区 0 的尾部位置将为 500,但偏移量将类似于 10000. 有没有办法重置偏移位置,使其与
..
我正在为 Storm 开发代码,这是开发人员的一个例子.我的问题是,当您从 IDE Eclipse 运行此代码时,没有建立 Storm 和 Zookeeper 之间的连接.Zookeeper运行在2181,也是设置在storm.yaml中. 我的例外是: 72992 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN o.a.s.s.o.a.z
..
我在尝试为本地开发 Windows 7 工作站启动 Storm nimbus 时遇到以下错误:错误:无法找到或加载主类 Files\Java\jdk1.8.0_92\bin;C:\Program storm.yaml: storm.zookeeper.servers:- “127.0.0.1"nimbus.seeds: ["127.0.0.1"]Storm.local.dir: "C:\\
..
我的问题是 Storm KafkaSpout 在一段时间后停止使用来自 Kafka 主题的消息.在 Storm 中启用调试时,我得到这样的日志文件: 2016-07-05 03:58:26.097 oasdtask [INFO] 发射:packet_spout __metrics [#object[org.apache.storm.metric.api.IMetricsConsumer$Ta
..
我正在关注 http://jayatiatblogs.blogspot.com/2011/11/storm-installation.html &http://zookeeper.apache.org/doc/r3.3.3/zookeeperAdmin.html#sc_zkMulitServerSetup 在 AWS EC2 的 Ubuntu 14.04 LTS 中设置 Apache Storm
..
我正在设置一个风暴集群来计算实时趋势和其他统计数据,但是我在将“恢复"功能引入该项目时遇到了一些问题,因为它允许 kafka-spout 最后读取的偏移量(kafka-spout 的源代码来自https://github.com/apache/incubator-storm/tree/master/external/storm-kafka)被记住.我以这种方式启动我的 kafka-spout:
..
我是 Java 和 Storm 的新手,所以请原谅任何明显的错误.我正在尝试使用水槽连接器运行风暴但它因以下错误而崩溃: java.lang.reflect.InvocationTargetException在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)在 sun.reflect.NativeMethodAccessor
..
我是 Storm 新手,尝试提交拓扑并发现了这个在主管 我在工人的日志文件中发现了这个 [ERROR] 异步循环死了!java.lang.RuntimeException: org.apache.thrift7.transport.TTransportException: java.net.ConnectException: 连接被拒绝在 backtype.storm.drpc.DRPCInv
..
我们的 Apache Storm 拓扑使用 KafkaSpout 侦听来自 Kafka 的消息,并在做了大量映射/减少/丰富/聚合等之后最终将数据插入到 Cassandra 中.还有另一个 kafka 输入,如果拓扑找到响应,我们将接收用户对数据的查询,然后将其发送到第三个 kafka 主题.现在我们想使用 Junit 编写 E2E 测试,其中我们可以直接以编程方式将数据插入到拓扑中,然后通过插入
..
我正在尝试使用 Eclipse 在 Linux 中运行 Storm starter 示例.我收到以下错误并且 nexttuple 函数从未被调用. 错误: 35979 [main] INFO o.a.s.d.supervisor - 关闭主管 cfba8fc6-81e6-47cb-b8b9-ec7c700f4dfe35981 [NIOServerCxn.Factory:0.0.0.0/0.
..
运行命令时: storm jar target/crawlIndexer-1.0-SNAPSHOT.jar org.apache.storm.flux.Flux --local es-injector.flux --sleep 86400000 我收到一条错误消息: 8710 [Thread-26-status-executor[4 4]] 错误 c.d.s.e.p.StatusUpdate
..
我们有一个用例,我们不想连续运行风暴拓扑.相反,有一组输入(10K+)应该在指定的时间处理,Spout 不断地发出这些输入并由拓扑中的其余螺栓处理.处理完所有输入后,我的 spout 中的 nextTuple 将没有任何内容可发出. 此时我们希望我们的拓扑在每天晚上 12:00 进入睡眠状态并重新启动进程. 风暴配置中是否有任何属性可以设置为每天运行一次拓扑并在处理完成后休眠并在指定时
..
我们有一个用例,我们不想连续运行风暴拓扑.相反,有一组输入(10K+)应该在指定的时间处理,Spout 不断地发出这些输入并由拓扑中的其余螺栓处理.处理完所有输入后,我的 spout 中的 nextTuple 将没有任何内容可发出. 此时我们希望我们的拓扑在每天晚上 12:00 进入睡眠状态并重新启动进程. 风暴配置中是否有任何属性可以设置为每天运行一次拓扑并在处理完成后休眠并在指定时
..
我可以使用本地集群运行storm Kafka,但不能使用storm Submitter 下面是我的拓扑代码 谁能帮我解决这个问题:) package com.org.kafka;导入 org.apache.storm.Config;导入 org.apache.storm.LocalCluster;导入 org.apache.storm.generated.AlreadyAliveExcep
..