|
@@ -307,10 +307,6 @@ public class TestDataNodeVolumeFailure {
|
|
|
@Test(timeout=10000)
|
|
|
public void testDataNodeShutdownAfterNumFailedVolumeExceedsTolerated()
|
|
|
throws InterruptedException, IOException {
|
|
|
- // The test uses DataNodeTestUtils#injectDataDirFailure() to simulate
|
|
|
- // volume failures which is currently not supported on Windows.
|
|
|
- assumeNotWindows();
|
|
|
-
|
|
|
// make both data directories to fail on dn0
|
|
|
final File dn0Vol1 = new File(dataDir, "data" + (2 * 0 + 1));
|
|
|
final File dn0Vol2 = new File(dataDir, "data" + (2 * 0 + 2));
|
|
@@ -330,10 +326,6 @@ public class TestDataNodeVolumeFailure {
|
|
|
@Test
|
|
|
public void testVolumeFailureRecoveredByHotSwappingVolume()
|
|
|
throws InterruptedException, ReconfigurationException, IOException {
|
|
|
- // The test uses DataNodeTestUtils#injectDataDirFailure() to simulate
|
|
|
- // volume failures which is currently not supported on Windows.
|
|
|
- assumeNotWindows();
|
|
|
-
|
|
|
final File dn0Vol1 = new File(dataDir, "data" + (2 * 0 + 1));
|
|
|
final File dn0Vol2 = new File(dataDir, "data" + (2 * 0 + 2));
|
|
|
final DataNode dn0 = cluster.getDataNodes().get(0);
|
|
@@ -372,10 +364,6 @@ public class TestDataNodeVolumeFailure {
|
|
|
@Test
|
|
|
public void testTolerateVolumeFailuresAfterAddingMoreVolumes()
|
|
|
throws InterruptedException, ReconfigurationException, IOException {
|
|
|
- // The test uses DataNodeTestUtils#injectDataDirFailure() to simulate
|
|
|
- // volume failures which is currently not supported on Windows.
|
|
|
- assumeNotWindows();
|
|
|
-
|
|
|
final File dn0Vol1 = new File(dataDir, "data" + (2 * 0 + 1));
|
|
|
final File dn0Vol2 = new File(dataDir, "data" + (2 * 0 + 2));
|
|
|
final File dn0VolNew = new File(dataDir, "data_new");
|