继之前遇到的那个同步问题的坑之后(storm坑之---同步问题),最近对代码又做了调整和重构,并且又遇到了另一个storm开发中应该值得警惕的坑。接下来说说这个坑的大体情况。 在我的storm程序中,Abolt需要将数据封装成一个对象同时发送给Bbolt和Cbolt各一份,Bbolt和Cbol...
分类:
其他好文 时间:
2015-05-04 21:39:46
阅读次数:
150
Java基础细节记录Java的index不是从0开始的情况: 格式化参数索引是从1开始的,而不是0:System.out.println(%1$s %2$s, "Test: ", "OK");Java中在使用while loop的时候要小心endless loop的情况, 因为while是当什么时....
分类:
编程语言 时间:
2015-05-04 19:32:28
阅读次数:
129
Threejs-webGL库官方网站:http://threejs.org/学习教程:https://github.com/josdirksen/learning-threejs源码下载:http://blog.csdn.net/column/details/omni360threejs.html源...
分类:
Web程序 时间:
2015-05-04 13:31:37
阅读次数:
193
Deep Learning: A Practitioner's Approachhttp://www.amazon.com/Deep-Learning-Practitioners-Adam-Gibson/dp/1491914254/ref=sr_1_1?ie=UTF8&qid=1430704761&...
分类:
其他好文 时间:
2015-05-04 11:29:26
阅读次数:
129
storm 测试集群上一个supervisor 挂掉,查看日志发现:java.io.FileNotFoundException: File '/home/q/storm/storm-data/supervisor/stormdist/Track_NotFind-66-1372059953/storm...
分类:
其他好文 时间:
2015-05-04 11:28:44
阅读次数:
129
在上一次单词计数的基础上做如下改动: 使用 自定义 ?分组策略,将首字母相同的单词发送给同一个task计数 自定义?CustomStreamGrouping package com.zhch.v4;
import backtype.storm.generated.GlobalStreamId...
分类:
其他好文 时间:
2015-05-03 23:58:03
阅读次数:
344
在上一次单词计数的基础上做如下改动: 使用?Direct Grouping 分组策略,将首字母相同的单词发送给同一个task计数 数据源spout package com.zhch.v3;
import backtype.storm.spout.SpoutOutputCollector;
impor...
分类:
其他好文 时间:
2015-05-03 22:10:54
阅读次数:
311
在上一次单词计数的基础上做如下改动: 1. 使用可靠的消息处理机制 2. 配置?worker 、executor、task 数量 3. 使用集群模式提交 数据源spout package com.zhch.v2;
import backtype.storm.spout.SpoutOutputCo...
分类:
其他好文 时间:
2015-05-03 19:12:59
阅读次数:
173
Python has become immensely popular in the modern IT world. The language is most popular for its efficiency. It is also known as the best beginner’s learning language. The prime reason why Python ...
分类:
编程语言 时间:
2015-05-03 19:12:53
阅读次数:
184
概念: Workers (JVMs): 在一个节点上可以运行一个或多个独立的JVM 进程。一个Topology可以包含一个或多个worker(并行的跑在不同的machine上), 所以worker process就是执行一个topology的子集, 并且worker只能对应...
分类:
其他好文 时间:
2015-05-03 14:45:11
阅读次数:
114