HDFS-13593. TestBlockReaderLocalLegacy#testBlockReaderLocalLegacyWithAppend fails on Windows. Contributed by Anbang Hu.

This commit is contained in:
Inigo Goiri 2018-05-18 09:46:02 -07:00
parent 57b893de3d
commit 9775ecb235
1 changed files with 5 additions and 2 deletions

View File

@ -48,6 +48,7 @@ import org.apache.hadoop.net.unix.DomainSocket;
import org.apache.hadoop.net.unix.TemporarySocketDirectory; import org.apache.hadoop.net.unix.TemporarySocketDirectory;
import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.security.UserGroupInformation;
import org.apache.hadoop.security.token.Token; import org.apache.hadoop.security.token.Token;
import org.apache.hadoop.test.GenericTestUtils;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Assume; import org.junit.Assume;
import org.junit.BeforeClass; import org.junit.BeforeClass;
@ -93,8 +94,9 @@ public class TestBlockReaderLocalLegacy {
final long FILE_LENGTH = 512L; final long FILE_LENGTH = 512L;
HdfsConfiguration conf = getConfiguration(null); HdfsConfiguration conf = getConfiguration(null);
File basedir = new File(GenericTestUtils.getRandomizedTempPath());
MiniDFSCluster cluster = MiniDFSCluster cluster =
new MiniDFSCluster.Builder(conf).numDataNodes(1).build(); new MiniDFSCluster.Builder(conf, basedir).numDataNodes(1).build();
cluster.waitActive(); cluster.waitActive();
FileSystem fs = cluster.getFileSystem(); FileSystem fs = cluster.getFileSystem();
@ -173,8 +175,9 @@ public class TestBlockReaderLocalLegacy {
final HdfsConfiguration conf = getConfiguration(null); final HdfsConfiguration conf = getConfiguration(null);
conf.setBoolean(HdfsClientConfigKeys.DFS_CLIENT_USE_LEGACY_BLOCKREADERLOCAL, true); conf.setBoolean(HdfsClientConfigKeys.DFS_CLIENT_USE_LEGACY_BLOCKREADERLOCAL, true);
File basedir = new File(GenericTestUtils.getRandomizedTempPath());
final MiniDFSCluster cluster = final MiniDFSCluster cluster =
new MiniDFSCluster.Builder(conf).numDataNodes(1).build(); new MiniDFSCluster.Builder(conf, basedir).numDataNodes(1).build();
cluster.waitActive(); cluster.waitActive();
final DistributedFileSystem dfs = cluster.getFileSystem(); final DistributedFileSystem dfs = cluster.getFileSystem();