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/27 06:41:22 UTC
[3/3] 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/79423f80
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/79423f80
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/79423f80
Branch: refs/heads/master
Commit: 79423f8011ef35ae5c8509d67e0935fff549e80b
Parents: 1120629
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:40:03 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/79423f80/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) {