Package org.apache.solr.cloud.api.collections

Class AbstractInstallShardTest

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.apache.solr.SolrTestCase

org.apache.solr.SolrTestCaseJ4

org.apache.solr.cloud.SolrCloudTestCase

org.apache.solr.cloud.api.collections.AbstractInstallShardTest

public abstract class AbstractInstallShardTest
extends SolrCloudTestCase

Base class for testing the "Install Shard API" with various backup repositories.

Subclasses are expected to bootstrap a Solr cluster with a single configured backup repository. This base-class will populate that backup repository all data necessary for these tests.

See Also:

• InstallShardData

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.cloud.SolrCloudTestCase

SolrCloudTestCase.NoPrs

Nested classes/interfaces inherited from class org.apache.solr.SolrTestCaseJ4

SolrTestCaseJ4.BVal, SolrTestCaseJ4.Doc, SolrTestCaseJ4.Fld, SolrTestCaseJ4.FldType, SolrTestCaseJ4.FVal, SolrTestCaseJ4.IRange, SolrTestCaseJ4.IVals, SolrTestCaseJ4.IValsPercent, SolrTestCaseJ4.RandomizingCloudSolrClientBuilder, SolrTestCaseJ4.SuppressPointFields, SolrTestCaseJ4.SuppressSSL, SolrTestCaseJ4.SVal, SolrTestCaseJ4.Vals, SolrTestCaseJ4.XmlDoc

Nested classes/interfaces inherited from class org.apache.lucene.tests.util.LuceneTestCase

org.apache.lucene.tests.util.LuceneTestCase.AwaitsFix, org.apache.lucene.tests.util.LuceneTestCase.Concurrency, org.apache.lucene.tests.util.LuceneTestCase.Monster, org.apache.lucene.tests.util.LuceneTestCase.Nightly, org.apache.lucene.tests.util.LuceneTestCase.SuppressAssertingFormats, org.apache.lucene.tests.util.LuceneTestCase.SuppressCodecs, org.apache.lucene.tests.util.LuceneTestCase.SuppressFileSystems, org.apache.lucene.tests.util.LuceneTestCase.SuppressFsync, org.apache.lucene.tests.util.LuceneTestCase.SuppressReproduceLine, org.apache.lucene.tests.util.LuceneTestCase.SuppressSysoutChecks, org.apache.lucene.tests.util.LuceneTestCase.SuppressTempFileChecks, org.apache.lucene.tests.util.LuceneTestCase.ThrowingConsumer<T>, org.apache.lucene.tests.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.tests.util.LuceneTestCase.Weekly

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	BACKUP_REPO_NAME
protected List<String>	collectionsToDelete
protected static final String	ERROR_BACKUP_REPO_NAME
protected static int	multiShardNumDocs
protected static URI[]	multiShardUris
protected static URI	nonExistentLocationUri
protected static int	replicasPerShard
protected static URI	singleShard1Uri
protected static int	singleShardNumDocs

Fields inherited from class org.apache.solr.cloud.SolrCloudTestCase

cluster, DEFAULT_TIMEOUT

Fields inherited from class org.apache.solr.SolrTestCaseJ4

configString, CORE_PROPERTIES_FILENAME, coreName, DEAD_HOST_1, DEAD_HOST_2, DEAD_HOST_3, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_TEST_COLLECTION_NAME, DEFAULT_TEST_CORENAME, h, lrf, NUMERIC_DOCVALUES_SYSPROP, NUMERIC_POINTS_SYSPROP, ONE_ONE, RANDOMIZED_NUMERIC_FIELDTYPES, schemaString, solrConfig, sslConfig, SYSTEM_PROPERTY_SOLR_TESTS_MERGEPOLICYFACTORY, TEST_URL_ALLOW_LIST, testExecutor, testSolrHome, UPDATELOG_SYSPROP, USE_NUMERIC_POINTS_SYSPROP, ZERO_ONE, ZERO_TWO

Fields inherited from class org.apache.solr.SolrTestCase

solrClassRules, solrTestRules

Fields inherited from class org.apache.lucene.tests.util.LuceneTestCase

assertsAreEnabled, classRules, DEFAULT_LINE_DOCS_FILE, INFOSTREAM, JENKINS_LARGE_LINE_DOCS_FILE, LEAVE_TEMPORARY, MAYBE_CACHE_POLICY, RANDOM_MULTIPLIER, ruleChain, suiteFailureMarker, SYSPROP_AWAITSFIX, SYSPROP_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, SYSPROP_WEEKLY, TEST_ASSERTS_ENABLED, TEST_AWAITSFIX, TEST_CODEC, TEST_DIRECTORY, TEST_DOCVALUESFORMAT, TEST_LINE_DOCS_FILE, TEST_MONSTER, TEST_NIGHTLY, TEST_POSTINGSFORMAT, TEST_THROTTLING, TEST_WEEKLY, VERBOSE

