集群环境下java单例查询多了就异常
JackGe 回复了问题 • 2 人关注 • 1 个回复 • 2623 次浏览 • 2018-07-14 22:11
elasticsearch5.6.9索引库不同type,同名字段的类型以及分词器的疑问
AndrewOYLK 回复了问题 • 2 人关注 • 1 个回复 • 1718 次浏览 • 2018-07-14 11:40
es5 想删除一项settings配置 怎么删
rockybean 回复了问题 • 4 人关注 • 2 个回复 • 4899 次浏览 • 2018-07-13 15:31
kibana 找不到Elasticsearch 节点
yu754369677 回复了问题 • 3 人关注 • 4 个回复 • 7141 次浏览 • 2018-07-13 14:33
es如何定位shard在那个节点?
vearne 回复了问题 • 6 人关注 • 4 个回复 • 2748 次浏览 • 2018-07-13 14:18
es 查询:_search 可以看到的数据 通过 index/type/id 却查不到
yayg2008 回复了问题 • 5 人关注 • 3 个回复 • 23586 次浏览 • 2018-07-13 11:55
elasticsearch集群日志存储问题
code4j 回复了问题 • 3 人关注 • 1 个回复 • 3993 次浏览 • 2018-07-13 11:51
googleplay分成google play,什么分词器支持呢?
rochy 回复了问题 • 2 人关注 • 1 个回复 • 2245 次浏览 • 2018-07-13 11:02
Es能否实现sql全数据的group by
dx420811682 回复了问题 • 3 人关注 • 2 个回复 • 9405 次浏览 • 2018-07-13 10:54
聊聊ELASTICSEARCH的集群状态的管理和维护
vearne 发表了文章 • 2 个评论 • 5976 次浏览 • 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 上的实例在不停的迁移
medcl 回复了问题 • 2 人关注 • 1 个回复 • 1475 次浏览 • 2018-07-12 16:41
elasticsearch如何使用hdfs备份的详细方案?
sun_changlong 回复了问题 • 3 人关注 • 2 个回复 • 2940 次浏览 • 2018-07-12 15:21
根据bucket过滤hit?
qiuxianxiang 回复了问题 • 3 人关注 • 2 个回复 • 2974 次浏览 • 2018-07-12 14:46