Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-3065 adding a missing removeMetaData in SplitLogWorker.java 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1153294 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jean-Daniel Cryans 2011-08-02 22:35:53 +00:00
parent af2059f439
commit c75e396fb6
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/org/apache/hadoop/hbase/regionserver/SplitLogWorker.java
View File

@ -537,6 +537,7 @@ public class SplitLogWorker extends ZooKeeperListener implements Runnable {
getDataSetWatchFailure(path); getDataSetWatchFailure(path);
return; return;
} }
data = watcher.getRecoverableZooKeeper().removeMetaData(data);
getDataSetWatchSuccess(path, data); getDataSetWatchSuccess(path, data);
return; return;
} }

10
src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java
View File

@ -207,7 +207,7 @@ public class TestMultiParallel {
doTestFlushCommits(true); doTestFlushCommits(true);
} }
@Test (timeout=300000) @Test (timeout=300000)
public void testFlushCommitsNoAbort() throws Exception { public void testFlushCommitsNoAbort() throws Exception {
LOG.info("test=testFlushCommitsNoAbort"); LOG.info("test=testFlushCommitsNoAbort");
doTestFlushCommits(false); doTestFlushCommits(false);
@ -261,7 +261,7 @@ public class TestMultiParallel {
LOG.info("done"); LOG.info("done");
} }
@Test (timeout=300000) @Test (timeout=300000)
public void testBatchWithPut() throws Exception { public void testBatchWithPut() throws Exception {
LOG.info("test=testBatchWithPut"); LOG.info("test=testBatchWithPut");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE); HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
@ -312,7 +312,7 @@ public class TestMultiParallel {
} }
@Test(timeout=300000) @Test(timeout=300000)
public void testHTableDeleteWithList() throws Exception { public void testHTableDeleteWithList() throws Exception {
LOG.info("test=testHTableDeleteWithList"); LOG.info("test=testHTableDeleteWithList");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE); HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
@ -341,7 +341,7 @@ public class TestMultiParallel {
} }
@Test(timeout=300000) @Test(timeout=300000)
public void testBatchWithManyColsInOneRowGetAndPut() throws Exception { public void testBatchWithManyColsInOneRowGetAndPut() throws Exception {
LOG.info("test=testBatchWithManyColsInOneRowGetAndPut"); LOG.info("test=testBatchWithManyColsInOneRowGetAndPut");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE); HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
@ -378,7 +378,7 @@ public class TestMultiParallel {
} }
@Test(timeout=300000) @Test(timeout=300000)
public void testBatchWithMixedActions() throws Exception { public void testBatchWithMixedActions() throws Exception {
LOG.info("test=testBatchWithMixedActions"); LOG.info("test=testBatchWithMixedActions");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE); HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);