You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2011/12/12 23:46:10 UTC
svn commit: r1213478 - in /hbase/branches/0.92: CHANGES.txt
src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java
Author: stack
Date: Mon Dec 12 22:46:10 2011
New Revision: 1213478
URL: http://svn.apache.org/viewvc?rev=1213478&view=rev
Log:
HBASE-4997 SplitLogManager can have a race on batch.installed
Modified:
hbase/branches/0.92/CHANGES.txt
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java
Modified: hbase/branches/0.92/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/CHANGES.txt?rev=1213478&r1=1213477&r2=1213478&view=diff
==============================================================================
--- hbase/branches/0.92/CHANGES.txt (original)
+++ hbase/branches/0.92/CHANGES.txt Mon Dec 12 22:46:10 2011
@@ -483,6 +483,7 @@ Release 0.92.0 - Unreleased
(Gaojinchao)
HBASE-4881 Unhealthy region is on service caused by rollback of region splitting
(Chunhui Shen)
+ HBASE-4997 SplitLogManager can have a race on batch.installed (Prakash Khemani)
TESTS
HBASE-4492 TestRollingRestart fails intermittently
Modified: hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java?rev=1213478&r1=1213477&r2=1213478&view=diff
==============================================================================
--- hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java (original)
+++ hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java Mon Dec 12 22:46:10 2011
@@ -343,9 +343,7 @@ public class SplitLogManager extends Zoo
} else {
task.batch.error++;
}
- if ((task.batch.done + task.batch.error) == task.batch.installed) {
- task.batch.notify();
- }
+ task.batch.notify();
}
}
}
@@ -599,9 +597,9 @@ public class SplitLogManager extends Zoo
// a single thread touches batch.installed.
oldtask = tasks.putIfAbsent(path, new Task(batch));
if (oldtask != null) {
+ // new task was not used.
+ batch.installed--;
synchronized (oldtask) {
- // new task was not used.
- batch.installed--;
if (oldtask.isOrphan()) {
if (oldtask.deleted) {
// The task is already done. Do not install the batch for this
@@ -610,12 +608,12 @@ public class SplitLogManager extends Zoo
// this task to complete.
return (null);
}
- LOG.info("Previously orphan task " + path +
- " is now being waited upon");
oldtask.setBatch(batch);
- return (null);
}
}
+ LOG.info("Previously orphan task " + path +
+ " is now being waited upon");
+ return (null);
}
return oldtask;
}