Package org.apache.solr.cloud

Class AbstractBasicDistributedZkTestBase

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

org.apache.solr.cloud.AbstractFullDistribZkTestBase

org.apache.solr.cloud.AbstractBasicDistributedZkTestBase

public abstract class AbstractBasicDistributedZkTestBase
extends AbstractFullDistribZkTestBase

This test simply does a bunch of basic things in solrcloud mode and asserts things work as expected.

Nested Class Summary

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

AbstractFullDistribZkTestBase.CloudJettyRunner, AbstractFullDistribZkTestBase.CloudSolrServerClient

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>, org.apache.lucene.tests.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.tests.util.LuceneTestCase.Weekly

Field Summary

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

chaosMonkey, cloudClient, cloudJettys, controlClientCloud, coreClients, printLayoutOnTearDown, SHARD1, SHARD2, shardToJetty, shardToLeaderJetty, sliceCount, solrClientByCollection, useJettyDataDir

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

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

methodRules, 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
AbstractBasicDistributedZkTestBase()

Method Summary

Modifier and Type	Method	Description
static void	beforeBDZKTClass()
protected org.apache.solr.client.solrj.response.CollectionAdminResponse	createCollection(Map<String,List<Integer>> collectionInfos, String collectionName, String configSetName, int numShards, int numReplicas, org.apache.solr.client.solrj.SolrClient client, String createNodeSetStr)
static void	createCollectionInOneInstance(org.apache.solr.client.solrj.SolrClient client, String nodeName, ThreadPoolExecutor executor, String collection, int numShards, int numReplicas)	Create a collection in single node
protected org.apache.solr.client.solrj.SolrClient	createNewSolrClient(String collection, String baseUrl)
protected org.apache.solr.client.solrj.SolrClient	createNewSolrClient(String collection, String baseUrl, int connectionTimeoutMillis, int socketTimeoutMillis)
void	distribTearDown()
protected org.apache.solr.common.cloud.Replica	getLeaderFromZk(String collection, String slice)
protected void	indexDoc(String collection, org.apache.solr.common.SolrInputDocument doc)
protected org.apache.solr.client.solrj.response.QueryResponse	queryServer(org.apache.solr.common.params.ModifiableSolrParams params)
protected void	setDistributedParams(org.apache.solr.common.params.ModifiableSolrParams params)
protected void	test()
protected boolean	useTlogReplicas()

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

afterClass, assertDocCounts, attemptCollectionDelete, beforeClass, beforeFullSolrCloudTest, beforeTest, checkForCollection, checkQueries, checkShardConsistency, checkShardConsistency, checkShardConsistency, checkShardConsistency, checkShardConsistency, clearErrorHook, closeRestTestHarnesses, commit, createCloudClient, createCollection, createCollection, createCollection, createCollection, createCollection, createCollectionRetry, createJetty, createJetty, createJetty, createJettys, createNewSolrClient, createNewSolrClient, createProxiedJetty, createReplicaProps, createServers, del, destroyServers, distribSetUp, enableAutoSoftCommit, ensureAllReplicasAreActive, forAllRestTestHarnesses, getBaseUrl, getBaseUrlFromZk, getClient, getCloudSolrClient, getCommonCloudSolrClient, getDataDir, getDoc, getIndexVersion, getJettyOnPort, getProxyForReplica, getPullReplicaCount, getReplicaPort, getRequestStateAfterCompletion, getShardLeader, getSolrClient, getTotalReplicas, index_specific, index_specific, indexAbunchOfDocs, indexDoc, initCloud, logReplicationDetails, logReplicaTypesReplicationInfo, printClusterStateInfo, printClusterStateInfo, queryAndCompareReplicas, queryAndCompareShards, randomlyEnableAutoSoftCommit, randomRestTestHarness, randomRestTestHarness, reloadCollection, sendDocsWithRetry, sendDocsWithRetry, setErrorHook, setupRestTestHarnesses, showCounts, updateMappingsFromZk, updateMappingsFromZk, waitForActiveReplicaCount, waitForAllWarmingSearchers, waitForCollection, waitForLiveNode, waitForNon403or404or503, waitForNoShardInconsistency, waitForRecoveriesToFinish, waitForRecoveriesToFinish, waitForRecoveriesToFinish, waitForReplicationFromReplicas, waitForThingsToLevelOut, waitForThingsToLevelOut

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

