fix: remove duplicated words and grammar issues in comments

libs/common/src/main/java/org/opensearch/common/LocalTimeOffset.java

@@ -48,7 +48,7 @@
  * Converts utc into local time and back again.
  * <p>
  * "Local time" is defined by some time zone, specifically and {@link ZoneId}.
- * At any point in time a particular time zone is at some offset from from
+ * At any point in time a particular time zone is at some offset from
  * utc. So converting from utc is as simple as adding the offset.
  * <p>
  * Getting from local time back to utc is harder. Most local times happen once.

libs/common/src/main/java/org/opensearch/common/lifecycle/package-info.java

@@ -7,7 +7,7 @@
  */
 
 /**
- * Foundation implementation for a object lifecycle.
+ * Foundation implementation for an object lifecycle.
  *
  * See {@link org.opensearch.common.lifecycle.Lifecycle} for example usage
  *

plugins/repository-azure/src/main/java/org/opensearch/repositories/azure/AzureStorageService.java

@@ -149,7 +149,7 @@ public AzureStorageService(Settings settings) {
 
     /**
      * Obtains a {@code BlobServiceClient} on each invocation using the current client
-     * settings. BlobServiceClient is thread safe and and could be cached but the settings
+     * settings. BlobServiceClient is thread safe and could be cached but the settings
      * can change, therefore the instance might be recreated from scratch.
      *
      * @param clientName client name
@@ -162,7 +162,7 @@ public Tuple<BlobServiceClient, Supplier<Context>> client(String clientName) {
 
     /**
      * Obtains a {@code BlobServiceClient} on each invocation using the current client
-     * settings. BlobServiceClient is thread safe and and could be cached but the settings
+     * settings. BlobServiceClient is thread safe and could be cached but the settings
      * can change, therefore the instance might be recreated from scratch.
 
      * @param clientName client name

server/src/main/java/org/opensearch/action/admin/indices/open/OpenIndexRequestBuilder.java

@@ -39,7 +39,7 @@
 import org.opensearch.transport.client.OpenSearchClient;
 
 /**
- * Builder for for open index request
+ * Builder for open index request
  *
  * @opensearch.api
  */

server/src/main/java/org/opensearch/action/bulk/TransportBulkAction.java

@@ -1291,7 +1291,7 @@ synchronized void markItemAsFailed(int slot, Exception e) {
                 e
             );
 
-            // We hit a error during preprocessing a request, so we:
+            // We hit an error during preprocessing a request, so we:
             // 1) Remember the request item slot from the bulk, so that we're done processing all requests we know what failed
             // 2) Add a bulk item failure for this request
             // 3) Continue with the next request in the bulk.

server/src/main/java/org/opensearch/action/bulk/TransportShardBulkAction.java

