phoenix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From an...@apache.org
Subject phoenix git commit: PHOENIX-3331 Bug in calculating minDisabledTimestamp for a batch
Date Thu, 29 Sep 2016 09:51:28 GMT
Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.2 e9c65009d -> 468ca2b93


PHOENIX-3331 Bug in calculating minDisabledTimestamp for a batch


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/468ca2b9
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/468ca2b9
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/468ca2b9

Branch: refs/heads/4.8-HBase-1.2
Commit: 468ca2b93de0a865216e017be0edfbe599ebe6f0
Parents: e9c65009
Author: Ankit Singhal <ankitsinghal59@gmail.com>
Authored: Thu Sep 29 15:21:21 2016 +0530
Committer: Ankit Singhal <ankitsinghal59@gmail.com>
Committed: Thu Sep 29 15:21:21 2016 +0530

----------------------------------------------------------------------
 .../java/org/apache/phoenix/index/PhoenixIndexFailurePolicy.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/phoenix/blob/468ca2b9/phoenix-core/src/main/java/org/apache/phoenix/index/PhoenixIndexFailurePolicy.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/index/PhoenixIndexFailurePolicy.java
b/phoenix-core/src/main/java/org/apache/phoenix/index/PhoenixIndexFailurePolicy.java
index c29d7b4..eb73d6b 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/index/PhoenixIndexFailurePolicy.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/index/PhoenixIndexFailurePolicy.java
@@ -129,7 +129,7 @@ public class PhoenixIndexFailurePolicy extends DelegateIndexFailurePolicy
{
                 for (Mutation m : mutations) {
                     for (List<Cell> kvs : m.getFamilyCellMap().values()) {
                         for (Cell kv : kvs) {
-                            if (minTimeStamp == 0 || (kv.getTimestamp() >= 0 &&
minTimeStamp < kv.getTimestamp())) {
+                            if (minTimeStamp == 0 || (kv.getTimestamp() >= 0 &&
minTimeStamp > kv.getTimestamp())) {
                                 minTimeStamp = kv.getTimestamp();
                             }
                         }


Mime
View raw message