Constructor Summary

Constructors

Constructor	Description
AbstractInstallShardTest()

Method Summary

Modifier and Type	Method	Description
protected static void	assertCollectionHasNumDocs(String collection, int expectedNumDocs)
static void	bootstrapBackupRepositoryData(String baseRepositoryLocation)
void	clearCollectionsToDelete()
protected static String	createAndAwaitEmptyCollection(int numShards, int replicasPerShard)
static String	defaultSolrXmlTextWithBackupRepository(String backupRepositoryText)	Builds a string representation of a valid solr.xml configuration, with the provided backup-repository configuration inserted
protected String	deleteAfterTest(String collName)
void	deleteTestCollections()
protected static void	enableReadOnly(String collectionName)
static void	seedDocGenerator()
void	testInstallFailsIfCollectionIsNotInReadOnlyMode()
void	testInstallReportsErrorsAppropriately()
void	testInstallSucceedsOnASingleError()
void	testInstallToSingleShardCollection()
void	testParallelInstallToMultiShardCollection()
void	testSerialInstallToMultiShardCollection()

Methods inherited from class org.apache.solr.cloud.SolrCloudTestCase

activeClusterShape, checkClusterConfiguration, clusterShape, configureCluster, configurePrsDefault, containsLiveNode, ensureRunningJettys, getCollectionState, getCoreStatus, getHttpSolrConnection, getRandomReplica, getRandomReplica, getRandomShard, getReplicas, getSolrConnection, getZookeeperSolrConnection, isPRS, mapReplicasToReplicaType, missingLiveNode, missingLiveNodes, replicasForCollectionAreFullyActive, shutdownCluster, waitForAsyncClusterRequest, waitForResponse, waitForState, waitForState, waitForState, waitForState, zkClient

Methods inherited from class org.apache.solr.SolrTestCaseJ4

add, addAndGetVersion, addDoc, adoc, adoc, assertExceptionThrownWithMessageContaining, assertFailedU, assertFailedU, assertFieldValues, assertJJQ, assertJQ, assertJQ, assertNonBlockingRandomGeneratorAvailable, assertQ, assertQ, assertQEx, assertQEx, assertQEx, assertResponseValues, assertSolrInputFieldEquals, assertThatJQ, assertThatJQ, assertU, assertU, assertXmlFile, assumeWorkingMockito, buildUrl, clearIndex, commit, compareSolrDocument, compareSolrDocumentList, compareSolrInputDocument, configset, copyMinConf, copyMinConf, copyMinConf, copySolrHomeToTemp, createComparator, createComparator, createCore, createCoreContainer, createCoreContainer, createCoreContainer, createDefaultCoreContainer, createDistributedUpdateProcessor, createDoc, createSort, deleteAndGetVersion, deleteByQueryAndGetVersion, deleteCore, delI, delQ, doc, getClassName, getFile, getRootCause, getSaferTestName, getSchemaFile, getSolrConfigFile, getWrappedException, hasInitException, hasInitException, indexDocs, initAndGetDataDir, initCore, initCore, initCore, initCore, invertField, isSSLMode, JQ, json, json, json, jsonAdd, jsonDelId, jsonDelQ, map, map, newRandomConfig, optimize, params, pickRandom, postSetUp, preTearDown, randomDate, randomSkewedDate, randomXmlUsableUnicodeString, req, req, req, reqWithPath, reqWithPath, resetFactory, sdoc, sdocs, sdocWithChildren, sdocWithChildren, sdocWithChildren, setUp, setupNoCoreTest, setupTestCases, skewed, startTrackingSearchers, systemSetPropertySolrTestsMergePolicyFactory, tearDown, teardownTestCases, TEST_COLL1_CONF, TEST_HOME, TEST_PATH, toJSON, updateJ, useFactory, waitForAsyncClusterRequest, waitForWarming, waitForWarming, whitespaceMockTokenizer, withPath, writeCoreProperties, writeCoreProperties

Methods inherited from class org.apache.solr.SolrTestCase

afterClassSolrTestCase, assertJSONEquals, assertThat, assertThat, beforeSolrTestCase, checkSyspropForceBeforeAssumptionFailure, checkSyspropForceBeforeClassAssumptionFailure

Methods inherited from class org.apache.lucene.tests.util.LuceneTestCase

addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertDoubleUlpEquals, assertFieldInfosEquals, assertFloatUlpEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, asSet, assumeFalse, assumeNoException, assumeTrue, atLeast, atLeast, callStackContains, callStackContains, callStackContainsAnyOf, closeAfterSuite, closeAfterTest, collate, createTempDir, createTempDir, createTempFile, createTempFile, dumpArray, dumpIterator, ensureSaneIWCOnNightly, expectThrows, expectThrows, expectThrows, expectThrowsAnyOf, expectThrowsAnyOf, getDataInputStream, getDataPath, getJvmForkArguments, getOnlyLeafReader, getTestClass, getTestName, isTestThread, localeForLanguageTag, maybeChangeLiveIndexWriterConfig, maybeWrapReader, newAlcoholicMergePolicy, newAlcoholicMergePolicy, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newDirectory, newDirectory, newDirectory, newDirectory, newDirectory, newField, newField, newFSDirectory, newFSDirectory, newIndexWriterConfig, newIndexWriterConfig, newIndexWriterConfig, newIOContext, newIOContext, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newMaybeVirusCheckingDirectory, newMaybeVirusCheckingFSDirectory, newMergePolicy, newMergePolicy, newMergePolicy, newMockDirectory, newMockDirectory, newMockDirectory, newMockFSDirectory, newMockFSDirectory, newSearcher, newSearcher, newSearcher, newSearcher, newSearcher, newSnapshotIndexWriterConfig, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, randomVectorFormat, rarely, rarely, replaceMaxFailureRule, resetDefaultQueryCache, restoreCPUCoreCount, restoreIndexWriterMaxDocs, runWithRestrictedPermissions, setIndexWriterMaxDocs, setupCPUCoreCount, setUpExecutorService, shutdownExecutorService, slowFileExists, usually, usually, wrapReader

Methods inherited from class org.junit.Assert

assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertThrows, assertThrows, assertTrue, assertTrue, fail, fail

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

BACKUP_REPO_NAME

protected static final String BACKUP_REPO_NAME

See Also:

• Constant Field Values

ERROR_BACKUP_REPO_NAME

protected static final String ERROR_BACKUP_REPO_NAME

See Also:

• Constant Field Values

singleShardNumDocs

protected static int singleShardNumDocs

replicasPerShard

protected static int replicasPerShard

multiShardNumDocs

protected static int multiShardNumDocs

singleShard1Uri

protected static URI singleShard1Uri

nonExistentLocationUri

protected static URI nonExistentLocationUri

multiShardUris

protected static URI[] multiShardUris

collectionsToDelete

protected List<String> collectionsToDelete

Constructor Details

AbstractInstallShardTest

public AbstractInstallShardTest()

Method Details

seedDocGenerator

public static void seedDocGenerator()

clearCollectionsToDelete

public void clearCollectionsToDelete()

deleteTestCollections

public void deleteTestCollections()
                           throws Exception

Throws:

Exception

deleteAfterTest

protected String deleteAfterTest(String collName)

bootstrapBackupRepositoryData

public static void bootstrapBackupRepositoryData(String baseRepositoryLocation)
                                          throws Exception

Throws:

Exception

testInstallFailsIfCollectionIsNotInReadOnlyMode

public void testInstallFailsIfCollectionIsNotInReadOnlyMode()
                                                     throws Exception

Throws:

Exception

testInstallToSingleShardCollection

public void testInstallToSingleShardCollection()
                                        throws Exception

Throws:

Exception

testInstallReportsErrorsAppropriately

public void testInstallReportsErrorsAppropriately()
                                           throws Exception

Throws:

Exception

testSerialInstallToMultiShardCollection

public void testSerialInstallToMultiShardCollection()
                                             throws Exception

Throws:

Exception

testParallelInstallToMultiShardCollection

public void testParallelInstallToMultiShardCollection()
                                               throws Exception

Throws:

Exception

testInstallSucceedsOnASingleError

public void testInstallSucceedsOnASingleError()
                                       throws Exception

Throws:

Exception

defaultSolrXmlTextWithBackupRepository

public static String defaultSolrXmlTextWithBackupRepository(String backupRepositoryText)

Builds a string representation of a valid solr.xml configuration, with the provided backup-repository configuration inserted

Parameters:

backupRepositoryText - a string representing the 'backup' XML tag to put in the constructed solr.xml

assertCollectionHasNumDocs

protected static void assertCollectionHasNumDocs(String collection,
 int expectedNumDocs)
                                          throws Exception

Throws:

Exception

createAndAwaitEmptyCollection

protected static String createAndAwaitEmptyCollection(int numShards,
 int replicasPerShard)
                                               throws Exception

Throws:

Exception

enableReadOnly

protected static void enableReadOnly(String collectionName)
                              throws Exception

Throws:

Exception