Package org.apache.solr.cloud

Class AbstractDistribZkTestBase

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.apache.solr.SolrTestCase

org.apache.solr.SolrTestCaseJ4

org.apache.solr.BaseDistributedSearchTestCase

org.apache.solr.cloud.AbstractDistribZkTestBase

Direct Known Subclasses:

AbstractFullDistribZkTestBase

public abstract class AbstractDistribZkTestBase
extends BaseDistributedSearchTestCase

Nested Class Summary

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

BaseDistributedSearchTestCase.RandDate, BaseDistributedSearchTestCase.RandVal, BaseDistributedSearchTestCase.ShardsFixed, BaseDistributedSearchTestCase.ShardsRepeat, BaseDistributedSearchTestCase.ShardsRepeatRule

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.RandomizingCloudHttp2SolrClientBuilder, 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.BadApple, org.apache.lucene.tests.util.LuceneTestCase.Monster, org.apache.lucene.tests.util.LuceneTestCase.Nightly, 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 extends Object>, org.apache.lucene.tests.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.tests.util.LuceneTestCase.Weekly

Field Summary

Fields

Modifier and Type	Field	Description
protected static String	DEFAULT_COLLECTION
protected ZkTestServer	zkServer

Fields inherited from class org.apache.solr.BaseDistributedSearchTestCase

clients, context, controlClient, controlJetty, deadServers, executor, fieldNames, flags, FUZZY, handle, id, jettys, nThreads, ORDERED, r, randVals, rdate, rdouble, repeatRule, rfloat, rint, rlong, shards, shardsArr, SKIP, SKIPVAL, stress, testDir, UNORDERED, useExplicitNodeNames, verifyStress

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, hdfsDataDir, initCoreDataDir, lrf, NUMERIC_DOCVALUES_SYSPROP, NUMERIC_POINTS_SYSPROP, ONE_ONE, RANDOMIZED_NUMERIC_FIELDTYPES, schemaString, solrConfig, solrTestRules, 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

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_BADAPPLES, SYSPROP_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, SYSPROP_WEEKLY, TEST_ASSERTS_ENABLED, TEST_AWAITSFIX, TEST_BADAPPLES, 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
AbstractDistribZkTestBase()

Method Summary

Modifier and Type	Method	Description
protected static void	assertAllActive(String collection, org.apache.solr.common.cloud.ZkStateReader zkStateReader)
static void	beforeThisClass()
protected static void	copyConfigUp(Path configSetDir, String srcConfigSet, String dstConfigName, String zkAddr)
protected void	createServers(int numShards)
void	distribSetUp()
void	distribTearDown()
protected String	getCloudSchemaFile()
protected String	getCloudSolrConfig()
protected void	printLayout()
protected void	restartZk(int pauseMillis)
static void	verifyReplicaStatus(org.apache.solr.common.cloud.ZkStateReader reader, String collection, String shard, String coreNodeName, org.apache.solr.common.cloud.Replica.State expectedState)
static void	waitForCollectionToDisappear(String collection, org.apache.solr.common.cloud.ZkStateReader zkStateReader, boolean failOnTimeout, int timeoutSeconds)
protected void	waitForRecoveriesToFinish(String collection, org.apache.solr.common.cloud.ZkStateReader zkStateReader, boolean verbose)
protected void	waitForRecoveriesToFinish(String collection, org.apache.solr.common.cloud.ZkStateReader zkStateReader, boolean verbose, boolean failOnTimeout)
static void	waitForRecoveriesToFinish(String collection, org.apache.solr.common.cloud.ZkStateReader zkStateReader, boolean verbose, boolean failOnTimeout, long timeoutSeconds)
static void	waitForRecoveriesToFinish(String collection, org.apache.solr.common.cloud.ZkStateReader zkStateReader, boolean verbose, boolean failOnTimeout, long timeout, TimeUnit unit)

Methods inherited from class org.apache.solr.BaseDistributedSearchTestCase

