• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:apache-storm

apache-storm

升级Apache Storm(1.0.0至1.2.3)

升级Apache Storm(1.0.0至1.2.3)
我需要将Apache Storm 1.0.0更新到最新版本1.x.x(1.2.3)。需要什么步骤?风暴配置文件有什么变化?有帮助(迁移)的指南吗? 非常感谢 解决方案如下: 我不相信(但可能是错误的)1.0.0和1.2.3之间的配置文件中没有任何重大更改。迁移应遵循Storm升级的常规步骤: 一次升级您的Storm主机一次 下载1.2.3二进制发行版……继续阅读 »

apache-storm

找不到Storm Hbase配置

找不到Storm Hbase配置
因此,我建立了一个来自kafka的 Storm 喷口,并用 bolt 写入HDFS。这一切都很好。现在,我想添加一个写入Hbase的新 bolt 。由于某些原因,我的应用程序未获取hbase配置资料,并且出现以下错误: java.lang.IllegalArgumentException: HBase configuration no……继续阅读 »

apache-storm

在Apache Storm上为 bolt 添加重试机制

在Apache Storm上为 bolt 添加重试机制
我的 Storm 拓扑中有一个 bolt (调度程序),可以打开http请求连接。 如果发生故障(连接超时,故障状态等),我想添加重试机制。重试应该仅在调度程序 bolt 中进行,而不能从整个拓扑开始。 通常我要做的是添加一个队列,该队列负责重试和异常处理(例如3次后自动将消息分发到错误队列。) 在 bolt 内做这样的事情可以吗?任何人都有任何经验,可以建……继续阅读 »

apache-storm

如何使用Redis和Flask连接Storm和D3.js?

如何使用Redis和Flask连接Storm和D3.js?
我已经完成了Storm测试拓 flutter ,并且在Html代码上创建d3脚本之前,该脚本从文本文件读取了数据。我现在希望它直接从Storm拓 flutter 中读取数据(也许是 bolt ?),但是我不知道如何执行此操作。我正在使用Horton Works Sandbox进行测试,对您的帮助将不胜感激。 提前致谢! 我找到了一个现在要使用的Redis S……继续阅读 »

apache-storm

测试Java HBase连接

测试Java HBase连接
我正在尝试使用HBase Java API将数据写入HBase。我通过Ambari安装了Hadoop / HBase。 这是当前设置的方式: final Configuration CONFIGURATION = HBaseConfiguration.create(); final HBaseAdmin HBASE_ADMIN; HBASE_ADMIN =……继续阅读 »