| package org.apache.solr.cloud; |
| |
| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| |
| import com.google.common.collect.Lists; |
| import org.apache.solr.client.solrj.SolrRequest; |
| import org.apache.solr.client.solrj.SolrServerException; |
| import org.apache.solr.client.solrj.impl.CloudSolrClient; |
| import org.apache.solr.client.solrj.request.CollectionAdminRequest; |
| import org.apache.solr.client.solrj.request.QueryRequest; |
| import org.apache.solr.common.SolrException; |
| import org.apache.solr.common.SolrInputDocument; |
| import org.apache.solr.common.cloud.ClusterState; |
| import org.apache.solr.common.cloud.Replica; |
| import org.apache.solr.common.cloud.Slice; |
| import org.apache.solr.common.params.CollectionParams; |
| import org.apache.solr.common.params.ModifiableSolrParams; |
| import org.apache.solr.common.params.ShardParams; |
| import org.apache.solr.common.util.NamedList; |
| import org.apache.zookeeper.KeeperException; |
| import org.junit.Test; |
| |
| import java.io.IOException; |
| import java.util.ArrayList; |
| import java.util.HashMap; |
| import java.util.List; |
| import java.util.Locale; |
| import java.util.Map; |
| |
| import static org.apache.solr.cloud.OverseerCollectionProcessor.SHARD_UNIQUE; |
| |
| public class TestCollectionAPI extends ReplicaPropertiesBase { |
| |
| public static final String COLLECTION_NAME = "testcollection"; |
| public static final String COLLECTION_NAME1 = "testcollection1"; |
| |
| public TestCollectionAPI() { |
| schemaString = "schema15.xml"; // we need a string id |
| } |
| |
| @Override |
| public void distribSetUp() throws Exception { |
| sliceCount = 2; |
| super.distribSetUp(); |
| } |
| |
| @Test |
| @ShardsFixed(num = 2) |
| public void test() throws Exception { |
| try (CloudSolrClient client = createCloudClient(null)) { |
| createCollection(null, COLLECTION_NAME, 2, 2, 2, client, null, "conf1"); |
| createCollection(null, COLLECTION_NAME1, 1, 1, 1, client, null, "conf1"); |
| } |
| |
| waitForCollection(cloudClient.getZkStateReader(), COLLECTION_NAME, 2); |
| waitForCollection(cloudClient.getZkStateReader(), COLLECTION_NAME1, 1); |
| waitForRecoveriesToFinish(COLLECTION_NAME, false); |
| waitForRecoveriesToFinish(COLLECTION_NAME1, false); |
| |
| listCollection(); |
| clusterStatusNoCollection(); |
| clusterStatusWithCollection(); |
| clusterStatusWithCollectionAndShard(); |
| clusterStatusWithRouteKey(); |
| clusterStatusAliasTest(); |
| clusterStatusRolesTest(); |
| replicaPropTest(); |
| clusterStatusZNodeVersion(); |
| } |
| |
| private void clusterStatusWithCollectionAndShard() throws IOException, SolrServerException { |
| |
| try (CloudSolrClient client = createCloudClient(null)) { |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.CLUSTERSTATUS.toString()); |
| params.set("collection", COLLECTION_NAME); |
| params.set("shard", SHARD1); |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| |
| NamedList<Object> rsp = client.request(request); |
| NamedList<Object> cluster = (NamedList<Object>) rsp.get("cluster"); |
| assertNotNull("Cluster state should not be null", cluster); |
| NamedList<Object> collections = (NamedList<Object>) cluster.get("collections"); |
| assertNotNull("Collections should not be null in cluster state", collections); |
| assertNotNull(collections.get(COLLECTION_NAME)); |
| assertEquals(1, collections.size()); |
| Map<String, Object> collection = (Map<String, Object>) collections.get(COLLECTION_NAME); |
| Map<String, Object> shardStatus = (Map<String, Object>) collection.get("shards"); |
| assertEquals(1, shardStatus.size()); |
| Map<String, Object> selectedShardStatus = (Map<String, Object>) shardStatus.get(SHARD1); |
| assertNotNull(selectedShardStatus); |
| |
| } |
| } |
| |
| |
| private void listCollection() throws IOException, SolrServerException { |
| try (CloudSolrClient client = createCloudClient(null)) { |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.LIST.toString()); |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| |
| NamedList<Object> rsp = client.request(request); |
| List<String> collections = (List<String>) rsp.get("collections"); |
| assertTrue("control_collection was not found in list", collections.contains("control_collection")); |
| assertTrue(DEFAULT_COLLECTION + " was not found in list", collections.contains(DEFAULT_COLLECTION)); |
| assertTrue(COLLECTION_NAME + " was not found in list", collections.contains(COLLECTION_NAME)); |
| assertTrue(COLLECTION_NAME1 + " was not found in list", collections.contains(COLLECTION_NAME1)); |
| } |
| |
| } |
| |
| private void clusterStatusNoCollection() throws Exception { |
| |
| try (CloudSolrClient client = createCloudClient(null)) { |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.CLUSTERSTATUS.toString()); |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| |
| NamedList<Object> rsp = client.request(request); |
| NamedList<Object> cluster = (NamedList<Object>) rsp.get("cluster"); |
| assertNotNull("Cluster state should not be null", cluster); |
| NamedList<Object> collections = (NamedList<Object>) cluster.get("collections"); |
| assertNotNull("Collections should not be null in cluster state", collections); |
| assertNotNull(collections.get(COLLECTION_NAME1)); |
| assertEquals(4, collections.size()); |
| |
| List<String> liveNodes = (List<String>) cluster.get("live_nodes"); |
| assertNotNull("Live nodes should not be null", liveNodes); |
| assertFalse(liveNodes.isEmpty()); |
| } |
| |
| } |
| |
| private void clusterStatusWithCollection() throws IOException, SolrServerException { |
| try (CloudSolrClient client = createCloudClient(null)) { |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.CLUSTERSTATUS.toString()); |
| params.set("collection", COLLECTION_NAME); |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| |
| NamedList<Object> rsp = client.request(request); |
| NamedList<Object> cluster = (NamedList<Object>) rsp.get("cluster"); |
| assertNotNull("Cluster state should not be null", cluster); |
| NamedList<Object> collections = (NamedList<Object>) cluster.get("collections"); |
| assertNotNull("Collections should not be null in cluster state", collections); |
| assertEquals(1, collections.size()); |
| Map<String, Object> collection = (Map<String, Object>) collections.get(COLLECTION_NAME); |
| assertNotNull(collection); |
| assertEquals("conf1", collection.get("configName")); |
| } |
| } |
| |
| private void clusterStatusZNodeVersion() throws Exception { |
| String cname = "clusterStatusZNodeVersion"; |
| try (CloudSolrClient client = createCloudClient(null)) { |
| |
| CollectionAdminRequest.Create create = new CollectionAdminRequest.Create() |
| .setCollectionName(cname) |
| .setMaxShardsPerNode(1) |
| .setNumShards(1) |
| .setReplicationFactor(1) |
| .setConfigName("conf1"); |
| create.process(client); |
| |
| waitForRecoveriesToFinish(cname, true); |
| |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.CLUSTERSTATUS.toString()); |
| params.set("collection", cname); |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| |
| NamedList<Object> rsp = client.request(request); |
| NamedList<Object> cluster = (NamedList<Object>) rsp.get("cluster"); |
| assertNotNull("Cluster state should not be null", cluster); |
| NamedList<Object> collections = (NamedList<Object>) cluster.get("collections"); |
| assertNotNull("Collections should not be null in cluster state", collections); |
| assertEquals(1, collections.size()); |
| Map<String, Object> collection = (Map<String, Object>) collections.get(cname); |
| assertNotNull(collection); |
| assertEquals("conf1", collection.get("configName")); |
| Integer znodeVersion = (Integer) collection.get("znodeVersion"); |
| assertNotNull(znodeVersion); |
| |
| CollectionAdminRequest.AddReplica addReplica = new CollectionAdminRequest.AddReplica() |
| .setCollectionName(cname) |
| .setShardName("shard1"); |
| addReplica.process(client); |
| |
| waitForRecoveriesToFinish(cname, true); |
| |
| rsp = client.request(request); |
| cluster = (NamedList<Object>) rsp.get("cluster"); |
| collections = (NamedList<Object>) cluster.get("collections"); |
| collection = (Map<String, Object>) collections.get(cname); |
| Integer newVersion = (Integer) collection.get("znodeVersion"); |
| assertNotNull(newVersion); |
| assertTrue(newVersion > znodeVersion); |
| } |
| } |
| |
| private void clusterStatusWithRouteKey() throws IOException, SolrServerException { |
| try (CloudSolrClient client = createCloudClient(DEFAULT_COLLECTION)) { |
| SolrInputDocument doc = new SolrInputDocument(); |
| doc.addField("id", "a!123"); // goes to shard2. see ShardRoutingTest for details |
| client.add(doc); |
| client.commit(); |
| |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.CLUSTERSTATUS.toString()); |
| params.set("collection", DEFAULT_COLLECTION); |
| params.set(ShardParams._ROUTE_, "a!"); |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| |
| NamedList<Object> rsp = client.request(request); |
| NamedList<Object> cluster = (NamedList<Object>) rsp.get("cluster"); |
| assertNotNull("Cluster state should not be null", cluster); |
| NamedList<Object> collections = (NamedList<Object>) cluster.get("collections"); |
| assertNotNull("Collections should not be null in cluster state", collections); |
| assertNotNull(collections.get(DEFAULT_COLLECTION)); |
| assertEquals(1, collections.size()); |
| Map<String, Object> collection = (Map<String, Object>) collections.get(DEFAULT_COLLECTION); |
| assertEquals("conf1", collection.get("configName")); |
| Map<String, Object> shardStatus = (Map<String, Object>) collection.get("shards"); |
| assertEquals(1, shardStatus.size()); |
| Map<String, Object> selectedShardStatus = (Map<String, Object>) shardStatus.get(SHARD2); |
| assertNotNull(selectedShardStatus); |
| } |
| } |
| |
| private void clusterStatusAliasTest() throws Exception { |
| try (CloudSolrClient client = createCloudClient(null)) { |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.CREATEALIAS.toString()); |
| params.set("name", "myalias"); |
| params.set("collections", DEFAULT_COLLECTION + "," + COLLECTION_NAME); |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| client.request(request); |
| params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.CLUSTERSTATUS.toString()); |
| params.set("collection", DEFAULT_COLLECTION); |
| request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| |
| NamedList<Object> rsp = client.request(request); |
| |
| |
| NamedList<Object> cluster = (NamedList<Object>) rsp.get("cluster"); |
| assertNotNull("Cluster state should not be null", cluster); |
| Map<String, String> aliases = (Map<String, String>) cluster.get("aliases"); |
| assertNotNull("Aliases should not be null", aliases); |
| assertEquals("Alias: myalias not found in cluster status", |
| DEFAULT_COLLECTION + "," + COLLECTION_NAME, aliases.get("myalias")); |
| |
| NamedList<Object> collections = (NamedList<Object>) cluster.get("collections"); |
| assertNotNull("Collections should not be null in cluster state", collections); |
| assertNotNull(collections.get(DEFAULT_COLLECTION)); |
| Map<String, Object> collection = (Map<String, Object>) collections.get(DEFAULT_COLLECTION); |
| assertEquals("conf1", collection.get("configName")); |
| List<String> collAlias = (List<String>) collection.get("aliases"); |
| assertEquals("Aliases not found", Lists.newArrayList("myalias"), collAlias); |
| } |
| } |
| |
| private void clusterStatusRolesTest() throws Exception { |
| try (CloudSolrClient client = createCloudClient(null)) { |
| client.connect(); |
| Replica replica = client.getZkStateReader().getLeaderRetry(DEFAULT_COLLECTION, SHARD1); |
| |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.ADDROLE.toString()); |
| params.set("node", replica.getNodeName()); |
| params.set("role", "overseer"); |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| client.request(request); |
| |
| params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.CLUSTERSTATUS.toString()); |
| params.set("collection", DEFAULT_COLLECTION); |
| request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| |
| NamedList<Object> rsp = client.request(request); |
| NamedList<Object> cluster = (NamedList<Object>) rsp.get("cluster"); |
| assertNotNull("Cluster state should not be null", cluster); |
| Map<String, Object> roles = (Map<String, Object>) cluster.get("roles"); |
| assertNotNull("Role information should not be null", roles); |
| List<String> overseer = (List<String>) roles.get("overseer"); |
| assertNotNull(overseer); |
| assertEquals(1, overseer.size()); |
| assertTrue(overseer.contains(replica.getNodeName())); |
| } |
| } |
| |
| private void replicaPropTest() throws Exception { |
| try (CloudSolrClient client = createCloudClient(null)) { |
| client.connect(); |
| Map<String, Slice> slices = client.getZkStateReader().getClusterState().getCollection(COLLECTION_NAME).getSlicesMap(); |
| List<String> sliceList = new ArrayList<>(slices.keySet()); |
| String c1_s1 = sliceList.get(0); |
| List<String> replicasList = new ArrayList<>(slices.get(c1_s1).getReplicasMap().keySet()); |
| String c1_s1_r1 = replicasList.get(0); |
| String c1_s1_r2 = replicasList.get(1); |
| |
| String c1_s2 = sliceList.get(1); |
| replicasList = new ArrayList<>(slices.get(c1_s2).getReplicasMap().keySet()); |
| String c1_s2_r1 = replicasList.get(0); |
| String c1_s2_r2 = replicasList.get(1); |
| |
| |
| slices = client.getZkStateReader().getClusterState().getCollection(COLLECTION_NAME1).getSlicesMap(); |
| sliceList = new ArrayList<>(slices.keySet()); |
| String c2_s1 = sliceList.get(0); |
| replicasList = new ArrayList<>(slices.get(c2_s1).getReplicasMap().keySet()); |
| String c2_s1_r1 = replicasList.get(0); |
| |
| ModifiableSolrParams params = new ModifiableSolrParams(); |
| params.set("action", CollectionParams.CollectionAction.ADDREPLICAPROP.toString()); |
| |
| // Insure we get error returns when omitting required parameters |
| |
| missingParamsError(client, params); |
| params.set("collection", COLLECTION_NAME); |
| missingParamsError(client, params); |
| params.set("shard", c1_s1); |
| missingParamsError(client, params); |
| params.set("replica", c1_s1_r1); |
| missingParamsError(client, params); |
| params.set("property", "preferredLeader"); |
| missingParamsError(client, params); |
| params.set("property.value", "true"); |
| |
| SolrRequest request = new QueryRequest(params); |
| request.setPath("/admin/collections"); |
| client.request(request); |
| |
| // The above should have set exactly one preferredleader... |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.preferredleader", "true"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toString(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r2, |
| "property", "preferredLeader", |
| "property.value", "true"); |
| // The preferred leader property for shard1 should have switched to the other replica. |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toString(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s2, |
| "replica", c1_s2_r1, |
| "property", "preferredLeader", |
| "property.value", "true"); |
| |
| // Now we should have a preferred leader in both shards... |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toString(), |
| "collection", COLLECTION_NAME1, |
| "shard", c2_s1, |
| "replica", c2_s1_r1, |
| "property", "preferredLeader", |
| "property.value", "true"); |
| |
| // Now we should have three preferred leaders. |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME1, c2_s1_r1, "property.preferredleader", "true"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME1, "property.preferredLeader"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.DELETEREPLICAPROP.toString(), |
| "collection", COLLECTION_NAME1, |
| "shard", c2_s1, |
| "replica", c2_s1_r1, |
| "property", "preferredLeader"); |
| |
| // Now we should have two preferred leaders. |
| // But first we have to wait for the overseer to finish the action |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME1, "property.preferredLeader"); |
| |
| // Try adding an arbitrary property to one that has the leader property |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toString(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "testprop", |
| "property.value", "true"); |
| |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.testprop", "true"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME1, "property.preferredLeader"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toString(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r2, |
| "property", "prop", |
| "property.value", "silly"); |
| |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.testprop", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.prop", "silly"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME1, "property.preferredLeader"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "testprop", |
| "property.value", "nonsense", |
| SHARD_UNIQUE, "true"); |
| |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.testprop", "nonsense"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.prop", "silly"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME1, "property.preferredLeader"); |
| |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "property.testprop", |
| "property.value", "true", |
| SHARD_UNIQUE, "false"); |
| |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.testprop", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.prop", "silly"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME1, "property.preferredLeader"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.DELETEREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "property.testprop"); |
| |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyPropertyNotPresent(client, COLLECTION_NAME, c1_s1_r1, "property.testprop"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.prop", "silly"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME1, "property.preferredLeader"); |
| |
| try { |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toString(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "preferredLeader", |
| "property.value", "true", |
| SHARD_UNIQUE, "false"); |
| fail("Should have thrown an exception, setting shardUnique=false is not allowed for 'preferredLeader'."); |
| } catch (SolrException se) { |
| assertTrue("Should have received a specific error message", |
| se.getMessage().contains("with the shardUnique parameter set to something other than 'true'")); |
| } |
| |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.preferredleader", "true"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s2_r1, "property.preferredleader", "true"); |
| verifyPropertyNotPresent(client, COLLECTION_NAME, c1_s1_r1, "property.testprop"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r2, "property.prop", "silly"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME, "property.preferredLeader"); |
| verifyUniquePropertyWithinCollection(client, COLLECTION_NAME1, "property.preferredLeader"); |
| |
| Map<String, String> origProps = getProps(client, COLLECTION_NAME, c1_s1_r1, |
| "state", "core", "node_name", "base_url"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "state", |
| "property.value", "state_bad"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "core", |
| "property.value", "core_bad"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "node_name", |
| "property.value", "node_name_bad"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.ADDREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "base_url", |
| "property.value", "base_url_bad"); |
| |
| // The above should be on new proeprties. |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.state", "state_bad"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.core", "core_bad"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.node_name", "node_name_bad"); |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, "property.base_url", "base_url_bad"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.DELETEREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "state"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.DELETEREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "core"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.DELETEREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "node_name"); |
| |
| doPropertyAction(client, |
| "action", CollectionParams.CollectionAction.DELETEREPLICAPROP.toLower(), |
| "collection", COLLECTION_NAME, |
| "shard", c1_s1, |
| "replica", c1_s1_r1, |
| "property", "base_url"); |
| |
| // They better not have been changed! |
| for (Map.Entry<String, String> ent : origProps.entrySet()) { |
| verifyPropertyVal(client, COLLECTION_NAME, c1_s1_r1, ent.getKey(), ent.getValue()); |
| } |
| |
| verifyPropertyNotPresent(client, COLLECTION_NAME, c1_s1_r1, "property.state"); |
| verifyPropertyNotPresent(client, COLLECTION_NAME, c1_s1_r1, "property.core"); |
| verifyPropertyNotPresent(client, COLLECTION_NAME, c1_s1_r1, "property.node_name"); |
| verifyPropertyNotPresent(client, COLLECTION_NAME, c1_s1_r1, "property.base_url"); |
| |
| } |
| } |
| |
| |
| // Expects the map will have keys, but blank values. |
| private Map<String, String> getProps(CloudSolrClient client, String collectionName, String replicaName, String... props) |
| throws KeeperException, InterruptedException { |
| |
| client.getZkStateReader().updateClusterState(true); |
| ClusterState clusterState = client.getZkStateReader().getClusterState(); |
| Replica replica = clusterState.getReplica(collectionName, replicaName); |
| if (replica == null) { |
| fail("Could not find collection/replica pair! " + collectionName + "/" + replicaName); |
| } |
| Map<String, String> propMap = new HashMap<>(); |
| for (String prop : props) { |
| propMap.put(prop, replica.getStr(prop)); |
| } |
| return propMap; |
| } |
| private void missingParamsError(CloudSolrClient client, ModifiableSolrParams origParams) |
| throws IOException, SolrServerException { |
| |
| SolrRequest request; |
| try { |
| request = new QueryRequest(origParams); |
| request.setPath("/admin/collections"); |
| client.request(request); |
| fail("Should have thrown a SolrException due to lack of a required parameter."); |
| } catch (SolrException se) { |
| assertTrue("Should have gotten a specific message back mentioning 'missing required parameter'. Got: " + se.getMessage(), |
| se.getMessage().toLowerCase(Locale.ROOT).contains("missing required parameter:")); |
| } |
| } |
| } |
