需求：每行数据格式"{\"movie\":\"2599\",\"rate\":\"5\",\"timeStamp\":\"957716949\",\"uid\":\"6040\"}"从其中计算出每个用户评分最高的十步电影movie值和rate值输出为uid：...movie...rate...思路：map端先将读取的json数据转成pojo对象，所以要创建一个bean用

程序一直运行正常，服务器异常kafka断开了一个broker，重新启动后抛出下面异常：18/10/22 23:24:41 INFO YarnClientSchedulerBackend: Application application_1536983779148_0365 has started running.18/10/22 23:24:41 INFO Utils: Successfu...

最近公司部署了一个sparkstreaming程序，主要逻辑是处理flume采集到kafka的数据，集群环境3个nodemanager，5核20G内存，刚开始测试阶段并没设置资源配置，直接丢在yarn上运行，每天的数据量大概2500万records。测试几天后发现数据处理时间延迟稍微长了一点，怀疑是程序处理数据的数据低于数据产生的数据，随着时间和数据的增加，这个时间延迟越来越大，遂决定对程序进行相

Error registering plugin {:pipeline_id=>"main", :plugin=>"#<LogStash::OutputDelegator:0x761d397b@namespaced_metric=#<LogStash::Instrument::NamespacedMetric:0

C语言编程数据结构中的哈弗曼树是非常重要的，哈夫曼主要是它的编码应用可以保证译码的非二义性。每天坚持编写一个程序，持之以恒，我们就会更加熟练的进行编程，从而为以后打下基础。下面是今天编写的HUffman树的源代码，因为纯手写，没有运行，了解了原理才是最重要的嘛！