Skip to content

Commit d47c1d9

Browse files
committed
IGNITE-26827 Minor refactoring after ErrorMessage updates
1 parent 5cabe53 commit d47c1d9

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import org.apache.ignite.internal.IgniteInternalFuture;
3030
import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException;
3131
import org.apache.ignite.internal.cluster.ClusterTopologyServerNotFoundException;
32-
import org.apache.ignite.internal.managers.communication.ErrorMessage;
3332
import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
3433
import org.apache.ignite.internal.processors.cache.CacheEntryPredicate;
3534
import org.apache.ignite.internal.processors.cache.CacheObject;
@@ -207,7 +206,7 @@ else if (rcvAll)
207206
UpdateErrors errors = res.errors();
208207

209208
if (errors != null) {
210-
assert ErrorMessage.error(errors.errorMessage()) != null;
209+
assert errors.error() != null;
211210

212211
completeFuture(null, errors.error(), res.futureId());
213212

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@
3333
import org.apache.ignite.internal.IgniteInternalFuture;
3434
import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException;
3535
import org.apache.ignite.internal.cluster.ClusterTopologyServerNotFoundException;
36-
import org.apache.ignite.internal.managers.communication.ErrorMessage;
3736
import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
3837
import org.apache.ignite.internal.processors.cache.CacheEntryPredicate;
3938
import org.apache.ignite.internal.processors.cache.CacheObject;
@@ -333,7 +332,7 @@ else if (rcvAll)
333332
UpdateErrors errors = res.errors();
334333

335334
if (errors != null) {
336-
assert ErrorMessage.error(errors.errorMessage()) != null;
335+
assert errors.error() != null;
337336

338337
completeFuture(null, errors.error(), res.futureId());
339338

0 commit comments

Comments
 (0)