This is an automated email from the ASF dual-hosted git repository.
aajisaka pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 7bc305d MAPREDUCE-7303. Fix TestJobResourceUploader failures after
HADOOP-16878. Contributed by Peter Bacsko.
7bc305d is described below
commit 7bc305db5d5a50127dd7780534d6d7d0b7c683d1
Author: Akira Ajisaka <[email protected]>
AuthorDate: Fri Oct 23 04:34:49 2020 +0900
MAPREDUCE-7303. Fix TestJobResourceUploader failures after HADOOP-16878.
Contributed by Peter Bacsko.
---
.../org/apache/hadoop/mapreduce/TestJobResourceUploader.java | 12 ++++++++++--
1 file changed, 10 insertions(+), 2 deletions(-)
diff --git
a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/TestJobResourceUploader.java
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/TestJobResourceUploader.java
index bbfe2fb..c49d771 100644
---
a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/TestJobResourceUploader.java
+++
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/TestJobResourceUploader.java
@@ -399,6 +399,7 @@ public class TestJobResourceUploader {
Path expectedRemotePath) throws IOException, URISyntaxException {
Path dstPath = new Path("hdfs://localhost:1234/home/hadoop/");
DistributedFileSystem fs = mock(DistributedFileSystem.class);
+ when(fs.makeQualified(any(Path.class))).thenReturn(dstPath);
// make sure that FileUtils.copy() doesn't try to copy anything
when(fs.mkdirs(any(Path.class))).thenReturn(false);
when(fs.getUri()).thenReturn(dstPath.toUri());
@@ -407,6 +408,7 @@ public class TestJobResourceUploader {
JobConf jConf = new JobConf();
Path originalPath = spy(path);
FileSystem localFs = mock(FileSystem.class);
+ when(localFs.makeQualified(any(Path.class))).thenReturn(path);
FileStatus fileStatus = mock(FileStatus.class);
when(localFs.getFileStatus(any(Path.class))).thenReturn(fileStatus);
when(fileStatus.isDirectory()).thenReturn(true);
@@ -420,8 +422,14 @@ public class TestJobResourceUploader {
originalPath, jConf, (short) 1);
ArgumentCaptor<Path> pathCaptor = ArgumentCaptor.forClass(Path.class);
- verify(fs).makeQualified(pathCaptor.capture());
- Assert.assertEquals("Path", expectedRemotePath, pathCaptor.getValue());
+ verify(fs, times(2)).makeQualified(pathCaptor.capture());
+ List<Path> paths = pathCaptor.getAllValues();
+ // first call is invoked on a path which was created by the test,
+ // but the second one is created in copyRemoteFiles()
+ Assert.assertEquals("Expected remote path",
+ expectedRemotePath, paths.get(0));
+ Assert.assertEquals("Expected remote path",
+ expectedRemotePath, paths.get(1));
}
private void testErasureCodingSetting(boolean defaultBehavior)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
