聊聊ELASTICSEARCH的集群状态的管理和维护
Elasticsearch • vearne 发表了文章 • 2 个评论 • 5955 次浏览 • 2018-07-12 22:49
注意 本文参考的ES 5.0.1的源码
1. 查看集群状态
可以通过API查看集群状态
<br /> GET /_cluster/state<br />
大致可以得到如下内容
![cluster_state](https://ut-bucket01.sh1a.qings ... 7.jpeg)
version
集群状态数字版本号
每次更新version + 1
集群重启version不会置0(只会单调增)
state_uuid
是集群状态字符串版本号(UUID)
master_node
master节点
nodes
该版本中的所有节点信息
routing_table
和 routing_nodes
都是描述不同index上的shard在node上的分布关系
2. 集群状态的维护
可以阅读
.//core/src/main/java/org/elasticsearch/cluster/ClusterState.java
- 2.1 ClusterState是不可变对象,每次状态变更都会产生新的ClusterState,它们拥有不同的版本号
- 2.2 在ES中, 集群状态由Master维护,并且只能由master节点更新集群状态
- 2.3 更新完成后,Master会把新版本的集群状态推送给集群的其它所有节点
对于publish,Master节点会根据它已知其它节点所拥有的集群状态版本,决定是执行
sendFullClusterState()
还是sendClusterStateDiff()
, 前者是全量推送,后者增量推送。
- 2.4 对于使用Zen Discovery的情况,只要有minimumMasterNodes响应了Master节点的
publish
消息, 那么这次的commit
就算成功
The cluster state can be updated only on the master node. All updates are performed by on a single thread and controlled by the {@link ClusterService}. After every update the
{@link Discovery#publish} method publishes new version of the cluster state to all other nodes in the cluster.
In the Zen Discovery it is handled in the {@link PublishClusterStateAction#publish} method
- 2.5 另外需要补充的是Elasticsearch使用Gossip + Bully算法进行选主。Bully算法在具体实现中,不是简单选取节点ID小的节点, 首先要先比较ClusterState的版本。版本高的优先当选。(各个版本实现有不同,但都需要考虑候选节点的集群状态版本)
<br /> /**<br /> * Elects a new master out of the possible nodes, returning it. Returns <tt>null</tt><br /> * if no master has been elected.<br /> */<br /> public MasterCandidate electMaster(Collection<MasterCandidate> candidates) {<br /> assert hasEnoughCandidates(candidates);<br /> List<MasterCandidate> sortedCandidates = new ArrayList<>(candidates);<br /> sortedCandidates.sort(MasterCandidate::compare);<br /> return sortedCandidates.get(0);<br /> }<br />
<br /> /**<br /> * compares two candidates to indicate which the a better master.<br /> * A higher cluster state version is better<br /> *<br /> * @return -1 if c1 is a batter candidate, 1 if c2.<br /> */<br /> public static int compare(MasterCandidate c1, MasterCandidate c2) {<br /> // we explicitly swap c1 and c2 here. the code expects "better" is lower in a sorted<br /> // list, so if c2 has a higher cluster state version, it needs to come first.<br /> int ret = Long.compare(c2.clusterStateVersion, c1.clusterStateVersion);<br /> if (ret == 0) {<br /> ret = compareNodes(c1.getNode(), c2.getNode());<br /> }<br /> return ret;<br /> }<br /> }<br />
参考资料
- [cluster-state](https://www.elastic.co/guide/e ... e.html)
欢迎光临我的个人博客 萌叔 | http://vearne.cc
- [cluster-state](https://www.elastic.co/guide/e ... e.html)
为什么Elastic.co 上的实例在不停的迁移
Elasticsearch • medcl 回复了问题 • 2 人关注 • 1 个回复 • 1470 次浏览 • 2018-07-12 16:41
社区日报 第330期 (2018-07-12)
社区日报 • 白衬衣 发表了文章 • 0 个评论 • 1301 次浏览 • 2018-07-12 15:23
http://t.cn/Rdumu4V
2.如何使用Kafka Streams构建广告消耗预测系统
http://t.cn/RlDKqWa
3.请自查!这些优秀日志实践准则,你做到了几点?
http://t.cn/Rldk5Ku
活动预告
1. 7月21日上海meetup倒计时
https://elasticsearch.cn/m/article/655
2. Elastic 中国开发者大会 2018 ,开始接受演讲申请和赞助合作
https://conf.elasticsearch.cn/2018/shenzhen.html
编辑:金桥
归档:https://elasticsearch.cn/article/710
订阅:https://tinyletter.com/elastic-daily
elasticsearch如何使用hdfs备份的详细方案?
Elasticsearch • sun_changlong 回复了问题 • 3 人关注 • 2 个回复 • 2938 次浏览 • 2018-07-12 15:21
根据bucket过滤hit?
Elasticsearch • qiuxianxiang 回复了问题 • 3 人关注 • 2 个回复 • 2972 次浏览 • 2018-07-12 14:46
我想问x-pack不收费的版本什么时候发布
Kibana • zqc0512 回复了问题 • 2 人关注 • 1 个回复 • 2617 次浏览 • 2018-07-12 10:50
5.3.2版本报 java.lang.NoClassDefFoundError: org/apache/lucene/util/SetOnce
Elasticsearch • vidi 回复了问题 • 5 人关注 • 5 个回复 • 14703 次浏览 • 2018-07-12 09:28
kopf/cerebro的问题
Elasticsearch • zqc0512 回复了问题 • 3 人关注 • 2 个回复 • 2605 次浏览 • 2018-07-12 09:24
如何实现在搜索结果中进行二次搜索?
Elasticsearch • laoyang360 回复了问题 • 4 人关注 • 2 个回复 • 6307 次浏览 • 2018-07-11 20:56
新手求助 装的es6.2.3版本 如何做到和oracle同步数据
Elasticsearch • laoyang360 回复了问题 • 2 人关注 • 1 个回复 • 2559 次浏览 • 2018-07-11 20:53
es存储word,pdf文档
Elasticsearch • laoyang360 回复了问题 • 5 人关注 • 7 个回复 • 10441 次浏览 • 2018-07-11 20:48
社区日报 第329期 (2018-07-11)
社区日报 • 千夜 发表了文章 • 0 个评论 • 1309 次浏览 • 2018-07-11 10:30
http://t.cn/RdnqiW0
2. 使用ELK在DC / OS中进行日志管理
http://t.cn/Rdn5hfQ
3.使用Logstash收集Mesos日志
http://t.cn/Rdn5QaI
1. 7月21日上海meetup倒计时
https://elasticsearch.cn/m/article/655
2. Elastic 中国开发者大会 2018 ,开始接受演讲申请和赞助合作
https://conf.elasticsearch.cn/2018/shenzhen.html
编辑:江水
归档:https://elasticsearch.cn/article/709
订阅:https://tinyletter.com/elastic-daily