assertAllActive, beforeThisClass, copyConfigUp, getCloudSchemaFile, getCloudSolrConfig, printLayout, restartZk, verifyReplicaStatus, waitForCollectionToDisappear, waitForRecoveriesToFinish, waitForRecoveriesToFinish, waitForRecoveriesToFinish, waitForRecoveriesToFinish

Methods inherited from class org.apache.solr.BaseDistributedSearchTestCase

add, add, addFields, addRandFields, buildUrl, clearHostContext, clearSolrDisableShardsWhitelist, compare, compare, compare, compare, compare, compare, compare1, compareResponses, compareSolrResponses, createControlJetty, createJetty, createJetty, createJetty, createParams, del, delQ, fixShardCount, flags, getExtraRequestFilters, getExtraServlets, getFieldNames, getRandFields, getRandValues, getShardCount, getShardsString, getSolrHome, getSolrXml, index, indexDoc, indexDocs, indexDocs, indexr, initHostContext, initialize, query, query, query, query, queryAndCompare, queryAndCompare, seedSolrHome, 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, assertThatJQ, assertThatJQ, assertU, assertU, assertXmlFile, assumeWorkingMockito, 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, getHttpSolrClient, getRootCause, getSaferTestName, getSchemaFile, getSimpleClassName, getSolrConfigFile, getWrappedException, hasInitException, hasInitException, ignoreException, indexDocs, initAndGetDataDir, initCore, initCore, initCore, initCore, 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, 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

afterClassShutdownLogging, 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, 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, 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

Constructor Details

AbstractBasicDistributedZkTestBase

public AbstractBasicDistributedZkTestBase()

Method Details

beforeBDZKTClass

public static void beforeBDZKTClass()

useTlogReplicas

protected boolean useTlogReplicas()

Overrides:

useTlogReplicas in class AbstractFullDistribZkTestBase

setDistributedParams

protected void setDistributedParams(org.apache.solr.common.params.ModifiableSolrParams params)

Overrides:

setDistributedParams in class AbstractFullDistribZkTestBase

test

protected void test()
             throws Exception

Throws:

Exception

createCollectionInOneInstance

public static void createCollectionInOneInstance(org.apache.solr.client.solrj.SolrClient client,
 String nodeName,
 ThreadPoolExecutor executor,
 String collection,
 int numShards,
 int numReplicas)

Create a collection in single node

createCollection

protected org.apache.solr.client.solrj.response.CollectionAdminResponse createCollection(Map<String,List<Integer>> collectionInfos,
 String collectionName,
 String configSetName,
 int numShards,
 int numReplicas,
 org.apache.solr.client.solrj.SolrClient client,
 String createNodeSetStr)
                                                                                  throws org.apache.solr.client.solrj.SolrServerException,
IOException

Overrides:

createCollection in class AbstractFullDistribZkTestBase

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

getLeaderFromZk

protected org.apache.solr.common.cloud.Replica getLeaderFromZk(String collection,
 String slice)

Overrides:

getLeaderFromZk in class AbstractFullDistribZkTestBase

indexDoc

protected void indexDoc(String collection,
 org.apache.solr.common.SolrInputDocument doc)
                 throws IOException,
org.apache.solr.client.solrj.SolrServerException

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

createNewSolrClient

protected org.apache.solr.client.solrj.SolrClient createNewSolrClient(String collection,
 String baseUrl)

Overrides:

createNewSolrClient in class AbstractFullDistribZkTestBase

createNewSolrClient

protected org.apache.solr.client.solrj.SolrClient createNewSolrClient(String collection,
 String baseUrl,
 int connectionTimeoutMillis,
 int socketTimeoutMillis)

Parameters:

collection - the name of a collection or core to set as the "default" on the created client.

baseUrl - the "base" URL of a Solr node. Should not contain a collection or core name.

connectionTimeoutMillis - the HTTP connection timeout in milliseconds

socketTimeoutMillis - the HTTP socket-read timeout in milliseconds

queryServer

protected org.apache.solr.client.solrj.response.QueryResponse queryServer(org.apache.solr.common.params.ModifiableSolrParams params)
                                                                   throws org.apache.solr.client.solrj.SolrServerException,
IOException

Overrides:

queryServer in class AbstractFullDistribZkTestBase

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

distribTearDown

public void distribTearDown()
                     throws Exception

Overrides:

distribTearDown in class AbstractFullDistribZkTestBase

Throws:

Exception