Spelling

TESTING.asciidoc

@@ -166,7 +166,7 @@ systemProp.tests.jvms=8
 ----------------------------
 
 Its difficult to pick the "right" number here. Hypercores don't count for CPU
-intensive tests and you should leave some slack for JVM-interal threads like
+intensive tests and you should leave some slack for JVM-internal threads like
 the garbage collector. And you have to have enough RAM to handle each JVM.
 
 === Test compatibility.

build.gradle

@@ -496,7 +496,7 @@ allprojects {
   // otherwise the eclipse merging is *super confusing*
   tasks.eclipse.dependsOn(cleanEclipse, copyEclipseSettings)
 
-  // work arround https://github.com/gradle/gradle/issues/6582 
+  // work around https://github.com/gradle/gradle/issues/6582 
   tasks.eclipseProject.mustRunAfter tasks.cleanEclipseProject
   tasks.matching { it.name == 'eclipseClasspath' }.all {
     it.mustRunAfter { tasks.cleanEclipseClasspath }

buildSrc/build.gradle

@@ -225,7 +225,7 @@ if (project != rootProject) {
   }
 
   /*
-   * We alread configure publication and we don't need or want this one that
+   * We already configure publication and we don't need or want this one that
    * comes from the java-gradle-plugin.
    */
   afterEvaluate {

buildSrc/src/main/groovy/org/elasticsearch/gradle/BuildPlugin.groovy

@@ -150,7 +150,7 @@ class BuildPlugin implements Plugin<Project> {
             }
 
             String inFipsJvmScript = 'print(java.security.Security.getProviders()[0].name.toLowerCase().contains("fips"));'
-            boolean inFipsJvm = Boolean.parseBoolean(runJavascript(project, runtimeJavaHome, inFipsJvmScript))
+            boolean inFipsJvm = Boolean.parseBoolean(runJavaScript(project, runtimeJavaHome, inFipsJvmScript))
 
             // Build debugging info
             println '======================================='
@@ -431,28 +431,28 @@ class BuildPlugin implements Plugin<Project> {
         String versionInfoScript = 'print(' +
             'java.lang.System.getProperty("java.vendor") + " " + java.lang.System.getProperty("java.version") + ' +
             '" [" + java.lang.System.getProperty("java.vm.name") + " " + java.lang.System.getProperty("java.vm.version") + "]");'
-        return runJavascript(project, javaHome, versionInfoScript).trim()
+        return runJavaScript(project, javaHome, versionInfoScript).trim()
     }
 
     /** Finds the parsable java specification version */
     private static String findJavaSpecificationVersion(Project project, String javaHome) {
         String versionScript = 'print(java.lang.System.getProperty("java.specification.version"));'
-        return runJavascript(project, javaHome, versionScript)
+        return runJavaScript(project, javaHome, versionScript)
     }
 
     private static String findJavaVendor(Project project, String javaHome) {
         String vendorScript = 'print(java.lang.System.getProperty("java.vendor"));'
-        return runJavascript(project, javaHome, vendorScript)
+        return runJavaScript(project, javaHome, vendorScript)
     }
 
     /** Finds the parsable java specification version */
     private static String findJavaVersion(Project project, String javaHome) {
         String versionScript = 'print(java.lang.System.getProperty("java.version"));'
-        return runJavascript(project, javaHome, versionScript)
+        return runJavaScript(project, javaHome, versionScript)
     }
 
     /** Runs the given javascript using jjs from the jdk, and returns the output */
-    private static String runJavascript(Project project, String javaHome, String script) {
+    private static String runJavaScript(Project project, String javaHome, String script) {
         ByteArrayOutputStream stdout = new ByteArrayOutputStream()
         ByteArrayOutputStream stderr = new ByteArrayOutputStream()
         if (Os.isFamily(Os.FAMILY_WINDOWS)) {
@@ -553,7 +553,7 @@ class BuildPlugin implements Plugin<Project> {
         RepositoryHandler repos = project.repositories
         if (System.getProperty("repos.mavenLocal") != null) {
             // with -Drepos.mavenLocal=true we can force checking the local .m2 repo which is
-            // useful for development ie. bwc tests where we install stuff in the local repository
+            // useful for development i.e. bwc tests where we install stuff in the local repository
             // such that we don't have to pass hardcoded files to gradle
             repos.mavenLocal()
         }

buildSrc/src/main/groovy/org/elasticsearch/gradle/FileContentsTask.groovy

@@ -37,7 +37,7 @@ class FileContentsTask extends DefaultTask {
   Object contents
 
   /**
-   * The file to be built. Takes any objecct and coerces to a file.
+   * The file to be built. Takes any object and coerces to a file.
    */
   void setFile(Object file) {
     this.file = file as File

buildSrc/src/main/groovy/org/elasticsearch/gradle/precommit/PrecommitTasks.groovy

@@ -68,7 +68,7 @@ class PrecommitTasks {
              * (which provides NamingConventionsCheck) and :test:logger-usage
              * which provides the logger usage check. Since the build tools
              * don't use the logger usage check because they don't have any
-             * of Elaticsearch's loggers and :test:logger-usage actually does
+             * of Elasticsearch's loggers and :test:logger-usage actually does
              * use the NamingConventionsCheck we break the circular dependency
              * here.
              */

buildSrc/src/main/java/org/elasticsearch/gradle/precommit/TestingConventionsTasks.java

@@ -233,7 +233,7 @@ private PatternFilterable getRandomizedTestingPatternSet(Task task) {
             Method getPatternSet = task.getClass().getMethod("getPatternSet");
             return (PatternFilterable) getPatternSet.invoke(task);
         } catch (NoSuchMethodException e) {
-            throw new IllegalStateException("Expecte task to have a `patternSet` " + task, e);
+            throw new IllegalStateException("Expected task to have a `patternSet` " + task, e);
         } catch (IllegalAccessException | InvocationTargetException e) {
             throw new IllegalStateException("Failed to get pattern set from task" + task, e);
         }

buildSrc/src/main/java/org/elasticsearch/gradle/testclusters/ElasticsearchNode.java

@@ -183,7 +183,7 @@ private void startElasticsearchProcess(File distroArtifact) {
         try {
             processBuilder.directory(workingDir);
             Map<String, String> environment = processBuilder.environment();
-            // Don't inherit anything from the environment for as that would  lack reproductability
+            // Don't inherit anything from the environment for as that would  lack reproducibility
             environment.clear();
             if (javaHome != null) {
                 environment.put("JAVA_HOME", getJavaHome().getAbsolutePath());
@@ -219,7 +219,7 @@ public String getTransportPortURI() {
     synchronized void stop(boolean tailLogs) {
         if (esProcess == null && tailLogs) {
             // This is a special case. If start() throws an exception the plugin will still call stop
-            // Another exception here would eat the orriginal.
+            // Another exception here would eat the original.
             return;
         }
         logger.info("Stopping `{}`, tailLogs: {}", this, tailLogs);

buildSrc/src/main/java/org/elasticsearch/gradle/testclusters/TestClustersPlugin.java

@@ -311,7 +311,7 @@ private static void configureCleanupHooks(Project project) {
             shutdownExecutorService();
         });
         // When the Daemon is not used, or runs into issues, rely on a shutdown hook
-        // When the daemon is used, but does not work correctly and eventually dies off (e.x. due to non interruptable
+        // When the daemon is used, but does not work correctly and eventually dies off (e.x. due to non interruptible
         // thread in the build) process will be stopped eventually when the daemon dies.
         Runtime.getRuntime().addShutdownHook(new Thread(TestClustersPlugin::shutDownAllClusters));
     }

buildSrc/src/test/java/org/elasticsearch/gradle/VersionCollectionTests.java

@@ -350,7 +350,7 @@ public void testCompareToAuthoritativeUnreleasedActuallyReleased() {
         vc.compareToAuthoritative(authoritativeReleasedVersions);
     }
 
-    public void testCompareToAuthoritativeNotReallyRelesed() {
+    public void testCompareToAuthoritativeNotReallyReleased() {
         List<String> listOfVersions = asList("7.0.0", "7.0.1", "7.1.0", "7.1.1", "7.2.0", "7.3.0", "8.0.0");
         List<Version> authoritativeReleasedVersions = Stream.of("7.0.0", "7.0.1")
                 .map(Version::fromString)

buildSrc/src/test/java/org/elasticsearch/gradle/test/GradleIntegrationTestCase.java

@@ -160,11 +160,11 @@ public void assertOutputOnlyOnce(String output, String... text) {
         for (String each : text) {
             int i = output.indexOf(each);
             if (i == -1 ) {
-                fail("Expected \n```" + each + "```\nto appear at most once, but it didn't at all.\n\nOutout is:\n"+ output
+                fail("Expected \n```" + each + "```\nto appear at most once, but it didn't at all.\n\nOutput is:\n"+ output
                 );
             }
             if(output.indexOf(each) !=  output.lastIndexOf(each)) {
-                fail("Expected `" + each + "` to appear at most once, but it did multiple times.\n\nOutout is:\n"+ output);
+                fail("Expected `" + each + "` to appear at most once, but it did multiple times.\n\nOutput is:\n"+ output);
             }
         }
     }

buildSrc/src/test/java/org/elasticsearch/gradle/test/JUnit3MethodProvider.java

@@ -39,7 +39,7 @@ public Collection<Method> getTestMethods(Class<?> suiteClass, ClassModel classMo
         Map<Method,MethodModel> methods = classModel.getMethods();
         ArrayList<Method> result = new ArrayList<>();
         for (MethodModel mm : methods.values()) {
-            // Skip any methods that have overrieds/ shadows.
+            // Skip any methods that have overrides/ shadows.
             if (mm.getDown() != null) continue;
 
             Method m = mm.element;

buildSrc/src/testKit/elasticsearch-build-resources/build.gradle

@@ -32,7 +32,7 @@ task sample {
 task noConfigAfterExecution {
     dependsOn buildResources
     doLast {
-        println "This should cause an error because we are refferencing " +
+        println "This should cause an error because we are referencing " +
                 "${buildResources.copy('checkstyle_suppressions.xml')} after the `buildResources` task has ran."
     }
 }

client/rest-high-level/src/main/java/org/elasticsearch/client/RethrottleRequest.java

@@ -72,6 +72,6 @@ public float getRequestsPerSecond() {
 
     @Override
     public String toString() {
-        return "RethrottleRequest: taskID = " + taskId +"; reqestsPerSecond = " + requestsPerSecond;
+        return "RethrottleRequest: taskID = " + taskId +"; requestsPerSecond = " + requestsPerSecond;
     }
 }

client/rest-high-level/src/main/java/org/elasticsearch/client/WatcherClient.java

@@ -291,7 +291,7 @@ public ExecuteWatchResponse executeWatch(ExecuteWatchRequest request, RequestOpt
      * the docs</a> for more.
      * @param request the request
      * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
-     * @param listener the listener to be notifed upon request completion
+     * @param listener the listener to be notified upon request completion
      */
     public void executeWatchAsync(ExecuteWatchRequest request, RequestOptions options, ActionListener<ExecuteWatchResponse> listener) {
         restHighLevelClient.performRequestAsyncAndParseEntity(request, WatcherRequestConverters::executeWatch, options,

client/rest-high-level/src/main/java/org/elasticsearch/client/common/ProtocolUtils.java

@@ -30,7 +30,7 @@ public final class ProtocolUtils {
     /**
      * Implements equals for a map of string arrays
      *
-     * The map of string arrays is used in some XPack protocol classes but does't work with equal.
+     * The map of string arrays is used in some XPack protocol classes but doesn't work with equal.
      */
     public static boolean equals(Map<String, String[]> a, Map<String, String[]> b) {
         if (a == null) {
@@ -61,7 +61,7 @@ public static boolean equals(Map<String, String[]> a, Map<String, String[]> b) {
     /**
      * Implements hashCode for map of string arrays
      *
-     * The map of string arrays does't work with hashCode.
+     * The map of string arrays doesn't work with hashCode.
      */
     public static int hashCode(Map<String, String[]> a) {
         int hash = 0;

client/rest-high-level/src/main/java/org/elasticsearch/client/graph/GraphExploreRequest.java

@@ -246,7 +246,7 @@ public boolean returnDetailedInfo() {
 
     /**
      * Add a stage in the graph exploration. Each hop represents a stage of
-     * querying elasticsearch to identify terms which can then be connnected to
+     * querying elasticsearch to identify terms which can then be connected to
      * other terms in a subsequent hop.
      * 
      * @param guidingQuery

client/rest-high-level/src/main/java/org/elasticsearch/client/graph/GraphExploreResponse.java

@@ -167,7 +167,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
     }
 
     private static final ConstructingObjectParser<GraphExploreResponse, Void> PARSER = new ConstructingObjectParser<>(
-            "GraphExploreResponsenParser", true,
+            "GraphExploreResponseParser", true,
             args -> {
                 GraphExploreResponse result = new GraphExploreResponse();  
                 result.vertices = new HashMap<>();

client/rest-high-level/src/main/java/org/elasticsearch/client/graph/Hop.java

@@ -45,7 +45,7 @@
  * <p>
  * Optionally, each hop can contain a "guiding query" that further limits the set of documents considered.
  * In our weblog example above we might choose to constrain the second hop to only look at log records that
- * had a reponse code of 404.
+ * had a response code of 404.
  * </p>
  * <p>
  * If absent, the list of {@link VertexRequest}s is inherited from the prior Hop's list to avoid repeating

client/rest-high-level/src/main/java/org/elasticsearch/client/indexlifecycle/GetLifecyclePolicyResponse.java

@@ -66,8 +66,8 @@ public static GetLifecyclePolicyResponse fromXContent(XContentParser parser) thr
         while (!parser.isClosed()) {
             if (parser.currentToken() == XContentParser.Token.START_OBJECT) {
                 String policyName = parser.currentName();
-                LifecyclePolicyMetadata policyDefinion = LifecyclePolicyMetadata.parse(parser, policyName);
-                policies.put(policyName, policyDefinion);
+                LifecyclePolicyMetadata policyDefinition = LifecyclePolicyMetadata.parse(parser, policyName);
+                policies.put(policyName, policyDefinition);
             } else {
                 parser.nextToken();
             }

client/rest-high-level/src/main/java/org/elasticsearch/client/indices/FreezeIndexRequest.java

@@ -70,7 +70,7 @@ public void setIndicesOptions(IndicesOptions indicesOptions) {
     }
 
     /**
-     * Returns the wait for active shard cound or null if the default should be used
+     * Returns the wait for active shard count or null if the default should be used
      */
     public ActiveShardCount getWaitForActiveShards() {
         return waitForActiveShards;

client/rest-high-level/src/main/java/org/elasticsearch/client/indices/UnfreezeIndexRequest.java

@@ -70,7 +70,7 @@ public void setIndicesOptions(IndicesOptions indicesOptions) {
     }
 
     /**
-     * Returns the wait for active shard cound or null if the default should be used
+     * Returns the wait for active shard count or null if the default should be used
      */
     public ActiveShardCount getWaitForActiveShards() {
         return waitForActiveShards;

client/rest-high-level/src/main/java/org/elasticsearch/client/ml/job/config/JobUpdate.java

@@ -73,7 +73,7 @@ private JobUpdate(String jobId, @Nullable List<String> groups, @Nullable String
                       @Nullable List<DetectorUpdate> detectorUpdates, @Nullable ModelPlotConfig modelPlotConfig,
                       @Nullable AnalysisLimits analysisLimits, @Nullable TimeValue backgroundPersistInterval,
                       @Nullable Long renormalizationWindowDays, @Nullable Long resultsRetentionDays,
-                      @Nullable Long modelSnapshotRetentionDays, @Nullable List<String> categorisationFilters,
+                      @Nullable Long modelSnapshotRetentionDays, @Nullable List<String> categorizationFilters,
                       @Nullable Map<String, Object> customSettings) {
         this.jobId = jobId;
         this.groups = groups;
@@ -85,7 +85,7 @@ private JobUpdate(String jobId, @Nullable List<String> groups, @Nullable String
         this.backgroundPersistInterval = backgroundPersistInterval;
         this.modelSnapshotRetentionDays = modelSnapshotRetentionDays;
         this.resultsRetentionDays = resultsRetentionDays;
-        this.categorizationFilters = categorisationFilters;
+        this.categorizationFilters = categorizationFilters;
         this.customSettings = customSettings;
     }
 

client/rest-high-level/src/main/java/org/elasticsearch/client/ml/job/process/DataCounts.java

@@ -307,7 +307,7 @@ public Date getLatestRecordTimeStamp() {
     /**
      * The wall clock time the latest record was seen.
      *
-     * @return Wall clock time of the lastest record
+     * @return Wall clock time of the latest record
      */
     public Date getLastDataTimeStamp() {
         return lastDataTimeStamp;

client/rest-high-level/src/main/java/org/elasticsearch/client/rollup/GetRollupJobRequest.java

@@ -32,7 +32,7 @@ public class GetRollupJobRequest implements Validatable {
     private final String jobId;
 
     /**
-     * Create a requets .
+     * Create a requests .
      * @param jobId id of the job to return or {@code _all} to return all jobs
      */
     public GetRollupJobRequest(final String jobId) {

client/rest-high-level/src/main/java/org/elasticsearch/client/rollup/GetRollupJobResponse.java

@@ -185,7 +185,7 @@ public final String toString() {
     public static class RollupIndexerJobStats {
         private final long numPages;
         private final long numInputDocuments;
-        private final long numOuputDocuments;
+        private final long numOutputDocuments;
         private final long numInvocations;
         private long indexTime;
         private long indexTotal;
@@ -194,11 +194,11 @@ public static class RollupIndexerJobStats {
         private long indexFailures;
         private long searchFailures;
 
-        RollupIndexerJobStats(long numPages, long numInputDocuments, long numOuputDocuments, long numInvocations,
+        RollupIndexerJobStats(long numPages, long numInputDocuments, long numOutputDocuments, long numInvocations,
                               long indexTime, long indexTotal, long searchTime, long searchTotal, long indexFailures, long searchFailures) {
             this.numPages = numPages;
             this.numInputDocuments = numInputDocuments;
-            this.numOuputDocuments = numOuputDocuments;
+            this.numOutputDocuments = numOutputDocuments;
             this.numInvocations = numInvocations;
             this.indexTime = indexTime;
             this.indexTotal = indexTotal;
@@ -233,7 +233,7 @@ public long getNumInvocations() {
          * Number of documents written to the result indices.
          */
         public long getOutputDocuments() {
-            return numOuputDocuments;
+            return numOutputDocuments;
         }
 
         /**
@@ -304,7 +304,7 @@ public boolean equals(Object other) {
             RollupIndexerJobStats that = (RollupIndexerJobStats) other;
             return Objects.equals(this.numPages, that.numPages)
                 && Objects.equals(this.numInputDocuments, that.numInputDocuments)
-                && Objects.equals(this.numOuputDocuments, that.numOuputDocuments)
+                && Objects.equals(this.numOutputDocuments, that.numOutputDocuments)
                 && Objects.equals(this.numInvocations, that.numInvocations)
                 && Objects.equals(this.indexTime, that.indexTime)
                 && Objects.equals(this.searchTime, that.searchTime)
@@ -316,15 +316,15 @@ public boolean equals(Object other) {
 
         @Override
         public int hashCode() {
-            return Objects.hash(numPages, numInputDocuments, numOuputDocuments, numInvocations,
+            return Objects.hash(numPages, numInputDocuments, numOutputDocuments, numInvocations,
                 indexTime, searchTime, indexFailures, searchFailures, searchTotal, indexTotal);
         }
 
         @Override
         public final String toString() {
             return "{pages=" + numPages
                     + ", input_docs=" + numInputDocuments
-                    + ", output_docs=" + numOuputDocuments
+                    + ", output_docs=" + numOutputDocuments
                     + ", invocations=" + numInvocations
                     + ", index_failures=" + indexFailures
                     + ", search_failures=" + searchFailures

client/rest-high-level/src/test/java/org/elasticsearch/client/BulkProcessorIT.java

@@ -287,7 +287,7 @@ public void testGlobalParametersAndSingleRequest() throws Exception {
 
         final CountDownLatch latch = new CountDownLatch(1);
         BulkProcessorTestListener listener = new BulkProcessorTestListener(latch);
-        createFieldAddingPipleine("pipeline_id", "fieldNameXYZ", "valueXYZ");
+        createFieldAddingPipeline("pipeline_id", "fieldNameXYZ", "valueXYZ");
 
         // tag::bulk-processor-mix-parameters
         try (BulkProcessor processor = initBulkProcessorBuilder(listener)
@@ -322,7 +322,7 @@ public void testGlobalParametersAndBulkProcessor() throws Exception {
 
         final CountDownLatch latch = new CountDownLatch(1);
         BulkProcessorTestListener listener = new BulkProcessorTestListener(latch);
-        createFieldAddingPipleine("pipeline_id", "fieldNameXYZ", "valueXYZ");
+        createFieldAddingPipeline("pipeline_id", "fieldNameXYZ", "valueXYZ");
 
         int numDocs = randomIntBetween(10, 10);
         try (BulkProcessor processor = initBulkProcessorBuilder(listener)