add, add, addFields, addRandFields, buildUrl, clearHostContext, clearSolrDisableShardsWhitelist, commit, compare, compare, compare, compare, compare, compare, compare1, compareResponses, compareSolrResponses, createControlJetty, createJetty, createJetty, createJetty, createJetty, createNewSolrClient, createParams, del, del, delQ, destroyServers, fixShardCount, flags, getExtraRequestFilters, getExtraServlets, getFieldNames, getRandFields, getRandValues, getShardCount, getShardsString, getSolrHome, getSolrXml, index, index_specific, indexDoc, indexDoc, indexDocs, indexDocs, indexr, initHostContext, initialize, query, query, query, query, queryAndCompare, queryAndCompare, queryServer, seedSolrHome, setDistributedParams, setSolrDisableShardsWhitelist, setupJettySolrHome, validateControlData

Methods inherited from class org.apache.solr.SolrTestCaseJ4

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

Methods inherited from class org.apache.solr.SolrTestCase

assertJSONEquals, beforeSolrTestCase, checkSyspropForceBeforeAssumptionFailure, checkSyspropForceBeforeClassAssumptionFailure

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

addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertFieldInfosEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, asSet, assumeFalse, assumeNoException, assumeTrue, assumeWorkingMMapOnWindows, 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, hasWorkingMMapOnWindows, 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, newSnapshotIndexWriterConfig, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, 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, assertThat, assertThat, 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 Detail

DEFAULT_COLLECTION

protected static final String DEFAULT_COLLECTION

See Also:

Constant Field Values

zkServer

protected volatile ZkTestServer zkServer

Constructor Detail

AbstractDistribZkTestBase

public AbstractDistribZkTestBase()

Method Detail

beforeThisClass

public static void beforeThisClass()
                            throws Exception

Throws:

Exception

distribSetUp

public void distribSetUp()
                  throws Exception

Overrides:

distribSetUp in class BaseDistributedSearchTestCase

Throws:

Exception

getCloudSolrConfig

protected String getCloudSolrConfig()

getCloudSchemaFile

protected String getCloudSchemaFile()

createServers

protected void createServers(int numShards)
                      throws Exception

Overrides:

createServers in class BaseDistributedSearchTestCase

Throws:

Exception

waitForRecoveriesToFinish

protected void waitForRecoveriesToFinish(String collection,
                                         org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                         boolean verbose)
                                  throws Exception

Throws:

Exception

waitForRecoveriesToFinish

protected void waitForRecoveriesToFinish(String collection,
                                         org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                         boolean verbose,
                                         boolean failOnTimeout)
                                  throws Exception

Throws:

Exception

waitForRecoveriesToFinish

public static void waitForRecoveriesToFinish(String collection,
                                             org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                             boolean verbose,
                                             boolean failOnTimeout,
                                             long timeoutSeconds)
                                      throws Exception

Throws:

Exception

waitForRecoveriesToFinish

public static void waitForRecoveriesToFinish(String collection,
                                             org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                             boolean verbose,
                                             boolean failOnTimeout,
                                             long timeout,
                                             TimeUnit unit)
                                      throws Exception

Throws:

Exception

waitForCollectionToDisappear

public static void waitForCollectionToDisappear(String collection,
                                                org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                                boolean failOnTimeout,
                                                int timeoutSeconds)
                                         throws Exception

Throws:

Exception

verifyReplicaStatus

public static void verifyReplicaStatus(org.apache.solr.common.cloud.ZkStateReader reader,
                                       String collection,
                                       String shard,
                                       String coreNodeName,
                                       org.apache.solr.common.cloud.Replica.State expectedState)
                                throws InterruptedException,
                                       TimeoutException

Throws:

InterruptedException

TimeoutException

assertAllActive

protected static void assertAllActive(String collection,
                                      org.apache.solr.common.cloud.ZkStateReader zkStateReader)
                               throws org.apache.zookeeper.KeeperException,
                                      InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

distribTearDown

public void distribTearDown()
                     throws Exception

Overrides:

distribTearDown in class BaseDistributedSearchTestCase

Throws:

Exception

printLayout

protected void printLayout()
                    throws Exception

Throws:

Exception

restartZk

protected void restartZk(int pauseMillis)
                  throws Exception

Throws:

Exception

copyConfigUp

protected static void copyConfigUp(Path configSetDir,
                                   String srcConfigSet,
                                   String dstConfigName,
                                   String zkAddr)
                            throws Exception

Throws:

Exception