# 微服务引擎 #
0
关注
8082内容
|
大数据分布式架构单点故障详解(Hdfs+Yarn+HBase+Spark+Storm)构建HA高可用架构
本文梳理了常见的hadoop生态圈中的组件：Hdfs+Yarn+HBase+Spark+Storm的单点故障问题，出现原因以及单点故障的原理和解决方案（构建HA（High Available）高可用架构）。阅读本文之前，最好了解清楚各组件的架构原理。
Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示
1.大数据处理的常用方法
大数据处理目前比较流行的是两种方法，一种是离线处理，一种是在线处理，基本处理架构如下：
在互联网应用中，不管是哪一种处理方式，其基本的数据来源都是日志数据，例如对于web应用来说，则可能是用户的访问日志、用户的点击日志等。
|
zookeeper解决Error contacting service. It is probably not running.
应用场景
安装了zookeeper集群之后，应用命令zkServer.sh start后，启动了zookeeper服务，用jps进程发现存在QuorumPeerMain进程，但是查看zookeeper状态的时候，发现报Error contacting service. It is probably not running.错误，提示服务并没有启动，那这是什么原因呢？原因可能有多种造成的，下面我们来分析一下。
|
高并发架构系列：如何从0到1设计一个类Dubbo的RPC框架
在过去持续分享的几十期阿里Java面试题中，几乎每次都会问到Dubbo相关问题，比如：“如何从0到1设计一个Dubbo的RPC框架”，这个问题主要考察以下几个方面：
你对RPC框架的底层原理掌握程度。
考验你的整体RPC框架系统设计能力。本文详解~
消息队列的exclusive consumer功能是如何保证消息有序和防止脑裂的
一般来说，消息队列都会保证queue当中的消息的顺序。然而如果有多个consumer同时消费同一个queue，那么这时就不能保证的消息的顺序性。
有时候，消息的顺序是非常重要的，为了能顺序的消费消息，我们只能启动一个consumer来消费这个queue。
|
回归模型评估指标
SSE(和方差、误差平方和)：The sum of squares dueto error
MSE(均方差、方差)：Meansquared error
RMSE(均方根、标准差)：Root mean squared error
R-square(确定系数)：Coefficientof determ...
E-MapReduce上如何采集Kafka客户端Metrics
我们知道Kafka提供一套非常完善的Metrics数据，覆盖Broker，Consumer，Producer，Stream以及Connect。E-MapReduce通过Ganglia收集了Kafka Broker metrics信息，可以很好地监控Broker运行状态。
Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka
聊什么
为了满足本系列读者的需求，在完成《Apache Flink 漫谈系列(14) - DataStream Connectors》之前，我先介绍一下Kafka在Apache Flink中的使用。所以本篇以一个简单的示例，向大家介绍在Apache Flink中如何使用Kafka。
免费试用