You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ja...@apache.org on 2014/10/29 00:58:53 UTC
[08/24] git commit: PHOENIX-1379 Wrong
MultiIndexWriteFailureException when recovering local index table (Shunsuke
Nakamura)
PHOENIX-1379 Wrong MultiIndexWriteFailureException when recovering local index table (Shunsuke Nakamura)
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/351769c6
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/351769c6
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/351769c6
Branch: refs/heads/4.2
Commit: 351769c69e1d857fda48c2e8aec851384fcafb0e
Parents: 5093c2f
Author: James Taylor <jt...@salesforce.com>
Authored: Sun Oct 26 22:26:41 2014 -0700
Committer: James Taylor <jt...@salesforce.com>
Committed: Sun Oct 26 22:26:41 2014 -0700
----------------------------------------------------------------------
.../index/write/recovery/TrackingParallelWriterIndexCommitter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/351769c6/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
index 9a61191..9171b53 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
@@ -158,7 +158,7 @@ public class TrackingParallelWriterIndexCommitter implements IndexCommitter {
if (indexRegion != null) {
throwFailureIfDone();
indexRegion.batchMutate(mutations.toArray(new Mutation[mutations.size()]));
- return null;
+ return Boolean.TRUE;
}
}
} catch (IOException ignord) {