Package org.apache.hadoop.hdfs.tools

Examples of org.apache.hadoop.hdfs.tools.FastCopy.shutdown()

95
96
97
98
99
100
101
102
103
104
105
    } catch (ExecutionException e) {
      System.out.println("Expected exception : " + e);
      assertEquals(IOException.class, e.getCause().getClass());
      return;
    } finally {
      fastCopy.shutdown();
    }
  }
 
  @Test(timeout = 2 * 60 * 1000)
  public void testDeadDatanodesCrossFS() throws Exception {
View Full Code Here
139
140
141
142
143
144
145
146
147
148
    } catch (ExecutionException e) {
      System.out.println("Expected exception : " + e);
      assertEquals(IOException.class, e.getCause().getClass());
      return;
    } finally {
      fastCopy.shutdown();
    }
    fail("No exception thrown");
  }
}
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
        for (String hardLink : hardlinks) {
          assertEquals(hardLink, fileName + "dst");
        }
      }
    } finally {
      fastCopy.shutdown();
    }
  }
 
  @Test
  public void testBadDatanodeCrossFS() throws Exception {
View Full Code Here
84
85
86
87
88
89
90
91
92
      Map<DatanodeInfo, Integer> dnErrors = fastCopy.getDatanodeErrors();
      assertEquals(1, dnErrors.size());
      int errors = dnErrors.values().iterator().next();
      assertTrue(errors >= conf.getInt("dfs.fastcopy.max.datanode.errors", 3) + 1);
    } finally {
      fastCopy.shutdown();
    }
  }
}
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
      }
    } catch (Exception e) {
      LOG.error("Fast Copy failed with exception : ", e);
      fail("Fast Copy failed");
    } finally {
      fastCopy.shutdown();
    }
    assertTrue(pass);
  }

  public void testFastCopyOldAPI(boolean hardlink) throws Exception {
View Full Code Here
254
255
256
257
258
259
260
261
262
263
264
      }
    } catch (Exception e) {
      LOG.error("Fast Copy failed with exception : ", e);
      fail("Fast Copy failed");
    } finally {
      fastCopy.shutdown();
    }
    assertTrue(pass);
  }

  public void testFastCopyMultiple(boolean hardlink) throws Exception {
View Full Code Here
281
282
283
284
285
286
287
288
289
290
291
      }
    } catch (Exception e) {
      LOG.error("Fast Copy failed with exception : ", e);
      fail("Fast Copy failed");
    } finally {
      fastCopy.shutdown();
    }
    assertTrue(pass);
  }

View Full Code Here
319
320
321
322
323
324
325
326
327
328
329
      }
    } catch (Exception e) {
      LOG.error("Fast Copy failed with exception : ", e);
      fail("Fast Copy failed");
    } finally {
      fastCopy.shutdown();
    }
    assertTrue(pass);
  }

  private static void setInjectionHandler() {
View Full Code Here
370
371
372
373
374
375
376
377
378
379
380
      }
    } catch (Exception e) {
      LOG.error("Fast Copy failed with exception : ", e);
      fail("Fast Copy failed");
    } finally {
      fastCopy.shutdown();
    }
    assertTrue(pass);
  }

  public void testFastCopyShellMultiple(boolean hardlink, String extraargs[])
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.