Address review comment: rename exception

Author: pawankartik-elastic

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

@@ -16,7 +16,7 @@
 import org.apache.lucene.store.LockObtainFailedException;
 import org.elasticsearch.action.bulk.IndexDocFailureStoreStatus;
 import org.elasticsearch.action.support.replication.ReplicationOperation;
-import org.elasticsearch.cluster.RemoteComputeException;
+import org.elasticsearch.cluster.RemoteException;
 import org.elasticsearch.cluster.action.shard.ShardStateAction;
 import org.elasticsearch.common.io.stream.NotSerializableExceptionWrapper;
 import org.elasticsearch.common.io.stream.StreamInput;
@@ -1984,8 +1984,8 @@ private enum ElasticsearchExceptionHandle {
             TransportVersions.V_8_16_0
         ),
         REMOTE_COMPUTE_EXCEPTION(
-            RemoteComputeException.class,
-            RemoteComputeException::new,
+            RemoteException.class,
+            RemoteException::new,
             184,
             TransportVersions.REMOTE_COMPUTE_EXCEPTION
         );

server/src/main/java/org/elasticsearch/cluster/RemoteComputeException.java renamed to server/src/main/java/org/elasticsearch/cluster/RemoteException.java

@@ -21,18 +21,18 @@
  * Represents an error that occurred on a remote node.
  * It allows capturing some context such as the cluster alias that encountered the error.
  */
-public class RemoteComputeException extends ElasticsearchException {
+public class RemoteException extends ElasticsearchException {
 
     /**
      * @param clusterAlias Name of the cluster.
      * @param cause Error that was encountered.
      */
-    public RemoteComputeException(String clusterAlias, Throwable cause) {
+    public RemoteException(String clusterAlias, Throwable cause) {
         super("Remote [" + clusterAlias + "] encountered an error", cause);
         Objects.requireNonNull(cause);
     }
 
-    public RemoteComputeException(StreamInput in) throws IOException {
+    public RemoteException(StreamInput in) throws IOException {
         super(in);
     }
 

server/src/test/java/org/elasticsearch/ExceptionSerializationTests.java

@@ -21,7 +21,7 @@
 import org.elasticsearch.action.search.ShardSearchFailure;
 import org.elasticsearch.action.support.replication.ReplicationOperation;
 import org.elasticsearch.client.internal.AbstractClientHeadersTestCase;
-import org.elasticsearch.cluster.RemoteComputeException;
+import org.elasticsearch.cluster.RemoteException;
 import org.elasticsearch.cluster.action.shard.ShardStateAction;
 import org.elasticsearch.cluster.block.ClusterBlockException;
 import org.elasticsearch.cluster.coordination.CoordinationStateRejectedException;
@@ -841,7 +841,7 @@ public void testIds() {
         ids.put(181, ResourceAlreadyUploadedException.class);
         ids.put(182, IngestPipelineException.class);
         ids.put(183, IndexDocFailureStoreStatus.ExceptionWithFailureStoreStatus.class);
-        ids.put(184, RemoteComputeException.class);
+        ids.put(184, RemoteException.class);
 
         Map<Class<? extends ElasticsearchException>, Integer> reverse = new HashMap<>();
         for (Map.Entry<Integer, Class<? extends ElasticsearchException>> entry : ids.entrySet()) {

x-pack/plugin/esql/qa/testFixtures/src/main/java/org/elasticsearch/xpack/esql/EsqlTestUtils.java

@@ -11,7 +11,7 @@
 import org.apache.lucene.sandbox.document.HalfFloatPoint;
 import org.apache.lucene.util.BytesRef;
 import org.elasticsearch.ExceptionsHelper;
-import org.elasticsearch.cluster.RemoteComputeException;
+import org.elasticsearch.cluster.RemoteException;
 import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.Strings;
@@ -867,7 +867,7 @@ public static <T> T singleValue(Collection<T> collection) {
      * @return Cause of RemoteComputeException, else the error itself.
      */
     public static Exception unwrapIfWrappedInRemoteComputeException(Exception e) {
-        if (e instanceof RemoteComputeException rce) {
+        if (e instanceof RemoteException rce) {
             return (Exception) rce.getCause();
         } else {
             return e;

x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/EsqlRemoteErrorWrapIT.java

@@ -7,7 +7,7 @@
 
 package org.elasticsearch.xpack.esql.action;
 
-import org.elasticsearch.cluster.RemoteComputeException;
+import org.elasticsearch.cluster.RemoteException;
 import org.elasticsearch.compute.operator.exchange.ExchangeService;
 import org.elasticsearch.test.transport.MockTransportService;
 import org.elasticsearch.transport.TransportService;
@@ -34,8 +34,8 @@ public void testThatRemoteErrorsAreWrapped() throws Exception {
             );
         }
 
-        RemoteComputeException wrappedError = expectThrows(
-            RemoteComputeException.class,
+        RemoteException wrappedError = expectThrows(
+            RemoteException.class,
             () -> runQuery("FROM " + REMOTE_CLUSTER_1 + ":*," + REMOTE_CLUSTER_2 + ":* | LIMIT 100", false)
         );
         assertThat(wrappedError.getMessage(), is("Remote [cluster-a] encountered an error"));

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeService.java

@@ -11,7 +11,7 @@
 import org.elasticsearch.action.OriginalIndices;
 import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.ShardSearchFailure;
-import org.elasticsearch.cluster.RemoteComputeException;
+import org.elasticsearch.cluster.RemoteException;
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.util.BigArrays;
 import org.elasticsearch.common.util.concurrent.RunOnce;
@@ -352,11 +352,9 @@ public void execute(
                              * wrapped.
                              */
                             if (ex instanceof TransportException te) {
-                                l.onFailure(
-                                    new RemoteComputeException(cluster.clusterAlias(), FailureCollector.unwrapTransportException(te))
-                                );
+                                l.onFailure(new RemoteException(cluster.clusterAlias(), FailureCollector.unwrapTransportException(te)));
                             } else {
-                                l.onFailure(new RemoteComputeException(cluster.clusterAlias(), ex));
+                                l.onFailure(new RemoteException(cluster.clusterAlias(), ex));
                             }
                         })
                     );