[Rename] refactor server/tasks package. (#265)

Refactor the server/tasks package to rename the package names from`org.elasticsearch.tasks` to `org.opensearch.tasks`. Signed-off-by: Rabi Panda <adnapibar@gmail.com>
opensearch-project · Mar 11, 2021 · 6261741 · 6261741
1 parent 45bc93a
commit 6261741
Show file tree

Hide file tree

Showing 218 changed files with 309 additions and 309 deletions.
diff --git a/...ugin/src/main/java/org/elasticsearch/plugin/noop/action/bulk/TransportNoopBulkAction.java b/...ugin/src/main/java/org/elasticsearch/plugin/noop/action/bulk/TransportNoopBulkAction.java
@@ -29,7 +29,7 @@
 import org.elasticsearch.action.update.UpdateResponse;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.index.shard.ShardId;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.elasticsearch.transport.TransportService;
 
 public class TransportNoopBulkAction extends HandledTransportAction<BulkRequest, BulkResponse> {

diff --git a/.../src/main/java/org/elasticsearch/plugin/noop/action/search/TransportNoopSearchAction.java b/.../src/main/java/org/elasticsearch/plugin/noop/action/search/TransportNoopSearchAction.java
@@ -33,7 +33,7 @@
 import org.elasticsearch.search.internal.InternalSearchResponse;
 import org.elasticsearch.search.profile.SearchProfileShardResults;
 import org.elasticsearch.search.suggest.Suggest;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.elasticsearch.transport.TransportService;
 
 import java.util.Collections;

diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/RequestConverters.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/RequestConverters.java
@@ -1105,14 +1105,14 @@ Params withActions(List<String> actions) {
             return this;
         }
 
-        Params withTaskId(org.elasticsearch.tasks.TaskId taskId) {
+        Params withTaskId(org.opensearch.tasks.TaskId taskId) {
             if (taskId != null && taskId.isSet()) {
                 return putParam("task_id", taskId.toString());
             }
             return this;
         }
 
-        Params withParentTaskId(org.elasticsearch.tasks.TaskId parentTaskId) {
+        Params withParentTaskId(org.opensearch.tasks.TaskId parentTaskId) {
             if (parentTaskId != null && parentTaskId.isSet()) {
                 return putParam("parent_task_id", parentTaskId.toString());
             }

diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/RethrottleRequest.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/RethrottleRequest.java
@@ -19,7 +19,7 @@
 
 package org.elasticsearch.client;
 
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.TaskId;
 
 import java.util.Objects;
 
@@ -74,4 +74,4 @@ public float getRequestsPerSecond() {
     public String toString() {
         return "RethrottleRequest: taskID = " + taskId +"; reqestsPerSecond = " + requestsPerSecond;
     }
-}
+}
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/tasks/GetTaskResponse.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/tasks/GetTaskResponse.java
@@ -21,7 +21,7 @@
 import org.elasticsearch.common.ParseField;
 import org.elasticsearch.common.xcontent.ConstructingObjectParser;
 import org.elasticsearch.common.xcontent.XContentParser;
-import org.elasticsearch.tasks.TaskInfo;
+import org.opensearch.tasks.TaskInfo;
 
 import static org.elasticsearch.common.xcontent.ConstructingObjectParser.constructorArg;
 

diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/tasks/TaskId.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/tasks/TaskId.java
@@ -21,7 +21,7 @@
 import java.util.Objects;
 
 /**
- * client side version of a {@link org.elasticsearch.tasks.TaskId}
+ * client side version of a {@link org.opensearch.tasks.TaskId}
  */
 public class TaskId {
 

diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/tasks/TaskInfo.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/tasks/TaskInfo.java
@@ -29,7 +29,7 @@
 /**
  * client side counterpart of server side
  * <p>
- * {@link org.elasticsearch.tasks.TaskInfo}
+ * {@link org.opensearch.tasks.TaskInfo}
  */
 public class TaskInfo {
 

diff --git a/...rest-high-level/src/test/java/org/elasticsearch/client/ESRestHighLevelClientTestCase.java b/...rest-high-level/src/test/java/org/elasticsearch/client/ESRestHighLevelClientTestCase.java
@@ -46,7 +46,7 @@
 import org.elasticsearch.ingest.Pipeline;
 import org.elasticsearch.search.SearchHit;
 import org.elasticsearch.search.SearchModule;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.TaskId;
 import org.elasticsearch.test.rest.ESRestTestCase;
 import org.junit.AfterClass;
 import org.junit.Before;

diff --git a/client/rest-high-level/src/test/java/org/elasticsearch/client/ReindexIT.java b/client/rest-high-level/src/test/java/org/elasticsearch/client/ReindexIT.java
@@ -35,8 +35,8 @@
 import org.elasticsearch.index.reindex.DeleteByQueryRequest;
 import org.elasticsearch.index.reindex.ReindexRequest;
 import org.opensearch.rest.RestStatus;
-import org.elasticsearch.tasks.RawTaskStatus;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.RawTaskStatus;
+import org.opensearch.tasks.TaskId;
 
 import java.io.IOException;
 import java.util.Collections;

diff --git a/client/rest-high-level/src/test/java/org/elasticsearch/client/RequestConvertersTests.java b/client/rest-high-level/src/test/java/org/elasticsearch/client/RequestConvertersTests.java
@@ -102,7 +102,7 @@
 import org.elasticsearch.search.rescore.QueryRescorerBuilder;
 import org.elasticsearch.search.suggest.SuggestBuilder;
 import org.elasticsearch.search.suggest.completion.CompletionSuggestionBuilder;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.TaskId;
 import org.elasticsearch.test.ESTestCase;
 import org.elasticsearch.test.RandomObjects;
 import org.hamcrest.Matchers;

diff --git a/client/rest-high-level/src/test/java/org/elasticsearch/client/TasksIT.java b/client/rest-high-level/src/test/java/org/elasticsearch/client/TasksIT.java
@@ -58,12 +58,12 @@ public void testListTasks() throws IOException {
         assertThat(response.getTasks().size(), greaterThanOrEqualTo(2));
         boolean listTasksFound = false;
         for (TaskGroup taskGroup : response.getTaskGroups()) {
-            org.elasticsearch.tasks.TaskInfo parent = taskGroup.getTaskInfo();
+            org.opensearch.tasks.TaskInfo parent = taskGroup.getTaskInfo();
             if ("cluster:monitor/tasks/lists".equals(parent.getAction())) {
                 assertThat(taskGroup.getChildTasks().size(), equalTo(1));
                 TaskGroup childGroup = taskGroup.getChildTasks().iterator().next();
                 assertThat(childGroup.getChildTasks().isEmpty(), equalTo(true));
-                org.elasticsearch.tasks.TaskInfo child = childGroup.getTaskInfo();
+                org.opensearch.tasks.TaskInfo child = childGroup.getTaskInfo();
                 assertThat(child.getAction(), equalTo("cluster:monitor/tasks/lists[n]"));
                 assertThat(child.getParentTaskId(), equalTo(parent.getTaskId()));
                 listTasksFound = true;
@@ -101,7 +101,7 @@ public void testGetValidTask() throws Exception {
         if (gtr.getWaitForCompletion()) {
             assertTrue(taskResponse.isCompleted());
         }
-        org.elasticsearch.tasks.TaskInfo info = taskResponse.getTaskInfo();
+        org.opensearch.tasks.TaskInfo info = taskResponse.getTaskInfo();
         assertTrue(info.isCancellable());
         assertEquals("reindex from [source1] to [dest][_doc]", info.getDescription());
         assertEquals("indices:data/write/reindex", info.getAction());
@@ -126,7 +126,7 @@ public void testCancelTasks() throws IOException {
         );
         // in this case, probably no task will actually be cancelled.
         // this is ok, that case is covered in TasksIT.testTasksCancellation
-        org.elasticsearch.tasks.TaskInfo firstTask = listResponse.getTasks().get(0);
+        org.opensearch.tasks.TaskInfo firstTask = listResponse.getTasks().get(0);
         String node = listResponse.getPerNodeTasks().keySet().iterator().next();
 
         CancelTasksRequest cancelTasksRequest =  new CancelTasksRequest.Builder().withTaskId(

diff --git a/...t/rest-high-level/src/test/java/org/elasticsearch/client/TasksRequestConvertersTests.java b/...t/rest-high-level/src/test/java/org/elasticsearch/client/TasksRequestConvertersTests.java
@@ -23,7 +23,7 @@
 import org.apache.http.client.methods.HttpPost;
 import org.opensearch.action.admin.cluster.node.tasks.list.ListTasksRequest;
 import org.elasticsearch.client.tasks.CancelTasksRequest;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.TaskId;
 import org.elasticsearch.test.ESTestCase;
 
 import java.util.HashMap;

diff --git a/client/rest-high-level/src/test/java/org/elasticsearch/client/UpdateByQueryIT.java b/client/rest-high-level/src/test/java/org/elasticsearch/client/UpdateByQueryIT.java
@@ -35,8 +35,8 @@
 import org.elasticsearch.index.reindex.UpdateByQueryRequest;
 import org.opensearch.rest.RestStatus;
 import org.elasticsearch.script.Script;
-import org.elasticsearch.tasks.RawTaskStatus;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.RawTaskStatus;
+import org.opensearch.tasks.TaskId;
 
 import java.io.IOException;
 import java.util.Collections;

diff --git a/...st-high-level/src/test/java/org/elasticsearch/client/core/tasks/GetTaskResponseTests.java b/...st-high-level/src/test/java/org/elasticsearch/client/core/tasks/GetTaskResponseTests.java
@@ -24,10 +24,10 @@
 import org.elasticsearch.common.bytes.BytesReference;
 import org.elasticsearch.common.xcontent.ToXContent;
 import org.elasticsearch.common.xcontent.XContentBuilder;
-import org.elasticsearch.tasks.RawTaskStatus;
-import org.elasticsearch.tasks.Task;
-import org.elasticsearch.tasks.TaskId;
-import org.elasticsearch.tasks.TaskInfo;
+import org.opensearch.tasks.RawTaskStatus;
+import org.opensearch.tasks.Task;
+import org.opensearch.tasks.TaskId;
+import org.opensearch.tasks.TaskInfo;
 import org.elasticsearch.test.ESTestCase;
 
 import java.io.IOException;
@@ -70,7 +70,7 @@ private void assertEqualInstances(GetTaskResponse expectedInstance, GetTaskRespo
         assertEquals(expectedInstance.isCompleted(), newInstance.isCompleted());
         assertEquals(expectedInstance.getTaskInfo(), newInstance.getTaskInfo());
     }
-    
+
     static TaskInfo randomTaskInfo() {
         TaskId taskId = randomTaskId();
         String type = randomAlphaOfLength(5);
@@ -103,5 +103,5 @@ private static RawTaskStatus randomRawTaskStatus() {
         } catch (IOException e) {
             throw new IllegalStateException(e);
         }
-    }    
+    }
 }
diff --git a/...-high-level/src/test/java/org/elasticsearch/client/documentation/CRUDDocumentationIT.java b/...-high-level/src/test/java/org/elasticsearch/client/documentation/CRUDDocumentationIT.java
@@ -85,7 +85,7 @@
 import org.elasticsearch.script.Script;
 import org.elasticsearch.script.ScriptType;
 import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.TaskId;
 
 import java.util.Collections;
 import java.util.Date;

diff --git a/...evel/src/test/java/org/elasticsearch/client/documentation/TasksClientDocumentationIT.java b/...evel/src/test/java/org/elasticsearch/client/documentation/TasksClientDocumentationIT.java
@@ -32,8 +32,8 @@
 import org.elasticsearch.client.tasks.CancelTasksRequest;
 import org.elasticsearch.client.tasks.CancelTasksResponse;
 import org.elasticsearch.common.unit.TimeValue;
-import org.elasticsearch.tasks.TaskId;
-import org.elasticsearch.tasks.TaskInfo;
+import org.opensearch.tasks.TaskId;
+import org.opensearch.tasks.TaskInfo;
 
 import java.io.IOException;
 import java.util.Arrays;

diff --git a/...est-high-level/src/test/java/org/elasticsearch/client/tasks/CancelTasksResponseTests.java b/...est-high-level/src/test/java/org/elasticsearch/client/tasks/CancelTasksResponseTests.java
@@ -31,9 +31,9 @@
 import org.elasticsearch.common.xcontent.XContentBuilder;
 import org.elasticsearch.common.xcontent.XContentParser;
 import org.elasticsearch.common.xcontent.XContentType;
-import org.elasticsearch.tasks.Task;
-import org.elasticsearch.tasks.TaskId;
-import org.elasticsearch.tasks.TaskInfo;
+import org.opensearch.tasks.Task;
+import org.opensearch.tasks.TaskId;
+import org.opensearch.tasks.TaskInfo;
 
 import java.io.IOException;
 import java.net.InetAddress;
@@ -56,7 +56,7 @@ public class CancelTasksResponseTests extends AbstractResponseTestCase<CancelTas
 
     @Override
     protected CancelTasksResponseTests.ByNodeCancelTasksResponse createServerTestInstance(XContentType xContentType) {
-        List<org.elasticsearch.tasks.TaskInfo> tasks = new ArrayList<>();
+        List<org.opensearch.tasks.TaskInfo> tasks = new ArrayList<>();
         List<TaskOperationFailure> taskFailures = new ArrayList<>();
         List<OpenSearchException> nodeFailures = new ArrayList<>();
 
@@ -69,7 +69,7 @@ protected CancelTasksResponseTests.ByNodeCancelTasksResponse createServerTestIns
         }
 
         for (int i = 0; i < 4; i++) {
-            tasks.add(new org.elasticsearch.tasks.TaskInfo(
+            tasks.add(new org.opensearch.tasks.TaskInfo(
                 new TaskId(NODE_ID, (long) i),
                 randomAlphaOfLength(4),
                 randomAlphaOfLength(4),

diff --git a/modules/ingest-common/src/main/java/org/opensearch/ingest/common/GrokProcessorGetAction.java b/modules/ingest-common/src/main/java/org/opensearch/ingest/common/GrokProcessorGetAction.java
@@ -36,7 +36,7 @@
 import org.opensearch.rest.BaseRestHandler;
 import org.opensearch.rest.RestRequest;
 import org.opensearch.rest.action.RestToXContentListener;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.elasticsearch.transport.TransportService;
 
 import java.io.IOException;

diff --git a/...ache/src/main/java/org/opensearch/script/mustache/TransportMultiSearchTemplateAction.java b/...ache/src/main/java/org/opensearch/script/mustache/TransportMultiSearchTemplateAction.java
@@ -29,7 +29,7 @@
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.xcontent.NamedXContentRegistry;
 import org.elasticsearch.script.ScriptService;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.elasticsearch.transport.TransportService;
 
 import java.util.ArrayList;

diff --git a/...-mustache/src/main/java/org/opensearch/script/mustache/TransportSearchTemplateAction.java b/...-mustache/src/main/java/org/opensearch/script/mustache/TransportSearchTemplateAction.java
@@ -39,7 +39,7 @@
 import org.elasticsearch.script.TemplateScript;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.elasticsearch.search.internal.SearchContext;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.elasticsearch.transport.TransportService;
 
 import java.io.IOException;

diff --git a/...les/lang-painless/src/main/java/org/opensearch/painless/action/PainlessContextAction.java b/...les/lang-painless/src/main/java/org/opensearch/painless/action/PainlessContextAction.java
@@ -40,7 +40,7 @@
 import org.opensearch.rest.RestRequest;
 import org.opensearch.rest.action.RestToXContentListener;
 import org.elasticsearch.script.ScriptContext;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.elasticsearch.transport.TransportService;
 
 import java.io.IOException;

diff --git a/modules/rank-eval/src/main/java/org/opensearch/index/rankeval/TransportRankEvalAction.java b/modules/rank-eval/src/main/java/org/opensearch/index/rankeval/TransportRankEvalAction.java
@@ -39,7 +39,7 @@
 import org.elasticsearch.script.TemplateScript;
 import org.elasticsearch.search.SearchHit;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.elasticsearch.transport.TransportService;
 
 import java.io.IOException;

diff --git a/.../internalClusterTest/java/org/opensearch/client/documentation/ReindexDocumentationIT.java b/.../internalClusterTest/java/org/opensearch/client/documentation/ReindexDocumentationIT.java
@@ -45,8 +45,8 @@
 import org.elasticsearch.script.Script;
 import org.elasticsearch.script.ScriptType;
 import org.elasticsearch.search.sort.SortOrder;
-import org.elasticsearch.tasks.TaskId;
-import org.elasticsearch.tasks.TaskInfo;
+import org.opensearch.tasks.TaskId;
+import org.opensearch.tasks.TaskInfo;
 import org.elasticsearch.test.ESIntegTestCase;
 import org.hamcrest.Matcher;
 import org.junit.Before;

diff --git a/...es/reindex/src/main/java/org/opensearch/index/reindex/AbstractBaseReindexRestHandler.java b/...es/reindex/src/main/java/org/opensearch/index/reindex/AbstractBaseReindexRestHandler.java
@@ -29,8 +29,8 @@
 import org.opensearch.rest.BytesRestResponse;
 import org.opensearch.rest.RestRequest;
 import org.opensearch.rest.RestStatus;
-import org.elasticsearch.tasks.LoggingTaskListener;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.LoggingTaskListener;
+import org.opensearch.tasks.Task;
 
 import java.io.IOException;
 import java.util.HashMap;

diff --git a/...reindex/src/main/java/org/opensearch/index/reindex/BulkByScrollParallelizationHelper.java b/...reindex/src/main/java/org/opensearch/index/reindex/BulkByScrollParallelizationHelper.java
@@ -34,7 +34,7 @@
 import org.elasticsearch.index.reindex.LeaderBulkByScrollTaskState;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.elasticsearch.search.slice.SliceBuilder;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.TaskId;
 
 import java.util.Arrays;
 import java.util.Collections;

diff --git a/modules/reindex/src/main/java/org/opensearch/index/reindex/ReindexPlugin.java b/modules/reindex/src/main/java/org/opensearch/index/reindex/ReindexPlugin.java
@@ -44,7 +44,7 @@
 import org.opensearch.rest.RestController;
 import org.opensearch.rest.RestHandler;
 import org.elasticsearch.script.ScriptService;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.elasticsearch.watcher.ResourceWatcherService;
 

diff --git a/modules/reindex/src/main/java/org/opensearch/index/reindex/RestRethrottleAction.java b/modules/reindex/src/main/java/org/opensearch/index/reindex/RestRethrottleAction.java
@@ -23,7 +23,7 @@
 import org.elasticsearch.cluster.node.DiscoveryNodes;
 import org.opensearch.rest.BaseRestHandler;
 import org.opensearch.rest.RestRequest;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.TaskId;
 
 import java.util.List;
 import java.util.function.Supplier;

diff --git a/modules/reindex/src/main/java/org/opensearch/index/reindex/TransportDeleteByQueryAction.java b/modules/reindex/src/main/java/org/opensearch/index/reindex/TransportDeleteByQueryAction.java
@@ -32,7 +32,7 @@
 import org.elasticsearch.index.reindex.DeleteByQueryAction;
 import org.elasticsearch.index.reindex.DeleteByQueryRequest;
 import org.elasticsearch.script.ScriptService;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 

diff --git a/modules/reindex/src/main/java/org/opensearch/index/reindex/TransportReindexAction.java b/modules/reindex/src/main/java/org/opensearch/index/reindex/TransportReindexAction.java
@@ -35,7 +35,7 @@
 import org.elasticsearch.index.reindex.ReindexAction;
 import org.elasticsearch.index.reindex.ReindexRequest;
 import org.elasticsearch.script.ScriptService;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 

diff --git a/modules/reindex/src/main/java/org/opensearch/index/reindex/TransportUpdateByQueryAction.java b/modules/reindex/src/main/java/org/opensearch/index/reindex/TransportUpdateByQueryAction.java
@@ -43,7 +43,7 @@
 import org.elasticsearch.index.reindex.WorkerBulkByScrollTaskState;
 import org.elasticsearch.script.Script;
 import org.elasticsearch.script.ScriptService;
-import org.elasticsearch.tasks.Task;
+import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportService;
 

diff --git a/modules/reindex/src/test/java/org/opensearch/index/reindex/AsyncBulkByScrollActionTests.java b/modules/reindex/src/test/java/org/opensearch/index/reindex/AsyncBulkByScrollActionTests.java
@@ -80,9 +80,9 @@
 import org.elasticsearch.search.SearchHit;
 import org.elasticsearch.search.SearchHits;
 import org.elasticsearch.search.internal.InternalSearchResponse;
-import org.elasticsearch.tasks.Task;
-import org.elasticsearch.tasks.TaskId;
-import org.elasticsearch.tasks.TaskManager;
+import org.opensearch.tasks.Task;
+import org.opensearch.tasks.TaskId;
+import org.opensearch.tasks.TaskManager;
 import org.elasticsearch.test.ESTestCase;
 import org.elasticsearch.test.client.NoOpClient;
 import org.opensearch.threadpool.TestThreadPool;

diff --git a/modules/reindex/src/test/java/org/opensearch/index/reindex/CancelTests.java b/modules/reindex/src/test/java/org/opensearch/index/reindex/CancelTests.java
@@ -43,8 +43,8 @@
 import org.elasticsearch.index.shard.ShardId;
 import org.elasticsearch.ingest.IngestTestPlugin;
 import org.elasticsearch.plugins.Plugin;
-import org.elasticsearch.tasks.TaskCancelledException;
-import org.elasticsearch.tasks.TaskInfo;
+import org.opensearch.tasks.TaskCancelledException;
+import org.opensearch.tasks.TaskInfo;
 import org.hamcrest.Matcher;
 import org.junit.Before;
 

diff --git a/...es/reindex/src/test/java/org/opensearch/index/reindex/ClientScrollableHitSourceTests.java b/...es/reindex/src/test/java/org/opensearch/index/reindex/ClientScrollableHitSourceTests.java
@@ -42,7 +42,7 @@
 import org.elasticsearch.search.SearchHit;
 import org.elasticsearch.search.SearchHits;
 import org.elasticsearch.search.internal.InternalSearchResponse;
-import org.elasticsearch.tasks.TaskId;
+import org.opensearch.tasks.TaskId;
 import org.elasticsearch.test.ESTestCase;
 import org.opensearch.threadpool.TestThreadPool;
 import org.opensearch.threadpool.ThreadPool;