[ignite-3] branch main updated: IGNITE-20527 Compilation fixed. (#2647)

[sanpwc]

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

sanpwc pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 6afdbab02a IGNITE-20527 Compilation fixed. (#2647)
6afdbab02a is described below

commit 6afdbab02a340548465893687109e7152c117265
Author: Alexander Lapin <lapin1...@gmail.com>
AuthorDate: Mon Oct 2 15:28:39 2023 +0300

    IGNITE-20527 Compilation fixed. (#2647)
---
 .../table/distributed/replicator/PartitionReplicaListener.java        | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
index 58d672f7ff..c1f667e0c4 100644
--- 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
+++ 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
@@ -59,7 +59,6 @@ import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.ConcurrentNavigableMap;
 import java.util.concurrent.ConcurrentSkipListMap;
 import java.util.concurrent.Executor;
-import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicReference;
@@ -1257,8 +1256,7 @@ public class PartitionReplicaListener implements 
ReplicaListener {
     }
 
     private CompletableFuture<String> findPrimaryReplica(TablePartitionId 
partitionId, HybridTimestamp now) {
-        return placementDriver.awaitPrimaryReplica(partitionId, now)
-                .orTimeout(AWAIT_PRIMARY_REPLICA_TIMEOUT, TimeUnit.SECONDS)
+        return placementDriver.awaitPrimaryReplica(partitionId, now, 
AWAIT_PRIMARY_REPLICA_TIMEOUT, SECONDS)
                 .handle((primaryReplica, e) -> {
                     if (e != null) {
                         LOG.error("Failed to retrieve primary replica for 
partition {}", partitionId, e);