diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java index 4a2fa3a9b55..cad0c65516d 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java @@ -545,7 +545,7 @@ public final class ConnectionUtils { TableName tableName, Query query, byte[] row, RegionLocateType locateType, Function> requestReplica, long rpcTimeoutNs, long primaryCallTimeoutNs, Timer retryTimer, Optional metrics) { - if (query.getConsistency() == Consistency.STRONG) { + if (query.getConsistency() != Consistency.TIMELINE) { return requestReplica.apply(RegionReplicaUtil.DEFAULT_REPLICA_ID); } // user specifies a replica id explicitly, just send request to the specific replica