IGNITE-23901

* test fixed
apache · Jan 16, 2025 · 7080fc3 · 7080fc3
1 parent b7ff4f8
commit 7080fc3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/.../main/java/org/apache/ignite/internal/processors/performancestatistics/OperationType.java b/.../main/java/org/apache/ignite/internal/processors/performancestatistics/OperationType.java
@@ -21,7 +21,6 @@
 import java.util.EnumSet;
 import java.util.HashMap;
 import java.util.Map;
-import org.apache.ignite.internal.util.typedef.CA;
 import org.jetbrains.annotations.Nullable;
 
 /**

diff --git a/...ignite/internal/processors/performancestatistics/PerformanceStatisticsThinClientTest.java b/...ignite/internal/processors/performancestatistics/PerformanceStatisticsThinClientTest.java
@@ -177,9 +177,9 @@ public void testCacheOperation() throws Exception {
 
         checkCacheOperation(CACHE_GET_AND_REMOVE, cache -> cache.getAndRemove(5));
 
-        checkCacheOperation(CACHE_PUT_ALL_CONFLICT, cache -> putAllConflict(Collections.singletonMap(6, 1)));
+        checkCacheOperation(CACHE_PUT_ALL_CONFLICT, putAllConflict(Collections.singletonMap(6, 1)));
 
-        checkCacheOperation(CACHE_REMOVE_ALL_CONFLICT, cache -> removeAllConflict(Collections.singleton(6)));
+        checkCacheOperation(CACHE_REMOVE_ALL_CONFLICT, removeAllConflict(Collections.singleton(6)));
     }
 
     /** Checks cache operation. */
@@ -210,7 +210,6 @@ private void checkCacheOperation(OperationType op, Consumer<ClientCache<Object,
         assertEquals(1, ops.get());
     }
 
-
     /**
      * Cache {@link TcpClientCache#putAllConflict} operation perfomed
      * @param map {@link Map} with entries for cache put all.
@@ -221,7 +220,7 @@ private Consumer<ClientCache<Object, Object>> putAllConflict(Map<Integer, Object
 
         GridCacheVersion confl = new GridCacheVersion(1, 0, 1, (byte)2);
 
-        map.forEach((key, value) -> drMap.put(key, new T3<>(value, confl, null)));
+        map.forEach((key, value) -> drMap.put(key, new T3<>(value, confl, CU.EXPIRE_TIME_ETERNAL)));
 
         return cache -> ((TcpClientCache<Object, Object>)cache).putAllConflict(drMap);
     }