import org.apache.hadoop.fi.DataTransferTestUtil.DoosAction; //导入依赖的package包/类
/**
 * Streaming: Write a packet, DN0 throws a DiskOutOfSpaceError
 * when it writes the data to disk.
 * Client gets an IOException and determine DN0 bad.
 */
@Test
public void pipeline_Fi_14() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  runCallWritePacketToDisk(methodName, 0, new DoosAction(methodName, 0));
}
 

import org.apache.hadoop.fi.DataTransferTestUtil.DoosAction; //导入依赖的package包/类
/**
 * Streaming: Write a packet, DN1 throws a DiskOutOfSpaceError
 * when it writes the data to disk.
 * Client gets an IOException and determine DN1 bad.
 */
@Test
public void pipeline_Fi_15() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  runCallWritePacketToDisk(methodName, 1, new DoosAction(methodName, 1));
}
 

import org.apache.hadoop.fi.DataTransferTestUtil.DoosAction; //导入依赖的package包/类
/**
 * Streaming: Write a packet, DN2 throws a DiskOutOfSpaceError
 * when it writes the data to disk.
 * Client gets an IOException and determine DN2 bad.
 */
@Test
public void pipeline_Fi_16() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  runCallWritePacketToDisk(methodName, 2, new DoosAction(methodName, 2));
}