|
@@ -38,6 +38,7 @@ import org.apache.hadoop.fs.FileSystem;
|
|
import org.apache.hadoop.fs.HardLink;
|
|
import org.apache.hadoop.fs.HardLink;
|
|
import org.apache.hadoop.fs.Path;
|
|
import org.apache.hadoop.fs.Path;
|
|
import org.apache.hadoop.hdfs.MiniDFSCluster.DataNodeProperties;
|
|
import org.apache.hadoop.hdfs.MiniDFSCluster.DataNodeProperties;
|
|
|
|
+import org.apache.hadoop.hdfs.client.HdfsClientConfigKeys;
|
|
import org.apache.hadoop.hdfs.protocol.AlreadyBeingCreatedException;
|
|
import org.apache.hadoop.hdfs.protocol.AlreadyBeingCreatedException;
|
|
import org.apache.hadoop.hdfs.protocol.ExtendedBlock;
|
|
import org.apache.hadoop.hdfs.protocol.ExtendedBlock;
|
|
import org.apache.hadoop.hdfs.protocol.LocatedBlock;
|
|
import org.apache.hadoop.hdfs.protocol.LocatedBlock;
|
|
@@ -371,6 +372,9 @@ public class TestFileAppend{
|
|
final Configuration conf = new HdfsConfiguration();
|
|
final Configuration conf = new HdfsConfiguration();
|
|
conf.setInt(
|
|
conf.setInt(
|
|
DFSConfigKeys.DFS_NAMENODE_FILE_CLOSE_NUM_COMMITTED_ALLOWED_KEY, 1);
|
|
DFSConfigKeys.DFS_NAMENODE_FILE_CLOSE_NUM_COMMITTED_ALLOWED_KEY, 1);
|
|
|
|
+ conf.setBoolean(
|
|
|
|
+ HdfsClientConfigKeys.BlockWrite.ReplaceDatanodeOnFailure.ENABLE_KEY,
|
|
|
|
+ false);
|
|
|
|
|
|
final MiniDFSCluster cluster = new MiniDFSCluster.Builder(conf)
|
|
final MiniDFSCluster cluster = new MiniDFSCluster.Builder(conf)
|
|
.numDataNodes(4).build();
|
|
.numDataNodes(4).build();
|