lide-reed closed pull request #511: EsTable without partition info
URL: https://github.com/apache/incubator-doris/pull/511
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/fe/src/main/java/org/apache/doris/catalog/EsTable.java
b/fe/src/main/java/org/apache/doris/catalog/EsTable.java
index 565ecd2b..a0d93091 100644
--- a/fe/src/main/java/org/apache/doris/catalog/EsTable.java
+++ b/fe/src/main/java/org/apache/doris/catalog/EsTable.java
@@ -161,6 +161,7 @@ public void write(DataOutput out) throws IOException {
public void readFields(DataInput in) throws IOException {
super.readFields(in);
hosts = Text.readString(in);
+ seeds = hosts.split(",");
userName = Text.readString(in);
passwd = Text.readString(in);
indexName = Text.readString(in);
diff --git a/fe/src/main/java/org/apache/doris/external/EsIndexState.java
b/fe/src/main/java/org/apache/doris/external/EsIndexState.java
index 60ce59da..bcb69251 100644
--- a/fe/src/main/java/org/apache/doris/external/EsIndexState.java
+++ b/fe/src/main/java/org/apache/doris/external/EsIndexState.java
@@ -68,8 +68,12 @@ public static EsIndexState parseIndexStateV55(String
indexName, JSONObject indic
JSONObject shard = shardRouting.getJSONObject(i);
String shardState = shard.getString("state");
if ("STARTED".equalsIgnoreCase(shardState)) {
-
singleShardRouting.add(EsShardRouting.parseShardRoutingV55(shardState,
- shardKey, shard, nodesMap));
+ try {
+
singleShardRouting.add(EsShardRouting.parseShardRoutingV55(shardState,
+ shardKey, shard, nodesMap));
+ } catch (Exception e) {
+ LOG.info("errors while parse shard routing from json
[{}], ignore this shard", shard.toString(), e);
+ }
}
}
if (singleShardRouting.isEmpty()) {
@@ -80,7 +84,7 @@ public static EsIndexState parseIndexStateV55(String
indexName, JSONObject indic
// get some meta info from es, could be used to prune index when query
// index.bpack.partition.upperbound: stu_age
- if (partitionInfo instanceof RangePartitionInfo) {
+ if (partitionInfo != null && partitionInfo instanceof
RangePartitionInfo) {
JSONObject indexMeta = indicesMetaMap.getJSONObject(indexName);
JSONObject partitionSetting = EsUtil.getJsonObject(indexMeta,
"settings.index.bpack.partition", 0);
LOG.debug("index {} range partition setting is {}", indexName,
diff --git a/fe/src/main/java/org/apache/doris/external/EsStateStore.java
b/fe/src/main/java/org/apache/doris/external/EsStateStore.java
index 1b97a740..20ec7bed 100644
--- a/fe/src/main/java/org/apache/doris/external/EsStateStore.java
+++ b/fe/src/main/java/org/apache/doris/external/EsStateStore.java
@@ -85,9 +85,13 @@ public void deRegisterTable(long tableId) {
protected void runOneCycle() {
for (EsTable esTable : esTables.values()) {
- EsTableState esTableState = loadEsIndexMetadataV55(esTable);
- if (esTableState != null) {
- esTable.setEsTableState(esTableState);
+ try {
+ EsTableState esTableState = loadEsIndexMetadataV55(esTable);
+ if (esTableState != null) {
+ esTable.setEsTableState(esTableState);
+ }
+ } catch (Throwable e) {
+ LOG.error("errors while load table {} state from es",
esTable.getName());
}
}
}
diff --git a/fe/src/main/java/org/apache/doris/planner/EsScanNode.java
b/fe/src/main/java/org/apache/doris/planner/EsScanNode.java
index fe1977d3..cc5079ee 100644
--- a/fe/src/main/java/org/apache/doris/planner/EsScanNode.java
+++ b/fe/src/main/java/org/apache/doris/planner/EsScanNode.java
@@ -240,6 +240,9 @@ private void assignBackends() throws UserException {
* @throws AnalysisException
*/
private Collection<Long> partitionPrune(PartitionInfo partitionInfo)
throws AnalysisException {
+ if (partitionInfo == null) {
+ return null;
+ }
PartitionPruner partitionPruner = null;
switch (partitionInfo.getType()) {
case RANGE: {
diff --git a/fe/src/test/java/org/apache/doris/catalog/CatalogTestUtil.java
b/fe/src/test/java/org/apache/doris/catalog/CatalogTestUtil.java
index 350cbd0b..5f2ec992 100644
--- a/fe/src/test/java/org/apache/doris/catalog/CatalogTestUtil.java
+++ b/fe/src/test/java/org/apache/doris/catalog/CatalogTestUtil.java
@@ -279,7 +279,7 @@ public static void createUnPartitionedEsTable(Database db)
throws DdlException {
.newArrayList("100")),
null));
- RangePartitionInfo partitionInfo = new
RangePartitionInfo(partitionColumns);
+ SinglePartitionInfo partitionInfo = new SinglePartitionInfo();
Map<String, String> properties = Maps.newHashMap();
properties.put(EsTable.HOSTS, "xxx");
properties.put(EsTable.INDEX, "indexa");
diff --git a/fe/src/test/java/org/apache/doris/es/EsStateStoreTest.java
b/fe/src/test/java/org/apache/doris/es/EsStateStoreTest.java
index d649d5df..569e3ba1 100644
--- a/fe/src/test/java/org/apache/doris/es/EsStateStoreTest.java
+++ b/fe/src/test/java/org/apache/doris/es/EsStateStoreTest.java
@@ -62,6 +62,8 @@
private static String clusterStateStr1 = "";
private static String clusterStateStr2 = "";
private static String clusterStateStr3 = "";
+ private static String clusterStateStr4 = "";
+ private static String clusterStateStr5 = "";
private EsStateStore esStateStore;
@BeforeClass
@@ -79,6 +81,8 @@ public static void init() throws IOException,
InstantiationException, IllegalAcc
clusterStateStr1 = loadJsonFromFile("data/es/clusterstate1.json");
clusterStateStr2 = loadJsonFromFile("data/es/clusterstate2.json");
clusterStateStr3 = loadJsonFromFile("data/es/clusterstate3.json");
+ clusterStateStr4 = loadJsonFromFile("data/es/clusterstate4.json");
+ clusterStateStr5 = loadJsonFromFile("data/es/clusterstate5.json");
}
@Before
@@ -90,7 +94,6 @@ public void setUp() {
* partitioned es table schema: k1(date), k2(int), v(double)
* @throws AnalysisException
*/
- @Ignore
@Test
public void testParsePartitionedClusterState() throws AnalysisException {
EsTable esTable = (EsTable) Catalog.getCurrentCatalog()
@@ -138,7 +141,6 @@ public void testParsePartitionedClusterState() throws
AnalysisException {
* 2 indices, one with partition desc, the other does not contains
partition desc
* @throws AnalysisException
*/
- @Ignore
@Test
public void testParsePartitionedClusterStateTwoIndices() throws
AnalysisException {
EsTable esTable = (EsTable) Catalog.getCurrentCatalog()
@@ -180,6 +182,75 @@ public void testParsePartitionedClusterStateTwoIndices()
throws AnalysisExceptio
assertEquals(6, esIndexState2.getShardRoutings().size());
}
+ /**
+ * partitioned es table schema: k1(date), k2(int), v(double)
+ * scenario desc:
+ * 2 indices, both of them does not contains partition desc and es table
does not have partition info
+ * but cluster state have partition info
+ * @throws AnalysisException
+ */
+ @Test
+ public void testParseUnPartitionedClusterStateTwoIndices() throws
AnalysisException {
+ EsTable esTable = (EsTable) Catalog.getCurrentCatalog()
+ .getDb(CatalogTestUtil.testDb1)
+
.getTable(CatalogTestUtil.testUnPartitionedEsTableId1);
+ boolean hasException = false;
+ EsTableState esTableState = null;
+ try {
+ esTableState = esStateStore.parseClusterState55(clusterStateStr4,
esTable);
+ } catch (Exception e) {
+ e.printStackTrace();
+ hasException = true;
+ }
+ assertFalse(hasException);
+ assertNotNull(esTableState);
+
+ // check
+ assertEquals(0, esTableState.getPartitionedIndexStates().size());
+ assertEquals(2, esTableState.getUnPartitionedIndexStates().size());
+
+ // check index with no partition desc
+ EsIndexState esIndexState1 =
esTableState.getUnPartitionedIndexStates().get("index1");
+ assertEquals("index1", esIndexState1.getIndexName());
+ EsIndexState esIndexState2 =
esTableState.getUnPartitionedIndexStates().get("index2");
+ assertEquals("index2", esIndexState2.getIndexName());
+ assertEquals(6, esIndexState2.getShardRoutings().size());
+ }
+
+ /**
+ * test node without thrift info, parse without error, but es index state
is empty
+ * @throws AnalysisException
+ */
+ @Test
+ public void testParseUnPartitionedWithoutThriftInfo() throws
AnalysisException {
+ EsTable esTable = (EsTable) Catalog.getCurrentCatalog()
+ .getDb(CatalogTestUtil.testDb1)
+
.getTable(CatalogTestUtil.testUnPartitionedEsTableId1);
+ boolean hasException = false;
+ EsTableState esTableState = null;
+ try {
+ esTableState = esStateStore.parseClusterState55(clusterStateStr5,
esTable);
+ } catch (Exception e) {
+ e.printStackTrace();
+ hasException = true;
+ }
+ assertFalse(hasException);
+ assertNotNull(esTableState);
+
+ // check
+ assertEquals(0, esTableState.getPartitionedIndexStates().size());
+ assertEquals(2, esTableState.getUnPartitionedIndexStates().size());
+
+ // check index with no partition desc
+ EsIndexState esIndexState1 =
esTableState.getUnPartitionedIndexStates().get("index1");
+ assertEquals("index1", esIndexState1.getIndexName());
+ EsIndexState esIndexState2 =
esTableState.getUnPartitionedIndexStates().get("index2");
+ assertEquals("index2", esIndexState2.getIndexName());
+ assertEquals(6, esIndexState2.getShardRoutings().size());
+
+ assertEquals(0, esIndexState1.getShardRoutings().get(1).size());
+ }
+
/**
* partitioned es table schema: k1(date), k2(int), v(double)
* "upperbound": "2018" is not a valid date value, so parsing procedure
will fail
diff --git a/fe/src/test/resources/data/es/clusterstate4.json
b/fe/src/test/resources/data/es/clusterstate4.json
new file mode 100644
index 00000000..6a0bdd18
--- /dev/null
+++ b/fe/src/test/resources/data/es/clusterstate4.json
@@ -0,0 +1,747 @@
+{
+ "cluster_name": "elasticsearch",
+ "version": 28,
+ "state_uuid": "C6WNazFPSPyZcQlE-cNw1g",
+ "master_node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "blocks": {},
+ "nodes": {
+ "ejy2E2sMTg6nqnjhF9KfsQ": {
+ "name": "ejy2E2s",
+ "ephemeral_id": "HO-_F6BLSqedHuv7-yhkNQ",
+ "transport_address": "192.168.0.1:9209",
+ "attributes": {
+ "thrift_port": "9210"
+ }
+ }
+ },
+ "metadata": {
+ "cluster_uuid": "_na_",
+ "templates": {},
+ "indices": {
+ "index2": {
+ "state": "open",
+ "settings": {
+ "index": {
+ "number_of_shards": "5",
+ "provided_name": "index2",
+ "creation_date": "1539592090322",
+ "number_of_replicas": "1",
+ "uuid": "T-Kg83WaTOSIXmiO0ZANzg",
+ "version": {
+ "created": "5050099"
+ }
+ }
+ },
+ "mappings": {},
+ "aliases": [
+ "indexa"
+ ],
+ "primary_terms": {
+ "0": 1,
+ "1": 1,
+ "2": 1,
+ "3": 1,
+ "4": 1
+ },
+ "in_sync_allocations": {
+ "0": [
+ "gbBnb3KFQOyXHl3eaVV6nA"
+ ],
+ "1": [
+ "sNsOyQBnSdKQuFETNtRYng"
+ ],
+ "2": [
+ "4UZfdxQeT7CMUxI9Fl5tYA"
+ ],
+ "3": [
+ "70TzfLRxQ_KL-tT81-QO4w"
+ ],
+ "4": [
+ "GhBM4mIdTAG-IVjGYFazkQ"
+ ]
+ }
+ },
+ "index1": {
+ "state": "open",
+ "settings": {
+ "index": {
+ "bpack": {
+ "partition": {
+ "upperbound": "2018-10-01"
+ }
+ },
+ "number_of_shards": "5",
+ "provided_name": "index1",
+ "creation_date": "1539592085059",
+ "number_of_replicas": "1",
+ "uuid": "hjbl6RxaTyCYFfAJwaSjCA",
+ "version": {
+ "created": "5050099"
+ }
+ }
+ },
+ "mappings": {},
+ "aliases": [
+ "indexa"
+ ],
+ "primary_terms": {
+ "0": 1,
+ "1": 1,
+ "2": 1,
+ "3": 1,
+ "4": 1
+ },
+ "in_sync_allocations": {
+ "0": [
+ "WFVdvk1eQrmOfemq6UoBIw"
+ ],
+ "1": [
+ "_ASJYn1bRO2MnCN0HKH5BA"
+ ],
+ "2": [
+ "o5kBd295ReKi2g4g1bpjyA"
+ ],
+ "3": [
+ "orpHABU0S8eJ0Nd82U_SQA"
+ ],
+ "4": [
+ "6I6OQ1QfTgCvHigkIdmuPA"
+ ]
+ }
+ }
+ },
+ "index-graveyard": {
+ "tombstones": []
+ }
+ },
+ "routing_table": {
+ "indices": {
+ "index2": {
+ "shards": {
+ "0": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index2",
+ "allocation_id": {
+ "id": "gbBnb3KFQOyXHl3eaVV6nA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "1": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index2",
+ "allocation_id": {
+ "id": "sNsOyQBnSdKQuFETNtRYng"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "2": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index2",
+ "allocation_id": {
+ "id": "4UZfdxQeT7CMUxI9Fl5tYA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "3": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index2",
+ "allocation_id": {
+ "id": "70TzfLRxQ_KL-tT81-QO4w"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "4": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "allocation_id": {
+ "id": "GhBM4mIdTAG-IVjGYFazkQ"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "5": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "allocation_id": {
+ "id": "GhBM4mIdTAG-IVjGYFazkQ"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ]
+ }
+ },
+ "index1": {
+ "shards": {
+ "0": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index1",
+ "allocation_id": {
+ "id": "WFVdvk1eQrmOfemq6UoBIw"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "1": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index1",
+ "allocation_id": {
+ "id": "_ASJYn1bRO2MnCN0HKH5BA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "2": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index1",
+ "allocation_id": {
+ "id": "o5kBd295ReKi2g4g1bpjyA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "3": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index1",
+ "allocation_id": {
+ "id": "orpHABU0S8eJ0Nd82U_SQA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "4": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index1",
+ "allocation_id": {
+ "id": "6I6OQ1QfTgCvHigkIdmuPA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ]
+ }
+ }
+ }
+ },
+ "routing_nodes": {
+ "unassigned": [
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "nodes": {
+ "ejy2E2sMTg6nqnjhF9KfsQ": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index2",
+ "allocation_id": {
+ "id": "4UZfdxQeT7CMUxI9Fl5tYA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index2",
+ "allocation_id": {
+ "id": "sNsOyQBnSdKQuFETNtRYng"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "allocation_id": {
+ "id": "GhBM4mIdTAG-IVjGYFazkQ"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index2",
+ "allocation_id": {
+ "id": "70TzfLRxQ_KL-tT81-QO4w"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index2",
+ "allocation_id": {
+ "id": "gbBnb3KFQOyXHl3eaVV6nA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index1",
+ "allocation_id": {
+ "id": "o5kBd295ReKi2g4g1bpjyA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index1",
+ "allocation_id": {
+ "id": "_ASJYn1bRO2MnCN0HKH5BA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index1",
+ "allocation_id": {
+ "id": "6I6OQ1QfTgCvHigkIdmuPA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index1",
+ "allocation_id": {
+ "id": "orpHABU0S8eJ0Nd82U_SQA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index1",
+ "allocation_id": {
+ "id": "WFVdvk1eQrmOfemq6UoBIw"
+ }
+ }
+ ]
+ }
+ }
+ }
diff --git a/fe/src/test/resources/data/es/clusterstate5.json
b/fe/src/test/resources/data/es/clusterstate5.json
new file mode 100644
index 00000000..8c110ad4
--- /dev/null
+++ b/fe/src/test/resources/data/es/clusterstate5.json
@@ -0,0 +1,751 @@
+{
+ "cluster_name": "elasticsearch",
+ "version": 28,
+ "state_uuid": "C6WNazFPSPyZcQlE-cNw1g",
+ "master_node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "blocks": {},
+ "nodes": {
+ "ejy2E2sMTg6nqnjhF9KfsQ": {
+ "name": "ejy2E2s",
+ "ephemeral_id": "HO-_F6BLSqedHuv7-yhkNQ",
+ "transport_address": "192.168.0.1:9209",
+ "attributes": {
+ }
+ }
+ },
+ "metadata": {
+ "cluster_uuid": "_na_",
+ "templates": {},
+ "indices": {
+ "index2": {
+ "state": "open",
+ "settings": {
+ "index": {
+ "bpack": {
+ "partition": {
+ "upperbound": "2018-10-02"
+ }
+ },
+ "number_of_shards": "5",
+ "provided_name": "index2",
+ "creation_date": "1539592090322",
+ "number_of_replicas": "1",
+ "uuid": "T-Kg83WaTOSIXmiO0ZANzg",
+ "version": {
+ "created": "5050099"
+ }
+ }
+ },
+ "mappings": {},
+ "aliases": [
+ "indexa"
+ ],
+ "primary_terms": {
+ "0": 1,
+ "1": 1,
+ "2": 1,
+ "3": 1,
+ "4": 1
+ },
+ "in_sync_allocations": {
+ "0": [
+ "gbBnb3KFQOyXHl3eaVV6nA"
+ ],
+ "1": [
+ "sNsOyQBnSdKQuFETNtRYng"
+ ],
+ "2": [
+ "4UZfdxQeT7CMUxI9Fl5tYA"
+ ],
+ "3": [
+ "70TzfLRxQ_KL-tT81-QO4w"
+ ],
+ "4": [
+ "GhBM4mIdTAG-IVjGYFazkQ"
+ ]
+ }
+ },
+ "index1": {
+ "state": "open",
+ "settings": {
+ "index": {
+ "bpack": {
+ "partition": {
+ "upperbound": "2018-10-01"
+ }
+ },
+ "number_of_shards": "5",
+ "provided_name": "index1",
+ "creation_date": "1539592085059",
+ "number_of_replicas": "1",
+ "uuid": "hjbl6RxaTyCYFfAJwaSjCA",
+ "version": {
+ "created": "5050099"
+ }
+ }
+ },
+ "mappings": {},
+ "aliases": [
+ "indexa"
+ ],
+ "primary_terms": {
+ "0": 1,
+ "1": 1,
+ "2": 1,
+ "3": 1,
+ "4": 1
+ },
+ "in_sync_allocations": {
+ "0": [
+ "WFVdvk1eQrmOfemq6UoBIw"
+ ],
+ "1": [
+ "_ASJYn1bRO2MnCN0HKH5BA"
+ ],
+ "2": [
+ "o5kBd295ReKi2g4g1bpjyA"
+ ],
+ "3": [
+ "orpHABU0S8eJ0Nd82U_SQA"
+ ],
+ "4": [
+ "6I6OQ1QfTgCvHigkIdmuPA"
+ ]
+ }
+ }
+ },
+ "index-graveyard": {
+ "tombstones": []
+ }
+ },
+ "routing_table": {
+ "indices": {
+ "index2": {
+ "shards": {
+ "0": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index2",
+ "allocation_id": {
+ "id": "gbBnb3KFQOyXHl3eaVV6nA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "1": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index2",
+ "allocation_id": {
+ "id": "sNsOyQBnSdKQuFETNtRYng"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "2": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index2",
+ "allocation_id": {
+ "id": "4UZfdxQeT7CMUxI9Fl5tYA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "3": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index2",
+ "allocation_id": {
+ "id": "70TzfLRxQ_KL-tT81-QO4w"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "4": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "allocation_id": {
+ "id": "GhBM4mIdTAG-IVjGYFazkQ"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "5": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "allocation_id": {
+ "id": "GhBM4mIdTAG-IVjGYFazkQ"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ]
+ }
+ },
+ "index1": {
+ "shards": {
+ "0": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index1",
+ "allocation_id": {
+ "id": "WFVdvk1eQrmOfemq6UoBIw"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "1": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index1",
+ "allocation_id": {
+ "id": "_ASJYn1bRO2MnCN0HKH5BA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "2": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index1",
+ "allocation_id": {
+ "id": "o5kBd295ReKi2g4g1bpjyA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "3": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index1",
+ "allocation_id": {
+ "id": "orpHABU0S8eJ0Nd82U_SQA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "4": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index1",
+ "allocation_id": {
+ "id": "6I6OQ1QfTgCvHigkIdmuPA"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ]
+ }
+ }
+ }
+ },
+ "routing_nodes": {
+ "unassigned": [
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index2",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:10.325Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ },
+ {
+ "state": "UNASSIGNED",
+ "primary": false,
+ "node": null,
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index1",
+ "recovery_source": {
+ "type": "PEER"
+ },
+ "unassigned_info": {
+ "reason": "INDEX_CREATED",
+ "at": "2018-10-15T08:28:05.063Z",
+ "delayed": false,
+ "allocation_status": "no_attempt"
+ }
+ }
+ ],
+ "nodes": {
+ "ejy2E2sMTg6nqnjhF9KfsQ": [
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index2",
+ "allocation_id": {
+ "id": "4UZfdxQeT7CMUxI9Fl5tYA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index2",
+ "allocation_id": {
+ "id": "sNsOyQBnSdKQuFETNtRYng"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index2",
+ "allocation_id": {
+ "id": "GhBM4mIdTAG-IVjGYFazkQ"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index2",
+ "allocation_id": {
+ "id": "70TzfLRxQ_KL-tT81-QO4w"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index2",
+ "allocation_id": {
+ "id": "gbBnb3KFQOyXHl3eaVV6nA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 2,
+ "index": "index1",
+ "allocation_id": {
+ "id": "o5kBd295ReKi2g4g1bpjyA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 1,
+ "index": "index1",
+ "allocation_id": {
+ "id": "_ASJYn1bRO2MnCN0HKH5BA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 4,
+ "index": "index1",
+ "allocation_id": {
+ "id": "6I6OQ1QfTgCvHigkIdmuPA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 3,
+ "index": "index1",
+ "allocation_id": {
+ "id": "orpHABU0S8eJ0Nd82U_SQA"
+ }
+ },
+ {
+ "state": "STARTED",
+ "primary": true,
+ "node": "ejy2E2sMTg6nqnjhF9KfsQ",
+ "relocating_node": null,
+ "shard": 0,
+ "index": "index1",
+ "allocation_id": {
+ "id": "WFVdvk1eQrmOfemq6UoBIw"
+ }
+ }
+ ]
+ }
+ }
+ }
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
