You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by su...@apache.org on 2021/09/23 22:16:43 UTC
[hadoop] 01/02: Revert "MAPREDUCE-7303. Fix TestJobResourceUploader
failures after HADOOP-16878. Contributed by Peter Bacsko."
This is an automated email from the ASF dual-hosted git repository.
sunchao pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
commit 9fd0832a998c9ddfe4d85d82f22ae09412f2763d
Author: Chao Sun <su...@apache.org>
AuthorDate: Tue Sep 21 12:46:20 2021 -0700
Revert "MAPREDUCE-7303. Fix TestJobResourceUploader failures after HADOOP-16878. Contributed by Peter Bacsko."
This reverts commit c40f0f1eb34df64449472f698d1d68355f109e9b.
---
.../org/apache/hadoop/mapreduce/TestJobResourceUploader.java | 12 ++----------
1 file changed, 2 insertions(+), 10 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 c49d771..bbfe2fb 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,7 +399,6 @@ 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());
@@ -408,7 +407,6 @@ 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);
@@ -422,14 +420,8 @@ public class TestJobResourceUploader {
originalPath, jConf, (short) 1);
ArgumentCaptor<Path> pathCaptor = ArgumentCaptor.forClass(Path.class);
- 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));
+ verify(fs).makeQualified(pathCaptor.capture());
+ Assert.assertEquals("Path", expectedRemotePath, pathCaptor.getValue());
}
private void testErasureCodingSetting(boolean defaultBehavior)
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org