HBASE-22569 Should treat null consistency as Consistency.STRONG in ConnectionUtils.timelineConsistentRead
This commit is contained in:
parent
853e586d0f
commit
04a91f961e
|
@ -545,7 +545,7 @@ public final class ConnectionUtils {
|
||||||
TableName tableName, Query query, byte[] row, RegionLocateType locateType,
|
TableName tableName, Query query, byte[] row, RegionLocateType locateType,
|
||||||
Function<Integer, CompletableFuture<T>> requestReplica, long rpcTimeoutNs,
|
Function<Integer, CompletableFuture<T>> requestReplica, long rpcTimeoutNs,
|
||||||
long primaryCallTimeoutNs, Timer retryTimer, Optional<MetricsConnection> metrics) {
|
long primaryCallTimeoutNs, Timer retryTimer, Optional<MetricsConnection> metrics) {
|
||||||
if (query.getConsistency() == Consistency.STRONG) {
|
if (query.getConsistency() != Consistency.TIMELINE) {
|
||||||
return requestReplica.apply(RegionReplicaUtil.DEFAULT_REPLICA_ID);
|
return requestReplica.apply(RegionReplicaUtil.DEFAULT_REPLICA_ID);
|
||||||
}
|
}
|
||||||
// user specifies a replica id explicitly, just send request to the specific replica
|
// user specifies a replica id explicitly, just send request to the specific replica
|
||||||
|
|
Loading…
Reference in New Issue