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.0
Commit: 351769c69e1d857fda48c2e8aec851384fcafb0e
Parents: 5093c2f
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: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) {

Reply via email to