This is an automated email from the ASF dual-hosted git repository.

sergeychugunov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 07b680df185 IGNITE-28039 Remove dependency on BinaryObjectException in 
MetadataRemoveProposedMessage (#12844)
07b680df185 is described below

commit 07b680df18507663dc411d3ebc880f54c2f10655
Author: Dmitry Werner <[email protected]>
AuthorDate: Wed Mar 4 12:13:29 2026 +0500

    IGNITE-28039 Remove dependency on BinaryObjectException in 
MetadataRemoveProposedMessage (#12844)
---
 .../internal/processors/cache/binary/BinaryMetadataTransport.java  | 5 ++---
 .../processors/cache/binary/ClientMetadataRequestFuture.java       | 5 +----
 .../processors/cache/binary/MetadataRemoveProposedMessage.java     | 5 ++---
 .../internal/processors/cache/binary/MetadataUpdateResult.java     | 7 +++++++
 4 files changed, 12 insertions(+), 10 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataTransport.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataTransport.java
index efa12ad9c11..0cfb2d96768 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataTransport.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataTransport.java
@@ -384,8 +384,7 @@ final class BinaryMetadataTransport {
 
     /** */
     void onDisconnected() {
-        cancelFutures(MetadataUpdateResult.createFailureResult(
-                new BinaryObjectException("Failed to update or wait for 
metadata, client node disconnected")));
+        cancelFutures(MetadataUpdateResult.createFailureResult("Failed to 
update or wait for metadata, client node disconnected"));
     }
 
     /**
@@ -945,7 +944,7 @@ final class BinaryMetadataTransport {
 
             if (msg.rejected()) {
                 if (fut != null)
-                    
fut.onDone(MetadataUpdateResult.createFailureResult(msg.rejectionError()));
+                    
fut.onDone(MetadataUpdateResult.createFailureResult(msg.rejectionErrorMessage()));
             }
             else {
                 if (fut != null)
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/ClientMetadataRequestFuture.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/ClientMetadataRequestFuture.java
index d229e65dd1d..e22ebd9afa4 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/ClientMetadataRequestFuture.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/ClientMetadataRequestFuture.java
@@ -23,7 +23,6 @@ import java.util.UUID;
 import java.util.concurrent.atomic.AtomicReference;
 import org.apache.ignite.IgniteCheckedException;
 import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.binary.BinaryObjectException;
 import org.apache.ignite.cluster.ClusterNode;
 import org.apache.ignite.internal.GridKernalContext;
 import org.apache.ignite.internal.GridTopic;
@@ -124,9 +123,7 @@ final class ClientMetadataRequestFuture extends 
GridFutureAdapter<MetadataUpdate
 
         if (noSrvsInCluster)
             onDone(MetadataUpdateResult.createFailureResult(
-                    new BinaryObjectException(
-                            "All server nodes have left grid, cannot request 
metadata [typeId: "
-                                    + typeId + "]")));
+                "All server nodes have left grid, cannot request metadata 
[typeId: " + typeId + "]"));
     }
 
     /**
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
index d9da720d70e..57aacddd75f 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
@@ -18,7 +18,6 @@
 package org.apache.ignite.internal.processors.cache.binary;
 
 import java.util.UUID;
-import org.apache.ignite.binary.BinaryObjectException;
 import org.apache.ignite.internal.Order;
 import org.apache.ignite.internal.binary.BinaryMetadata;
 import org.apache.ignite.internal.managers.discovery.DiscoCache;
@@ -116,8 +115,8 @@ public final class MetadataRemoveProposedMessage implements 
DiscoveryCustomMessa
     }
 
     /** */
-    BinaryObjectException rejectionError() {
-        return new BinaryObjectException(errMsg);
+    String rejectionErrorMessage() {
+        return errMsg;
     }
 
     /** */
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateResult.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateResult.java
index f6d0d9de69a..f6f8a1796c6 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateResult.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateResult.java
@@ -68,6 +68,13 @@ final class MetadataUpdateResult {
         return new MetadataUpdateResult(ResultType.SUCCESS, null, typeVer);
     }
 
+    /**
+     * @param errMsg Error message lead to request failure.
+     */
+    static MetadataUpdateResult createFailureResult(String errMsg) {
+        return createFailureResult(new BinaryObjectException(errMsg));
+    }
+
     /**
      * @param err Error lead to request failure.
      */

Reply via email to