You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2014/03/19 04:52:09 UTC
svn commit: r1579125 -
/lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/hdfs/StressHdfsTest.java
Author: markrmiller
Date: Wed Mar 19 03:52:09 2014
New Revision: 1579125
URL: http://svn.apache.org/r1579125
Log:
tests: cancel Timer
Modified:
lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/hdfs/StressHdfsTest.java
Modified: lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/hdfs/StressHdfsTest.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/hdfs/StressHdfsTest.java?rev=1579125&r1=1579124&r2=1579125&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/hdfs/StressHdfsTest.java (original)
+++ lucene/dev/trunk/solr/core/src/test/org/apache/solr/cloud/hdfs/StressHdfsTest.java Wed Mar 19 03:52:09 2014
@@ -100,28 +100,34 @@ public class StressHdfsTest extends Basi
}
if (testRestartIntoSafeMode) {
- createCollection(DELETE_DATA_DIR_COLLECTION, 1, 1, 1);
-
- waitForRecoveriesToFinish(DELETE_DATA_DIR_COLLECTION, false);
-
- ChaosMonkey.stop(jettys.get(0));
-
- // enter safe mode and restart a node
- NameNodeAdapter.enterSafeMode(dfsCluster.getNameNode(), false);
-
- int rnd = LuceneTestCase.random().nextInt(10000);
Timer timer = new Timer();
- timer.schedule(new TimerTask() {
-
- @Override
- public void run() {
- NameNodeAdapter.leaveSafeMode(dfsCluster.getNameNode());
- }
- }, rnd);
-
- ChaosMonkey.start(jettys.get(0));
- waitForRecoveriesToFinish(DELETE_DATA_DIR_COLLECTION, false);
+ try {
+ createCollection(DELETE_DATA_DIR_COLLECTION, 1, 1, 1);
+
+ waitForRecoveriesToFinish(DELETE_DATA_DIR_COLLECTION, false);
+
+ ChaosMonkey.stop(jettys.get(0));
+
+ // enter safe mode and restart a node
+ NameNodeAdapter.enterSafeMode(dfsCluster.getNameNode(), false);
+
+ int rnd = LuceneTestCase.random().nextInt(10000);
+
+ timer.schedule(new TimerTask() {
+
+ @Override
+ public void run() {
+ NameNodeAdapter.leaveSafeMode(dfsCluster.getNameNode());
+ }
+ }, rnd);
+
+ ChaosMonkey.start(jettys.get(0));
+
+ waitForRecoveriesToFinish(DELETE_DATA_DIR_COLLECTION, false);
+ } finally {
+ timer.cancel();
+ }
}
}