MAPREDUCE-6587. Remove unused params in connection-related methods of Fetcher. Contributed by Yiqun Lin.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/8cc4a670 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/8cc4a670 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/8cc4a670 Branch: refs/heads/HDFS-9806 Commit: 8cc4a67059e37b2083cd5468b35a64a403a3e3ae Parents: c49333b Author: Akira Ajisaka <aajis...@apache.org> Authored: Tue Aug 23 17:04:55 2016 +0900 Committer: Akira Ajisaka <aajis...@apache.org> Committed: Tue Aug 23 17:04:55 2016 +0900 ---------------------------------------------------------------------- .../org/apache/hadoop/mapreduce/task/reduce/Fetcher.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/8cc4a670/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/Fetcher.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/Fetcher.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/Fetcher.java index d8dd7b5..be2f84f 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/Fetcher.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/Fetcher.java @@ -263,7 +263,7 @@ class Fetcher<K,V> extends Thread { DataInputStream input = null; try { - setupConnectionsWithRetry(host, remaining, url); + setupConnectionsWithRetry(url); if (stopped) { abortConnect(host, remaining); } else { @@ -374,9 +374,8 @@ class Fetcher<K,V> extends Thread { } } - private void setupConnectionsWithRetry(MapHost host, - Set<TaskAttemptID> remaining, URL url) throws IOException { - openConnectionWithRetry(host, remaining, url); + private void setupConnectionsWithRetry(URL url) throws IOException { + openConnectionWithRetry(url); if (stopped) { return; } @@ -396,8 +395,7 @@ class Fetcher<K,V> extends Thread { verifyConnection(url, msgToEncode, encHash); } - private void openConnectionWithRetry(MapHost host, - Set<TaskAttemptID> remaining, URL url) throws IOException { + private void openConnectionWithRetry(URL url) throws IOException { long startTime = Time.monotonicNow(); boolean shouldWait = true; while (shouldWait) { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org