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:52:46 GMT
Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-0.98 3ce8e564e -> 54bc83839


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/54bc8383
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/54bc8383
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/54bc8383

Branch: refs/heads/4.8-HBase-0.98
Commit: 54bc83839c40f55f42915d66849bcab6d9e5e5fe
Parents: 3ce8e56
Author: Ankit Singhal <ankitsinghal59@gmail.com>
Authored: Thu Sep 29 15:22:38 2016 +0530
Committer: Ankit Singhal <ankitsinghal59@gmail.com>
Committed: Thu Sep 29 15:22:38 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/54bc8383/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