Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 ba8c1438e -> c9ec1e9d5
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/c9ec1e9d Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c9ec1e9d Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c9ec1e9d Branch: refs/heads/4.x-HBase-0.98 Commit: c9ec1e9d57131acaca390ffec14aad5e1afff08e Parents: ba8c143 Author: Ankit Singhal <ankitsingha...@gmail.com> Authored: Thu Sep 29 15:20:49 2016 +0530 Committer: Ankit Singhal <ankitsingha...@gmail.com> Committed: Thu Sep 29 15:20:49 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/c9ec1e9d/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(); } }
