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.
*/