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 <jtay...@salesforce.com>
Authored: Sun Oct 26 22:26:41 2014 -0700
Committer: James Taylor <jtay...@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) {

Reply via email to