This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new 04a91f9 HBASE-22569 Should treat null consistency as
Consistency.STRONG in ConnectionUtils.timelineConsistentRead
04a91f9 is described below
commit 04a91f961e3d7641f25914be4c9f3c5e3c1e1e8f
Author: Duo Zhang <[email protected]>
AuthorDate: Wed Jun 12 10:50:44 2019 +0800
HBASE-22569 Should treat null consistency as Consistency.STRONG in
ConnectionUtils.timelineConsistentRead
---
.../src/main/java/org/apache/hadoop/hbase/client/ConnectionUtils.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 4a2fa3a..cad0c65 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<Integer, CompletableFuture<T>> requestReplica, long
rpcTimeoutNs,
long primaryCallTimeoutNs, Timer retryTimer, Optional<MetricsConnection>
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