@@ -946,7 +946,7 @@ private static Engine.Result performOpOnReplica(
             // Even though the primary waits on all nodes to ack the mapping changes to the cluster-manager
             // (see MappingUpdatedAction.updateMappingOnClusterManager) we still need to protect against missing mappings
             // and wait for them. The reason is concurrent requests. Request r1 which has new field f triggers a
-            // mapping update. Assume that that update is first applied on the primary, and only later on the replica
+            // mapping update. Assume that the update is first applied on the primary, and only later on the replica
             // (it’s happening concurrently). Request r2, which now arrives on the primary and which also has the new
             // field f might see the updated mapping (on the primary), and will therefore proceed to be replicated
             // to the replica. When it arrives on the replica, there’s no guarantee that the replica has already

server/src/main/java/org/opensearch/cluster/ClusterState.java

@@ -244,7 +244,7 @@ public long getVersionOrMetadataVersion() {
     }
 
     /**
-     * This stateUUID is automatically generated for for each version of cluster state. It is used to make sure that
+     * This stateUUID is automatically generated for each version of cluster state. It is used to make sure that
      * we are applying diffs to the right previous state.
      */
     public String stateUUID() {

server/src/main/java/org/opensearch/index/IndexSettings.java

@@ -1843,7 +1843,7 @@ public TimeValue getTranslogRetentionAge() {
     }
 
     /**
-     * Returns the maximum number of translog files that that no longer required for persistence should be kept for peer recovery
+     * Returns the maximum number of translog files that no longer required for persistence should be kept for peer recovery
      * when soft-deletes is disabled.
      */
     public int getTranslogRetentionTotalFiles() {

server/src/main/java/org/opensearch/index/engine/InternalEngine.java

@@ -890,7 +890,7 @@ public IndexResult index(Index index) throws IOException {
                  *  - doc A has autoGeneratedIdTimestamp = 10, isRetry = false
                  *  - doc B has autoGeneratedIdTimestamp = 9, isRetry = false
                  *
-                 *  while both docs are in in flight, we disconnect on one node, reconnect and send doc A again
+                 *  while both docs are in flight, we disconnect on one node, reconnect and send doc A again
                  *  - now doc A' has autoGeneratedIdTimestamp = 10, isRetry = true
                  *
                  *  if A' arrives on the shard first we update maxUnsafeAutoIdTimestamp to 10 and use update document. All subsequent

server/src/main/java/org/opensearch/index/get/ShardGetService.java

@@ -310,7 +310,7 @@ private GetResult innerGetLoadFromStoredFields(
                 Mapper fieldMapper = docMapper.mappers().getMapper(field);
                 if (fieldMapper == null) {
                     if (docMapper.objectMappers().get(field) != null) {
-                        // Only fail if we know it is a object field, missing paths / fields shouldn't fail.
+                        // Only fail if we know it is an object field, missing paths / fields shouldn't fail.
                         throw new IllegalArgumentException("field [" + field + "] isn't a leaf field");
                     }
                 }

server/src/main/java/org/opensearch/index/reindex/BulkByScrollTask.java

@@ -174,7 +174,7 @@ public boolean isWorker() {
     /**
      * Sets this task to be a worker task that performs search requests
      * @param requestsPerSecond How many search requests per second this task should make
-     * @param sliceId If this is is a sliced task, which slice number this task corresponds to. Null if not sliced.
+     * @param sliceId If this is a sliced task, which slice number this task corresponds to. Null if not sliced.
      */
     public void setWorker(float requestsPerSecond, @Nullable Integer sliceId) {
         if (isWorker()) {

server/src/main/java/org/opensearch/index/shard/IndexShard.java

@@ -6264,7 +6264,7 @@ RetentionLeaseSyncer getRetentionLeaseSyncer() {
 
     /**
      * Fetch the latest SegmentInfos held by the shard's underlying Engine, wrapped
-     * by a a {@link GatedCloseable} to ensure files are not deleted/merged away.
+     * by a {@link GatedCloseable} to ensure files are not deleted/merged away.
      *
      * @throws EngineException - When segment infos cannot be safely retrieved
      */

server/src/main/java/org/opensearch/index/shard/ShardSplittingQuery.java

@@ -126,7 +126,7 @@ public ScorerSupplier scorerSupplier(LeafReaderContext context) throws IOExcepti
                     }
                     if (indexMetadata.isRoutingPartitionedIndex()) {
                         // this is the heaviest invariant. Here we have to visit all docs stored fields do extract _id and _routing
-                        // this this index is routing partitioned.
+                        // this index is routing partitioned.
                         Visitor visitor = new Visitor(leafReader);
                         TwoPhaseIterator twoPhaseIterator = parentBitSet == null
                             ? new RoutingPartitionedDocIdSetIterator(visitor)

server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshot.java

@@ -216,7 +216,7 @@ public StoreFileMetadata metadata() {
          * Checks if a file in a store is the same file
          *
          * @param md file in a store
-         * @return true if file in a store this this file have the same checksum and length
+         * @return true if file in a store this file has the same checksum and length
          */
         public boolean isSame(StoreFileMetadata md) {
             return metadata.isSame(md);
@@ -226,7 +226,7 @@ public boolean isSame(StoreFileMetadata md) {
          * Checks if a file in a store is the same file
          *
          * @param fileInfo file in a store
-         * @return true if file in a store this this file have the same checksum and length
+         * @return true if file in a store this file has the same checksum and length
          */
         public boolean isSame(FileInfo fileInfo) {
             if (numberOfParts != fileInfo.numberOfParts) {

server/src/main/java/org/opensearch/plugins/SearchPlugin.java

@@ -870,7 +870,7 @@ public SearchExtensionSpec(ParseField name, Writeable.Reader<? extends W> reader
         /**
          * Build the spec with a String.
          *
-         * @param name the name of the behavior. The parser and the reader are are registered under this name so be sure that that is the
+         * @param name the name of the behavior. The parser and the reader are registered under this name so be sure that is the
          *        name that W's {@link NamedWriteable#getWriteableName()} returns.  It is an error if this name conflicts with another
          *        registered name, including names from other plugins.
          * @param reader reader that reads the behavior from the internode protocol

server/src/main/java/org/opensearch/rest/action/RestActions.java

@@ -195,7 +195,7 @@ public static void buildNodesHeader(
     }
 
     /**
-     * Automatically transform the {@link ToXContent}-compatible, nodes-level {@code response} into a a {@link BytesRestResponse}.
+     * Automatically transform the {@link ToXContent}-compatible, nodes-level {@code response} into a {@link BytesRestResponse}.
      * <p>
      * This looks like:
      * <code>

server/src/main/java/org/opensearch/search/aggregations/bucket/terms/GlobalOrdinalsStringTermsAggregator.java

@@ -697,7 +697,7 @@ abstract class CollectionStrategy implements Releasable {
          * @param owningBucketOrd the ordinal of the bucket that owns this collection
          * @param doc the doc id in to collect
          * @param globalOrd the global ordinal to collect
-         * @param sub the sub-aggregators that that will collect the bucket data
+         * @param sub the sub-aggregators that will collect the bucket data
          */
         abstract void collectGlobalOrd(long owningBucketOrd, int doc, long globalOrd, LeafBucketCollector sub) throws IOException;
 

server/src/main/java/org/opensearch/search/fetch/FetchPhase.java

@@ -320,7 +320,7 @@ protected FieldsVisitor createStoredFieldsVisitor(SearchContext context, Map<Str
                 for (String fieldName : fieldNames) {
                     MappedFieldType fieldType = context.fieldType(fieldName);
                     if (fieldType == null) {
-                        // Only fail if we know it is a object field, missing paths / fields shouldn't fail.
+                        // Only fail if we know it is an object field, missing paths / fields shouldn't fail.
                         if (context.getObjectMapper(fieldName) != null) {
                             throw new IllegalArgumentException("field [" + fieldName + "] isn't a leaf field");
                         }

server/src/main/java/org/opensearch/search/suggest/phrase/DirectCandidateGeneratorBuilder.java

@@ -287,7 +287,7 @@ Integer maxInspections() {
      * <p>
      * This can be used to exclude high frequency terms from being
      * suggested. High frequency terms are usually spelled correctly on top
-     * of this this also improves the suggest performance.
+     * of this. This also improves the suggest performance.
      */
     public DirectCandidateGeneratorBuilder maxTermFreq(float maxTermFreq) {
         this.maxTermFreq = maxTermFreq;

server/src/main/java/org/opensearch/search/suggest/term/TermSuggestionBuilder.java

@@ -300,8 +300,8 @@ public int maxInspections() {
      * to {@code 0.01}.
      * <p>
      * This can be used to exclude high frequency terms from being suggested.
-     * High frequency terms are usually spelled correctly on top of this this
-     * also improves the suggest performance.
+     * High frequency terms are usually spelled correctly. On top of this,
+     * this also improves the suggest performance.
      */
     public TermSuggestionBuilder maxTermFreq(float maxTermFreq) {
         if (maxTermFreq < 0.0f) {