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

HBASE-7177 TestZooKeeperScanPolicyObserver.testScanPolicyObserver is flaky 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1410199 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
larsh 2012-11-16 05:20:57 +00:00
parent 3e0385ec1d
commit d322efdeb6
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java
View File

@ -85,9 +85,13 @@ public class TestZooKeeperScanPolicyObserver {
// let's say test last backup was 1h ago
// using plain ZK here, because RecoverableZooKeeper add extra encoding to the data
zk.setData(ZooKeeperScanPolicyObserver.node, Bytes.toBytes(now - 3600*1000), -1);
LOG.debug("Set time: "+Bytes.toLong(Bytes.toBytes(now - 3600*1000)));
// sleep for 1s to give the ZK change a chance to reach the watcher in the observer.
// TODO: Better to wait for the data to be propagated
Thread.sleep(1000);
long ts = now - 2000;
Put p = new Put(R);
p.add(F, Q, ts, Q);