Fix typos in comments

Closes #16592

Author: dongjoon-hyun

core/src/main/java/org/elasticsearch/ElasticsearchException.java

@@ -257,7 +257,7 @@ public static ElasticsearchException readException(StreamInput input, int id) th
     }
 
     /**
-     * Retruns <code>true</code> iff the given class is a registered for an exception to be read.
+     * Returns <code>true</code> iff the given class is a registered for an exception to be read.
      */
     public static boolean isRegistered(Class<? extends Throwable> exception) {
         return CLASS_TO_ELASTICSEARCH_EXCEPTION_HANDLE.containsKey(exception);
@@ -372,7 +372,7 @@ public static void toXContent(XContentBuilder builder, Params params, Throwable
     }
 
     /**
-     * Returns the root cause of this exception or mupltiple if different shards caused different exceptions
+     * Returns the root cause of this exception or multiple if different shards caused different exceptions
      */
     public ElasticsearchException[] guessRootCauses() {
         final Throwable cause = getCause();
@@ -383,7 +383,7 @@ public ElasticsearchException[] guessRootCauses() {
     }
 
     /**
-     * Returns the root cause of this exception or mupltiple if different shards caused different exceptions.
+     * Returns the root cause of this exception or multiple if different shards caused different exceptions.
      * If the given exception is not an instance of {@link org.elasticsearch.ElasticsearchException} an empty array
      * is returned.
      */

core/src/main/java/org/elasticsearch/action/admin/cluster/node/info/NodesInfoRequestBuilder.java

@@ -40,7 +40,7 @@ public NodesInfoRequestBuilder clear() {
     }
 
     /**
-     * Sets to reutrn all the data.
+     * Sets to return all the data.
      */
     public NodesInfoRequestBuilder all() {
         request.all();

core/src/main/java/org/elasticsearch/action/fieldstats/IndexConstraint.java

@@ -73,7 +73,7 @@ public Comparison getComparison() {
     }
 
     /**
-     * @return On what property of a field the contraint is going to be applied on (min or max value)
+     * @return On what property of a field the constraint is going to be applied on (min or max value)
      */
     public Property getProperty() {
         return property;

core/src/main/java/org/elasticsearch/action/index/IndexRequest.java

@@ -372,7 +372,7 @@ public String getPipeline() {
     }
 
     /**
-     * The source of the document to index, recopied to a new array if it is unsage.
+     * The source of the document to index, recopied to a new array if it is unsafe.
      */
     public BytesReference source() {
         return source;

core/src/main/java/org/elasticsearch/action/indexedscripts/put/PutIndexedScriptRequest.java

@@ -164,7 +164,7 @@ public PutIndexedScriptRequest id(String id) {
     }
 
     /**
-     * The source of the document to index, recopied to a new array if it is unsage.
+     * The source of the document to index, recopied to a new array if it is unsafe.
      */
     public BytesReference source() {
         return source;

core/src/main/java/org/elasticsearch/action/search/ClearScrollResponse.java

@@ -55,7 +55,7 @@ public boolean isSucceeded() {
     }
 
     /**
-     * @return The number of seach contexts that were freed. If this is <code>0</code> the assumption can be made,
+     * @return The number of search contexts that were freed. If this is <code>0</code> the assumption can be made,
      * that the scroll id specified in the request did not exist. (never existed, was expired, or completely consumed)
      */
     public int getNumFreed() {

core/src/main/java/org/elasticsearch/action/search/SearchRequestBuilder.java

@@ -223,7 +223,7 @@ public SearchRequestBuilder setVersion(boolean version) {
     }
 
     /**
-     * Sets the boost a specific index will receive when the query is executeed against it.
+     * Sets the boost a specific index will receive when the query is executed against it.
      *
      * @param index      The index to apply the boost against
      * @param indexBoost The boost to apply to the index

core/src/main/java/org/elasticsearch/action/termvectors/TermVectorsFields.java

@@ -486,15 +486,15 @@ public long cost() {
 
     // read a vInt. this is used if the integer might be negative. In this case,
     // the writer writes a 0 for -1 or value +1 and accordingly we have to
-    // substract 1 again
+    // subtract 1 again
     // adds one to mock not existing term freq
     int readPotentiallyNegativeVInt(StreamInput stream) throws IOException {
         return stream.readVInt() - 1;
     }
 
     // read a vLong. this is used if the integer might be negative. In this
     // case, the writer writes a 0 for -1 or value +1 and accordingly we have to
-    // substract 1 again
+    // subtract 1 again
     // adds one to mock not existing term freq
     long readPotentiallyNegativeVLong(StreamInput stream) throws IOException {
         return stream.readVLong() - 1;

core/src/main/java/org/elasticsearch/bootstrap/JNANatives.java

@@ -108,7 +108,7 @@ static String rlimitToString(long value) {
         if (value == JNACLibrary.RLIM_INFINITY) {
             return "unlimited";
         } else {
-            // TODO, on java 8 use Long.toUnsignedString, since thats what it is.
+            // TODO, on java 8 use Long.toUnsignedString, since that's what it is.
             return Long.toString(value);
         }
     }

core/src/main/java/org/elasticsearch/bootstrap/Seccomp.java

@@ -104,7 +104,7 @@ static interface LinuxLibrary extends Library {
         int prctl(int option, NativeLong arg2, NativeLong arg3, NativeLong arg4, NativeLong arg5);
         /**
          * used to call seccomp(2), its too new...
-         * this is the only way, DONT use it on some other architecture unless you know wtf you are doing
+         * this is the only way, DON'T use it on some other architecture unless you know wtf you are doing
          */
         NativeLong syscall(NativeLong number, Object... args);
     };

core/src/main/java/org/elasticsearch/cache/recycler/PageCacheRecycler.java

@@ -93,7 +93,7 @@ public PageCacheRecycler(Settings settings, ThreadPool threadPool) {
         // because they would make obtain/release too costly: we really need constant-time
         // operations.
         // Ultimately a better solution would be to only store one kind of data and have the
-        // ability to intepret it either as a source of bytes, doubles, longs, etc. eg. thanks
+        // ability to interpret it either as a source of bytes, doubles, longs, etc. eg. thanks
         // to direct ByteBuffers or sun.misc.Unsafe on a byte[] but this would have other issues
         // that would need to be addressed such as garbage collection of native memory or safety
         // of Unsafe writes.

core/src/main/java/org/elasticsearch/client/Requests.java

@@ -107,7 +107,7 @@ public static DeleteRequest deleteRequest(String index) {
     }
 
     /**
-     * Creats a new bulk request.
+     * Creates a new bulk request.
      */
     public static BulkRequest bulkRequest() {
         return new BulkRequest();

core/src/main/java/org/elasticsearch/cluster/LocalNodeMasterListener.java

@@ -38,9 +38,9 @@ public interface LocalNodeMasterListener {
      * The name of the executor that the implementation of the callbacks of this lister should be executed on. The thread
      * that is responsible for managing instances of this lister is the same thread handling the cluster state events. If
      * the work done is the callbacks above is inexpensive, this value may be {@link org.elasticsearch.threadpool.ThreadPool.Names#SAME SAME}
-     * (indicating that the callbaks will run on the same thread as the cluster state events are fired with). On the other hand,
+     * (indicating that the callbacks will run on the same thread as the cluster state events are fired with). On the other hand,
      * if the logic in the callbacks are heavier and take longer to process (or perhaps involve blocking due to IO operations),
-     * prefer to execute them on a separte more appropriate executor (eg. {@link org.elasticsearch.threadpool.ThreadPool.Names#GENERIC GENERIC}
+     * prefer to execute them on a separate more appropriate executor (eg. {@link org.elasticsearch.threadpool.ThreadPool.Names#GENERIC GENERIC}
      * or {@link org.elasticsearch.threadpool.ThreadPool.Names#MANAGEMENT MANAGEMENT}).
      *
      * @return The name of the executor that will run the callbacks of this listener.

core/src/main/java/org/elasticsearch/cluster/metadata/MetaData.java

@@ -959,7 +959,7 @@ public Builder generateClusterUuidIfNeeded() {
 
         public MetaData build() {
             // TODO: We should move these datastructures to IndexNameExpressionResolver, this will give the following benefits:
-            // 1) The datastructures will only be rebuilded when needed. Now during serailizing we rebuild these datastructures
+            // 1) The datastructures will only be rebuilded when needed. Now during serializing we rebuild these datastructures
             //    while these datastructures aren't even used.
             // 2) The aliasAndIndexLookup can be updated instead of rebuilding it all the time.
 

core/src/main/java/org/elasticsearch/cluster/routing/allocation/AllocationService.java

@@ -611,7 +611,7 @@ private RoutingNodes getMutableRoutingNodes(ClusterState clusterState) {
         return routingNodes;
     }
 
-    /** ovrride this to control time based decisions during allocation */
+    /** override this to control time based decisions during allocation */
     protected long currentNanoTime() {
         return System.nanoTime();
     }

core/src/main/java/org/elasticsearch/cluster/routing/allocation/FailedRerouteAllocation.java

@@ -30,7 +30,7 @@
 
 /**
  * This {@link RoutingAllocation} keeps a shard which routing
- * allocation has faild
+ * allocation has failed.
  */
 public class FailedRerouteAllocation extends RoutingAllocation {
 

core/src/main/java/org/elasticsearch/cluster/routing/allocation/allocator/BalancedShardsAllocator.java

@@ -571,7 +571,7 @@ private void buildModelFromAssigned(Iterable<ShardRouting> shards) {
         }
 
         /**
-         * Allocates all given shards on the minimal eligable node for the shards index
+         * Allocates all given shards on the minimal eligible node for the shards index
          * with respect to the weight function. All given shards must be unassigned.
          */
         private boolean allocateUnassigned(RoutingNodes.UnassignedShards unassigned) {
@@ -611,7 +611,7 @@ private boolean allocateUnassigned(RoutingNodes.UnassignedShards unassigned) {
              * The arrays are sorted by primaries first and then by index and shard ID so a 2 indices with 2 replica and 1 shard would look like:
              * [(0,P,IDX1), (0,P,IDX2), (0,R,IDX1), (0,R,IDX1), (0,R,IDX2), (0,R,IDX2)]
              * if we allocate for instance (0, R, IDX1) we move the second replica to the secondary array and proceed with
-             * the next replica. If we could not find a node to allocate (0,R,IDX1) we move all it's replicas to ingoreUnassigned.
+             * the next replica. If we could not find a node to allocate (0,R,IDX1) we move all it's replicas to ignoreUnassigned.
              */
             ShardRouting[] primary = unassigned.drain();
             ShardRouting[] secondary = new ShardRouting[primary.length];
@@ -733,7 +733,7 @@ private boolean allocateUnassigned(RoutingNodes.UnassignedShards unassigned) {
                 secondary = tmp;
                 secondaryLength = 0;
             } while (primaryLength > 0);
-            // clear everything we have either added it or moved to ingoreUnassigned
+            // clear everything we have either added it or moved to ignoreUnassigned
             return changed;
         }
 

core/src/main/java/org/elasticsearch/cluster/routing/allocation/decider/AwarenessAllocationDecider.java

@@ -54,7 +54,7 @@
  * <p>
  * Awareness can also be used to prevent over-allocation in the case of node or
  * even "zone" failure. For example in cloud-computing infrastructures like
- * Amazone AWS a cluster might span over multiple "zones". Awareness can be used
+ * Amazon AWS a cluster might span over multiple "zones". Awareness can be used
  * to distribute replicas to individual zones by setting:
  * <pre>
  * cluster.routing.allocation.awareness.attributes: zone

core/src/main/java/org/elasticsearch/cluster/routing/allocation/decider/ConcurrentRebalanceAllocationDecider.java

@@ -30,7 +30,7 @@
  * Similar to the {@link ClusterRebalanceAllocationDecider} this
  * {@link AllocationDecider} controls the number of currently in-progress
  * re-balance (relocation) operations and restricts node allocations if the
- * configured threashold is reached. The default number of concurrent rebalance
+ * configured threshold is reached. The default number of concurrent rebalance
  * operations is set to <tt>2</tt>
  * <p>
  * Re-balance operations can be controlled in real-time via the cluster update API using

core/src/main/java/org/elasticsearch/cluster/routing/allocation/decider/DiskThresholdDecider.java

@@ -282,7 +282,7 @@ public TimeValue getRerouteInterval() {
 
     /**
      * Returns the size of all shards that are currently being relocated to
-     * the node, but may not be finished transfering yet.
+     * the node, but may not be finished transferring yet.
      *
      * If subtractShardsMovingAway is set then the size of shards moving away is subtracted from the total size
      * of all shards

core/src/main/java/org/elasticsearch/discovery/DiscoverySettings.java

@@ -41,7 +41,7 @@ public class DiscoverySettings extends AbstractComponent {
     public final static ClusterBlock NO_MASTER_BLOCK_WRITES = new ClusterBlock(NO_MASTER_BLOCK_ID, "no master", true, false, RestStatus.SERVICE_UNAVAILABLE, EnumSet.of(ClusterBlockLevel.WRITE, ClusterBlockLevel.METADATA_WRITE));
     /**
      * sets the timeout for a complete publishing cycle, including both sending and committing. the master
-     * will continute to process the next cluster state update after this time has elapsed
+     * will continue to process the next cluster state update after this time has elapsed
      **/
     public static final Setting<TimeValue> PUBLISH_TIMEOUT_SETTING = Setting.positiveTimeSetting("discovery.zen.publish_timeout", TimeValue.timeValueSeconds(30), true, Setting.Scope.CLUSTER);
 

core/src/main/java/org/elasticsearch/discovery/local/LocalDiscovery.java

@@ -328,7 +328,7 @@ private void publish(LocalDiscovery[] members, ClusterChangedEvent clusterChange
                 ClusterState newNodeSpecificClusterState = null;
                 synchronized (this) {
                     // we do the marshaling intentionally, to check it works well...
-                    // check if we publsihed cluster state at least once and node was in the cluster when we published cluster state the last time
+                    // check if we published cluster state at least once and node was in the cluster when we published cluster state the last time
                     if (discovery.lastProcessedClusterState != null && clusterChangedEvent.previousState().nodes().nodeExists(discovery.localNode().id())) {
                         // both conditions are true - which means we can try sending cluster state as diffs
                         if (clusterStateDiffBytes == null) {

core/src/main/java/org/elasticsearch/discovery/zen/elect/ElectMasterService.java

@@ -79,7 +79,7 @@ public boolean hasEnoughMasterNodes(Iterable<DiscoveryNode> nodes) {
     }
 
     /**
-     * Returns the given nodes sorted by likelyhood of being elected as master, most likely first.
+     * Returns the given nodes sorted by likelihood of being elected as master, most likely first.
      * Non-master nodes are not removed but are rather put in the end
      */
     public List<DiscoveryNode> sortByMasterLikelihood(Iterable<DiscoveryNode> nodes) {

core/src/main/java/org/elasticsearch/discovery/zen/ping/unicast/UnicastZenPing.java

@@ -342,7 +342,7 @@ void sendPings(final TimeValue timeout, @Nullable TimeValue waitTime, final Send
         // sort the nodes by likelihood of being an active master
         List<DiscoveryNode> sortedNodesToPing = electMasterService.sortByMasterLikelihood(nodesToPingSet);
 
-        // new add the the unicast targets first
+        // new add the unicast targets first
         List<DiscoveryNode> nodesToPing = CollectionUtils.arrayAsArrayList(configuredTargetNodes);
         nodesToPing.addAll(sortedNodesToPing);
 

core/src/main/java/org/elasticsearch/gateway/AsyncShardFetch.java

@@ -166,7 +166,7 @@ public synchronized FetchResult<T> fetchData(DiscoveryNodes nodes, MetaData meta
     /**
      * Called by the response handler of the async action to fetch data. Verifies that its still working
      * on the same cache generation, otherwise the results are discarded. It then goes and fills the relevant data for
-     * the shard (response + failures), issueing a reroute at the end of it to make sure there will be another round
+     * the shard (response + failures), issuing a reroute at the end of it to make sure there will be another round
      * of allocations taking this new data into account.
      */
     protected synchronized void processAsyncFetch(ShardId shardId, T[] responses, FailedNodeException[] failures) {

core/src/main/java/org/elasticsearch/gateway/MetaDataStateFormat.java

@@ -255,7 +255,7 @@ public  T loadLatestState(ESLogger logger, Path... dataLocations) throws IOExcep
         List<PathAndStateId> files = new ArrayList<>();
         long maxStateId = -1;
         boolean maxStateIdIsLegacy = true;
-        if (dataLocations != null) { // select all eligable files first
+        if (dataLocations != null) { // select all eligible files first
             for (Path dataLocation : dataLocations) {
                 final Path stateDir = dataLocation.resolve(STATE_DIR_NAME);
                 // now, iterate over the current versions, and find latest one

core/src/main/java/org/elasticsearch/http/netty/ESHttpContentDecompressor.java

@@ -39,7 +39,7 @@ protected DecoderEmbedder<ChannelBuffer> newContentDecoder(String contentEncodin
             // compression is enabled so handle the request according to the headers (compressed and uncompressed)
             return super.newContentDecoder(contentEncoding);
         } else {
-            // if compression is disabled only allow "indentity" (uncompressed) requests
+            // if compression is disabled only allow "identity" (uncompressed) requests
             if (HttpHeaders.Values.IDENTITY.equals(contentEncoding)) {
                 // nothing to handle here
                 return null;
@@ -48,4 +48,4 @@ protected DecoderEmbedder<ChannelBuffer> newContentDecoder(String contentEncodin
             }
         }
     }
-}
+}

core/src/main/java/org/elasticsearch/http/netty/cors/CorsConfig.java

@@ -132,7 +132,7 @@ public boolean isNullOriginAllowed() {
      * xhr.withCredentials = true;
      * </pre>
      * The default value for 'withCredentials' is false in which case no cookies are sent.
-     * Settning this to true will included cookies in cross origin requests.
+     * Setting this to true will included cookies in cross origin requests.
      *
      * @return {@code true} if cookies are supported.
      */
@@ -205,7 +205,7 @@ public HttpHeaders preflightResponseHeaders() {
      * and this setting will check that the Origin is valid and if it is not valid no
      * further processing will take place, and a error will be returned to the calling client.
      *
-     * @return {@code true} if a CORS request should short-curcuit upon receiving an invalid Origin header.
+     * @return {@code true} if a CORS request should short-circuit upon receiving an invalid Origin header.
      */
     public boolean isShortCircuit() {
         return shortCircuit;

core/src/main/java/org/elasticsearch/http/netty/cors/CorsConfigBuilder.java

@@ -133,7 +133,7 @@ public static CorsConfigBuilder forOrigins(final String... origins) {
     /**
      * Web browsers may set the 'Origin' request header to 'null' if a resource is loaded
      * from the local file system. Calling this method will enable a successful CORS response
-     * with a wildcard for the the CORS response header 'Access-Control-Allow-Origin'.
+     * with a wildcard for the CORS response header 'Access-Control-Allow-Origin'.
      *
      * @return {@link CorsConfigBuilder} to support method chaining.
      */

core/src/main/java/org/elasticsearch/index/IndexModule.java

@@ -143,7 +143,7 @@ public void addIndexEventListener(IndexEventListener listener) {
     }
 
     /**
-     * Adds an {@link IndexStore} type to this index module. Typically stores are registered with a refrence to
+     * Adds an {@link IndexStore} type to this index module. Typically stores are registered with a reference to
      * it's constructor:
      * <pre>
      *     indexModule.addIndexStore("my_store_type", MyStore::new);

core/src/main/java/org/elasticsearch/index/IndexService.java

@@ -691,7 +691,7 @@ static abstract class BaseAsyncTask implements Runnable, Closeable {
         }
 
         boolean mustReschedule() {
-            // don't re-schedule if its closed or if we dont' have a single shard here..., we are done
+            // don't re-schedule if its closed or if we don't have a single shard here..., we are done
             return indexService.closed.get() == false
                 && closed.get() == false && interval.millis() > 0;
         }

core/src/main/java/org/elasticsearch/index/IndexSettings.java

@@ -329,7 +329,7 @@ public IndexMetaData getIndexMetaData() {
     public boolean isShadowReplicaIndex() { return isShadowReplicaIndex; }
 
     /**
-     * Returns the node settings. The settings retured from {@link #getSettings()} are a merged version of the
+     * Returns the node settings. The settings returned from {@link #getSettings()} are a merged version of the
      * index settings and the node settings where node settings are overwritten by index settings.
      */
     public Settings getNodeSettings() {

core/src/main/java/org/elasticsearch/index/engine/DeleteVersionValue.java

@@ -22,7 +22,7 @@
 import org.apache.lucene.util.RamUsageEstimator;
 import org.elasticsearch.index.translog.Translog;
 
-/** Holds a deleted version, which just adds a timestmap to {@link VersionValue} so we know when we can expire the deletion. */
+/** Holds a deleted version, which just adds a timestamp to {@link VersionValue} so we know when we can expire the deletion. */
 
 class DeleteVersionValue extends VersionValue {
     private final long time;