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 aa...@apache.org on 2016/08/23 08:11:55 UTC
hadoop git commit: MAPREDUCE-6587. Remove unused params in
connection-related methods of Fetcher. Contributed by Yiqun Lin.
Repository: hadoop
Updated Branches:
refs/heads/trunk c49333bec -> 8cc4a6705
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/trunk
Commit: 8cc4a67059e37b2083cd5468b35a64a403a3e3ae
Parents: c49333b
Author: Akira Ajisaka <aa...@apache.org>
Authored: Tue Aug 23 17:04:55 2016 +0900
Committer: Akira Ajisaka <aa...@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-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org