}
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
if (dfs != null) { dfs.shutdown(); }
if (mr != null) { mr.shutdown(); }
}
}
public static void main(String[] argv) throws Exception {
TestMiniCoronaTaskFail td = new TestMiniCoronaTaskFail();