[Docs] Fix common word repetitions (#39703)

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

@@ -34,7 +34,7 @@
  * Job processed record counts.
  * <p>
  * The getInput... methods return the actual number of
- * fields/records sent the the API including invalid records.
+ * fields/records sent the API including invalid records.
  * The getProcessed... methods are the number sent to the
  * Engine.
  * <p>

docs/painless/painless-contexts/painless-bucket-selector-agg-context.asciidoc

@@ -15,7 +15,7 @@ to determine if a bucket should be retained or filtered out.
 ==== Return
 
 boolean::
-        True if the the bucket should be retained, false if the bucket should be filtered out.
+        True if the bucket should be retained, false if the bucket should be filtered out.
 
 ==== API
 
@@ -78,4 +78,4 @@ GET /seats/_search
 // TEST[setup:seats]
 <1> The `buckets_path` points to the max aggregations (`max_cost`) and adds `max` variables
 to the `params` map
-<2> The user-specified `base_cost` is also added to the `params` map
+<2> The user-specified `base_cost` is also added to the `params` map

docs/reference/docs/index_.asciidoc

@@ -367,7 +367,7 @@ PUT twitter/_doc/1?version=2&version_type=external
 near real time aspects of search operations. If no version is provided,
 then the operation is executed without any version checks.
 
-The above will succeed since the the supplied version of 2 is higher than
+The above will succeed since the supplied version of 2 is higher than
 the current document version of 1. If the document was already updated
 and its version was set to 2 or higher, the indexing command will fail
 and result in a conflict (409 http status code).

docs/reference/ilm/apis/explain.asciidoc

@@ -227,7 +227,7 @@ information for the step that's being performed on the index.
 <1> Status of the step that's in progress.
 
 If the index is in the ERROR step, something went wrong while executing a
-step in the policy and and you will need to take action for the index to proceed
+step in the policy and you will need to take action for the index to proceed
 to the next step. To help you diagnose the problem, the explain response shows
 the step that failed and the step info provides information about the error.
 

docs/reference/mapping/removal_of_types.asciidoc

@@ -431,7 +431,7 @@ In Elasticsearch 7.0, each API will support typeless requests,
 and specifying a type will produce a deprecation warning.
 
 NOTE: Typeless APIs work even if the target index contains a custom type.
-For example, if an index has the the custom type name `my_type`, we can add
+For example, if an index has the custom type name `my_type`, we can add
 documents to it using typeless `index` calls, and load documents with typeless
 `get` calls.
 

docs/src/test/java/org/elasticsearch/smoketest/DocsClientYamlTestSuiteIT.java

@@ -98,7 +98,7 @@ protected ClientYamlTestClient initClientYamlTestClient(
     }
 
     /**
-     * Compares the the results of running two analyzers against many random
+     * Compares the results of running two analyzers against many random
      * strings. The goal is to figure out if two anlayzers are "the same" by
      * comparing their results. This is far from perfect but should be fairly
      * accurate, especially for gross things like missing {@code decimal_digit}

libs/dissect/src/main/java/org/elasticsearch/dissect/DissectParser.java

@@ -182,7 +182,7 @@ public Map<String, String> parse(String inputString) {
          * all of the bytes then progress the main cursor. Repeat till the end of the input string. Since the string being searching for
          * (the delimiter) is generally small and rare the naive approach is efficient.
          *
-         * In this case the the string that is walked is the input string, and the string being searched for is the current delimiter.
+         * In this case the string that is walked is the input string, and the string being searched for is the current delimiter.
          * For example for a dissect pattern of {@code %{a},%{b}:%{c}} the delimiters (comma then colon) are searched for in the
          * input string. At class construction the list of keys+delimiters are found (dissectPairs), which allows the use of that ordered
          * list to know which delimiter to use for the search. The delimiters is progressed once the current delimiter is matched.

libs/dissect/src/test/java/org/elasticsearch/dissect/DissectParserTests.java

@@ -67,7 +67,7 @@ public void testLogstashSpecs() {
         assertMatch("%{a} » %{b}»%{c}€%{d}", "foo » bar»baz€quux",
             Arrays.asList("a", "b", "c", "d"), Arrays.asList("foo", "bar", "baz", "quux"));
         assertMatch("%{a} %{b} %{+a}", "foo bar baz quux", Arrays.asList("a", "b"), Arrays.asList("foo baz quux", "bar"), " ");
-        //Logstash supports implicit ordering based anchored by the the key without the '+'
+        //Logstash supports implicit ordering based anchored by the key without the '+'
         //This implementation will only honor implicit ordering for appending right to left else explicit order (/N) is required.
         //The results of this test differ from Logstash.
         assertMatch("%{+a} %{a} %{+a} %{b}", "December 31 1999 quux",

libs/ssl-config/src/main/java/org/elasticsearch/common/ssl/PemUtils.java

@@ -397,7 +397,7 @@ private static byte[] possiblyDecryptPKCS1Key(Map<String, String> pemHeaders, St
      * defined in RFC 1423. RFC 1423 only defines DES-CBS and triple DES (EDE) in CBC mode. AES in CBC mode is also widely used though ( 3
      * different variants of 128, 192, 256 bit keys )
      *
-     * @param dekHeaderValue The value of the the DEK-Info PEM header
+     * @param dekHeaderValue The value of the DEK-Info PEM header
      * @param password       The password with which the key is encrypted
      * @return a cipher of the appropriate algorithm and parameters to be used for decryption
      * @throws GeneralSecurityException if the algorithm is not available in the used security provider, or if the key is inappropriate

modules/ingest-common/src/main/java/org/elasticsearch/ingest/common/DateFormat.java

@@ -92,7 +92,7 @@ Function<String, ZonedDateTime> getFunction(String format, ZoneId zoneId, Locale
             int year = LocalDate.now(ZoneOffset.UTC).getYear();
             DateFormatter dateFormatter = DateFormatter.forPattern(format)
                 .withLocale(locale);
-            // if UTC zone is set here, the the time zone specified in the format will be ignored, leading to wrong dates
+            // if UTC zone is set here, the time zone specified in the format will be ignored, leading to wrong dates
             if (isUtc == false) {
                 dateFormatter = dateFormatter.withZone(zoneId);
             }

modules/rank-eval/src/main/java/org/elasticsearch/index/rankeval/RankEvalRequest.java

@@ -86,7 +86,7 @@ public RankEvalSpec getRankEvalSpec() {
     }
 
     /**
-     * Set the the specification of the ranking evaluation.
+     * Set the specification of the ranking evaluation.
      */
     public void setRankEvalSpec(RankEvalSpec task) {
         this.rankingEvaluationSpec = task;

server/src/main/java/org/elasticsearch/index/engine/SoftDeletesPolicy.java

@@ -120,7 +120,7 @@ synchronized long getMinRetainedSeqNo() {
              *    localCheckpointOfSafeCommit.
              *  - Changes APIs are driven by a combination of the global checkpoint, retention operations, and retention leases. Here we
              *    prefer using the global checkpoint instead of the maximum sequence number because only operations up to the global
-             *    checkpoint are exposed in the the changes APIs.
+             *    checkpoint are exposed in the changes APIs.
              */
 
             // calculate the minimum sequence number to retain based on retention leases

server/src/main/java/org/elasticsearch/index/mapper/Mapper.java

@@ -171,7 +171,7 @@ public final String simpleName() {
     public abstract String name();
 
     /**
-     * Returns a name representing the the type of this mapper.
+     * Returns a name representing the type of this mapper.
      */
     public abstract String typeName();
 

server/src/test/java/org/elasticsearch/persistent/PersistentTasksExecutorIT.java

@@ -162,7 +162,7 @@ public void testPersistentActionWithNoAvailableNode() throws Exception {
         TaskInfo taskInfo = client().admin().cluster().prepareListTasks().setActions(TestPersistentTasksExecutor.NAME + "[c]")
                 .get().getTasks().get(0);
 
-        // Verifying the the task runs on the new node
+        // Verifying the task runs on the new node
         assertThat(taskInfo.getTaskId().getNodeId(), equalTo(newNodeId));
 
         internalCluster().stopRandomNode(settings -> "test".equals(settings.get("node.attr.test_attr")));
@@ -202,7 +202,7 @@ public void testPersistentActionWithNonClusterStateCondition() throws Exception
         TaskInfo taskInfo = client().admin().cluster().prepareListTasks().setActions(TestPersistentTasksExecutor.NAME + "[c]")
             .get().getTasks().get(0);
 
-        // Verifying the the task can now be assigned
+        // Verifying the task can now be assigned
         assertThat(taskInfo.getTaskId().getNodeId(), notNullValue());
 
         // Remove the persistent task

server/src/test/java/org/elasticsearch/persistent/PersistentTasksNodeServiceTests.java

@@ -269,7 +269,7 @@ public void sendCompletionRequest(final String taskId, final long taskAllocation
         newClusterState = addTask(state, "test", null, "this_node");
         coordinator.clusterChanged(new ClusterChangedEvent("test", newClusterState, state));
 
-        // Check the the task is know to the task manager
+        // Check the task is know to the task manager
         assertThat(taskManager.getTasks().size(), equalTo(1));
         AllocatedPersistentTask runningTask = (AllocatedPersistentTask)taskManager.getTasks().values().iterator().next();
         String persistentId = runningTask.getPersistentTaskId();
@@ -305,7 +305,7 @@ public void sendCompletionRequest(final String taskId, final long taskAllocation
             executor.get(0).task.markAsFailed(new IOException("test"));
         }
 
-        // Check the the task is now removed from task manager
+        // Check the task is now removed from task manager
         assertThat(taskManager.getTasks().values(), empty());
     }
 

x-pack/docs/en/rest-api/watcher/execute-watch.asciidoc

@@ -99,7 +99,7 @@ are five possible modes an action can be associated with:
                       send it. In this mode, the action might be throttled if the
                       current state of the watch indicates it should be.
 
-| `force_simulate`  | Similar to the the `simulate` mode, except the action is
+| `force_simulate`  | Similar to the `simulate` mode, except the action is
                       not be throttled even if the current state of the watch
                       indicates it should be.
 

x-pack/docs/en/security/fips-140-compliance.asciidoc

@@ -89,7 +89,7 @@ the following table:
 
 {es} offers a number of algorithms for securely hashing credentials in memory and
 on disk. However, only the `PBKDF2` family of algorithms is compliant with FIPS
-140-2 for password hashing. You must set the the `cache.hash_algo` realm settings
+140-2 for password hashing. You must set the `cache.hash_algo` realm settings
 and the `xpack.security.authc.password_hashing.algorithm` setting to one of the
 available `PBKDF2` values.
 See <<hashing-settings>>.

x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/repository/CcrRepositoryRetentionLeaseTests.java

@@ -68,7 +68,7 @@ public void testWhenRetentionLeaseAlreadyExistsWeTryToRenewIt() {
         final String retentionLeaseId =
                 retentionLeaseId("local-cluster", followerShardId.getIndex(), "remote-cluster", leaderShardId.getIndex());
 
-        // simulate that the the retention lease already exists on the leader, and verify that we attempt to renew it
+        // simulate that the retention lease already exists on the leader, and verify that we attempt to renew it
         final Client remoteClient = mock(Client.class);
         final ArgumentCaptor<RetentionLeaseActions.AddRequest> addRequestCaptor =
                 ArgumentCaptor.forClass(RetentionLeaseActions.AddRequest.class);
@@ -133,7 +133,7 @@ public void testWhenRetentionLeaseExpiresBeforeWeCanRenewIt() {
         final String retentionLeaseId =
                 retentionLeaseId("local-cluster", followerShardId.getIndex(), "remote-cluster", leaderShardId.getIndex());
 
-        // simulate that the the retention lease already exists on the leader, expires before we renew, and verify that we attempt to add it
+        // simulate that the retention lease already exists on the leader, expires before we renew, and verify that we attempt to add it
         final Client remoteClient = mock(Client.class);
         final ArgumentCaptor<RetentionLeaseActions.AddRequest> addRequestCaptor =
                 ArgumentCaptor.forClass(RetentionLeaseActions.AddRequest.class);

x-pack/plugin/core/src/main/java/org/elasticsearch/snapshots/SourceOnlySnapshotRepository.java

@@ -45,7 +45,7 @@
  * <p>
  * This is a filter snapshot repository that only snapshots the minimal required information
  * that is needed to recreate the index. In other words instead of snapshotting the entire shard
- * with all it's lucene indexed fields, doc values, points etc. it only snapshots the the stored
+ * with all it's lucene indexed fields, doc values, points etc. it only snapshots the stored
  * fields including _source and _routing as well as the live docs in oder to distinguish between
  * live and deleted docs.
  * </p>

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/job/process/autodetect/state/DataCounts.java

@@ -24,7 +24,7 @@
  * Job processed record counts.
  * <p>
  * The getInput... methods return the actual number of
- * fields/records sent the the API including invalid records.
+ * fields/records sent the API including invalid records.
  * The getProcessed... methods are the number sent to the
  * Engine.
  * <p>

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/scheduler/SchedulerEngine.java

@@ -197,7 +197,7 @@ public void run() {
             } catch (final Throwable t) {
                 /*
                  * Allowing the throwable to escape here will lead to be it being caught in FutureTask#run and set as the outcome of this
-                 * task; however, we never inspect the the outcomes of these scheduled tasks and so allowing the throwable to escape
+                 * task; however, we never inspect the outcomes of these scheduled tasks and so allowing the throwable to escape
                  * unhandled here could lead to us losing fatal errors. Instead, we rely on ExceptionsHelper#maybeDieOnAnotherThread to
                  * appropriately dispatch any error to the uncaught exception handler. We should never see an exception here as these do
                  * not escape from SchedulerEngine#notifyListeners.

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/security/authz/permission/IndicesPermission.java

@@ -277,7 +277,7 @@ public static class Group {
         private final Set<BytesReference> query;
         // by default certain restricted indices are exempted when granting privileges, as they should generally be hidden for ordinary
         // users. Setting this flag true eliminates the special status for the purpose of this permission - restricted indices still have
-        // to be covered by the the "indices"
+        // to be covered by the "indices"
         private final boolean allowRestrictedIndices;
 
         public Group(IndexPrivilege privilege, FieldPermissions fieldPermissions, @Nullable Set<BytesReference> query,

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ssl/PemUtils.java

@@ -374,7 +374,7 @@ private static byte[] possiblyDecryptPKCS1Key(Map<String, String> pemHeaders, St
      * defined in RFC 1423. RFC 1423 only defines DES-CBS and triple DES (EDE) in CBC mode. AES in CBC mode is also widely used though ( 3
      * different variants of 128, 192, 256 bit keys )
      *
-     * @param dekHeaderValue The value of the the DEK-Info PEM header
+     * @param dekHeaderValue The value of the DEK-Info PEM header
      * @param password       The password with which the key is encrypted
      * @return a cipher of the appropriate algorithm and parameters to be used for decryption
      * @throws GeneralSecurityException if the algorithm is not available in the used security provider, or if the key is inappropriate

x-pack/plugin/ilm/qa/with-security/src/test/java/org/elasticsearch/xpack/security/PermissionsIT.java

@@ -87,7 +87,7 @@ public void init() throws Exception {
     /**
      * Tests that a policy that simply deletes an index after 0s succeeds when an index
      * with user `test_admin` is created referencing a policy created by `test_ilm` when both
-     * users have read/write permissions on the the index. The goal is to verify that one
+     * users have read/write permissions on the index. The goal is to verify that one
      * does not need to be the same user who created both the policy and the index to have the
      * index be properly managed by ILM.
      */

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/utils/TypedChainTaskExecutor.java

@@ -43,7 +43,7 @@ public interface ChainTask <T> {
      *                              {@code true} means continue on to the next task.
      *                              Must be able to handle null values.
      * @param failureShortCircuitPredicate The predicate on whether to short circuit execution on a give exception.
-     *                                     {@code true} means that no more tasks should execute and the the listener::onFailure should be
+     *                                     {@code true} means that no more tasks should execute and the listener::onFailure should be
      *                                     called.
      */
     public TypedChainTaskExecutor(ExecutorService executorService,

x-pack/plugin/monitoring/src/main/java/org/elasticsearch/xpack/monitoring/MonitoringService.java

@@ -233,7 +233,7 @@ protected void doRun() throws Exception {
                     final Collection<MonitoringDoc> results = new ArrayList<>();
                     for (Collector collector : collectors) {
                         if (isStarted() == false) {
-                            // Do not collect more data if the the monitoring service is stopping
+                            // Do not collect more data if the monitoring service is stopping
                             // otherwise some collectors might just fail.
                             return;
                         }

x-pack/plugin/monitoring/src/main/java/org/elasticsearch/xpack/monitoring/exporter/http/MultiHttpResource.java

@@ -19,7 +19,7 @@
  * <p>
  * By telling the {@code MultiHttpResource} to become dirty, it effectively marks all of its sub-resources dirty as well.
  * <p>
- * Sub-resources should be the sole responsibility of the the {@code MultiHttpResource}; there should not be something using them directly
+ * Sub-resources should be the sole responsibility of the {@code MultiHttpResource}; there should not be something using them directly
  * if they are included in a {@code MultiHttpResource}.
  */
 public class MultiHttpResource extends HttpResource {

x-pack/plugin/security/src/main/java/org/elasticsearch/xpack/security/authc/TokenService.java

@@ -349,7 +349,7 @@ public void getAuthenticationAndMetaData(String token, ActionListener<Tuple<Auth
     }
 
     /**
-     * Gets the UserToken with given id by fetching the the corresponding token document
+     * Gets the UserToken with given id by fetching the corresponding token document
      */
     void getUserTokenFromId(String userTokenId, ActionListener<UserToken> listener) {
         if (securityIndex.isAvailable() == false) {

x-pack/plugin/security/src/main/java/org/elasticsearch/xpack/security/support/SecurityIndexManager.java

@@ -73,7 +73,7 @@
 import static org.elasticsearch.xpack.core.ClientHelper.executeAsyncWithOrigin;
 
 /**
- * Manages the lifecycle of a single index, mapping and and data upgrades/migrations.
+ * Manages the lifecycle of a single index, mapping and data upgrades/migrations.
  */
 public class SecurityIndexManager implements ClusterStateListener {
 

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/transport/actions/get/TransportGetWatchAction.java

@@ -61,7 +61,7 @@ protected void doExecute(GetWatchRequest request, ActionListener<GetWatchRespons
                         try (XContentBuilder builder = jsonBuilder()) {
                             // When we return the watch via the Get Watch REST API, we want to return the watch as was specified in
                             // the put api, we don't include the status in the watch source itself, but as a separate top level field,
-                            // so that it indicates the the status is managed by watcher itself.
+                            // so that it indicates the status is managed by watcher itself.
                             ZonedDateTime now = clock.instant().atZone(ZoneOffset.UTC);
                             Watch watch = parser.parseWithSecrets(request.getId(), true, getResponse.getSourceAsBytesRef(), now,
                                     XContentType.JSON, getResponse.getSeqNo(), getResponse.getPrimaryTerm());

x-pack/plugin/watcher/src/test/java/org/elasticsearch/xpack/watcher/test/integration/HttpSecretsIntegrationTests.java

@@ -179,7 +179,7 @@ public void testWebhookAction() throws Exception {
                         .get();
 
         // verifying the basic auth password is stored encrypted in the index when security
-        // is enabled, when it's not enabled, the the passowrd should be stored in plain text
+        // is enabled, when it's not enabled, the password should be stored in plain text
         GetResponse response = client().prepareGet().setIndex(Watch.INDEX).setId("_id").get();
         assertThat(response, notNullValue());
         assertThat(response.getId(), is("_id"));