Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
NotSerializedException org.neo4j.kernel.EmbeddedGraphDatabase
我正在使用 neo4j 创建图表 将 mongodb 中的数据作为文档 独立代码运行良好 没有风暴 但是 在将其与 Storm 集成时 我得到了 java io NotSerializedException org neo4j kernel
MongoDB
neo4j
apachestorm
找不到 Storm 日志查看器页面
我可以在多租户集群中提交拓扑作业 作业正在运行 但是 日志查看器页面不可用 有什么办法可以解决这个问题吗 在单击之前您需要启动日志查看器topology port查看日志查看器 要启动日志查看器 请运行 storm logviewer和你跑
apachestorm
logviewer
使用storm时如何将拓扑上下文中的对象访问到bolt中?
我们在创建拓扑时需要传递一个对象 以便 Bolt 可以访问该对象并基于该对象进行一些进一步的处理 是否可以通过传递对象TopplogyContext如果是 怎么办 或者是否有其他方法可以在提交拓扑时传递对象 然后再提交 以便 Bolt 可以
apachestorm
如何使用 Log4j 和 Storm Framework 将日志写入文件?
我在 Storm 中使用 log4j 记录到文件时遇到了一些问题 在提交我的拓扑之前 即在我的主要方法中 我编写了一些日志语句并使用以下方法配置了记录器 PropertyConfigurator configure myLog4jPrope
Java
logging
Log4j
slf4j
apachestorm
将一个项目导入到另一个导入的项目中
我在一个项目的帮助中找到了这个声明 我想将其导入名为 storm 选举 这是一个基于storm starter 项目的简单演示应用程序 https github com nathanmarz storm starter https gith
eclipse
apachestorm
java.lang.ClassNotFoundException:kafka.api.OffsetRequest
我在尝试将 Kafka 集成到我们的 Storm 拓扑时收到错误 java lang ClassNotFoundException kafka api OffsetRequest 您正在运行什么版本并且它正在运行 我的 pom xml
ApacheKafka
apachestorm
Storm拓扑未提交
我已经配置了我的机器zookeeper nimbus supervisor运行正常 并且我的拓扑在LocalCluster中工作 LocalCluster cluster new LocalCluster cluster submitTop
Java
Log4j
rabbitmq
slf4j
apachestorm
重新平衡 Apache Storm 中的执行器
我正在尝试重新平衡正在运行的 Apache Storm 0 9 5 拓扑中的 Bolt 的执行器数量 当我对 Nimbus 节点执行命令时 storm rebalance MyTopology n 2 e GreenBolt 4它接受命令行
apachestorm
Storm:如何将字符串数组从一个螺栓传递到另一个螺栓?
这就是我发出数据的方式 collector emit stream new Values sessionid tables Where sessionid and tables are ArrayList
Java
ArrayList
apachestorm
在 Apache Storm Bolt 中使用 Apache Camel ProducerTemplate
我正在尝试编写简单的 Storm Camel 项目 我的 Storm 拓扑分析推文 一个 Bolt 应该将推文文本发送到 apache 骆驼路由 而该路由又使用 websocket 通知某些 Web 应用程序 由于尝试使用一次构建 Came
Java
apachecamel
apachestorm
Storm-Kafka多个spout,如何分担负载?
我正在尝试在多个喷口之间分担任务 我遇到一种情况 我一次从外部源获取一个元组 消息 并且我想要拥有多个 spout 实例 其背后的主要目的是共享负载并提高性能效率 我可以对一个 Spout 本身执行相同的操作 但我想在多个 Spout 之间
Java
loadbalancing
apachestorm
ApacheKafka
测试java HBase连接
我正在尝试使用 HBase Java API 将数据写入 HBase 我通过 Ambari 安装了 Hadoop HBase 以下是当前设置配置的方式 final Configuration CONFIGURATION HBaseConfi
Java
Hadoop
Hbase
apachestorm
如何通过 eclipse 在本地集群/模式下调试 Apache Storm
使用以下问答 我设法通过 Apache Storm 集群 本地运行 上的 eclipse 启用调试 如何在 Eclipse 中调试 Apache Storm My conf storm yaml有以下行可以在工作节点上启用调试 worker
Java
eclipse
debugging
apachestorm
构建 Storm 时 Zookeeper 出现 ClassNotFoundException
我是 java 和 Storm 的新手 所以请原谅任何明显的错误 我正在尝试使用水槽连接器进行风暴 但它因以下错误而崩溃 java lang reflect InvocationTargetException at sun reflect
Java
apachezookeeper
apachestorm
Eclipse 中 Storm 集群关闭
我有一个问题 我知道有麻烦 但找不到解决方案 集群没有关闭 抛出 IOException I O 方法不起作用 因为 Windows 不允许临时文件夹 我的意思是这个路径 C Users Mert AppData Local Temp 8b
Java
Realtime
distributedcomputing
apachestorm
如何将两个不同Spout的输出发送到同一个Bolt?
我有两个 Kafka Spout 我想将它们的值发送到同一个 Bolt 是否可以 对的 这是可能的 TopologyBuilder b new TopologyBuilder b setSpout topic 1 new KafkaSpou
Java
ApacheKafka
apachestorm
Graphite/Carbon 如何获取每秒指标
I ve 泊坞窗化石墨正在与这个图书馆从 Apache Storm 拓扑获取指标 我正在获取指标数据 但无论我做什么 我只能每分钟获取数据 而我真正需要的是每秒的点数 As per 这个帖子我已将保留策略设置为每秒抓取数据 我也设置了 co
Java
apachestorm
Metrics
graphite
添加 jsoup 作为提供的依赖项后,Storm 命令失败并出现 NoClassDefFoundError
我在我的项目中使用 JSoup 并且我已经在我的项目中声明了依赖关系POM文件 它编译得很好并且运行得很好 但只有当我使用jar with all dependencies并将依赖范围更改为compiled 如果我将此范围更改为provid
Java
python
Maven
apachestorm
java.lang.ClassNotFoundException:TopologyMain
我正在尝试向本地风暴集群提交一个简单的字数统计拓扑 首先 我尝试使用 Maven 然后使用 Storm 命令行客户端 我使用 eclipse 创建了 JAR 文件 但是 它抛出主类未找到异常 谁能告诉我可能是什么问题 我在下面附上代码和异常
Java
Maven
apachestorm
«
1
2