hadoop-mapreduce-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hudson (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (MAPREDUCE-6587) Remove unused params in connection-related methods of Fetcher
Date Tue, 23 Aug 2016 08:42:22 GMT

    [ https://issues.apache.org/jira/browse/MAPREDUCE-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432396#comment-15432396
] 

Hudson commented on MAPREDUCE-6587:
-----------------------------------

SUCCESS: Integrated in Jenkins build Hadoop-trunk-Commit #10324 (See [https://builds.apache.org/job/Hadoop-trunk-Commit/10324/])
MAPREDUCE-6587. Remove unused params in connection-related methods of (aajisaka: rev 8cc4a67059e37b2083cd5468b35a64a403a3e3ae)
* (edit) hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/Fetcher.java


> Remove unused params in connection-related methods of Fetcher
> -------------------------------------------------------------
>
>                 Key: MAPREDUCE-6587
>                 URL: https://issues.apache.org/jira/browse/MAPREDUCE-6587
>             Project: Hadoop Map/Reduce
>          Issue Type: Improvement
>    Affects Versions: 2.7.1
>            Reporter: Yiqun Lin
>            Assignee: Yiqun Lin
>            Priority: Minor
>             Fix For: 2.8.0
>
>         Attachments: MAPREDUCE-6587.001.patch
>
>
> There are some unused params in Fecther#openConnectionWithRetry.The code is following:
> {code}
> private void openConnectionWithRetry(MapHost host,
>       Set<TaskAttemptID> remaining, URL url) throws IOException {
>     long startTime = Time.monotonicNow();
>     boolean shouldWait = true;
>     while (shouldWait) {
>       try {
>         openConnection(url);
>         shouldWait = false;
>       } catch (IOException e) {
>         if (!fetchRetryEnabled) {
>            // throw exception directly if fetch's retry is not enabled
>            throw e;
>         }
>         if ((Time.monotonicNow() - startTime) >= this.fetchRetryTimeout) {
>           LOG.warn("Failed to connect to host: " + url + "after " 
>               + fetchRetryTimeout + " milliseconds.");
>           throw e;
>         }
>         try {
>           Thread.sleep(this.fetchRetryInterval);
>         } catch (InterruptedException e1) {
>           if (stopped) {
>             return;
>           }
>         }
>       }
>     }
>   }
> {code}
> we can see that the param remaing and host is not be used in this method. So we need
to remove these param and update the method params which invoke this method.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: mapreduce-issues-unsubscribe@hadoop.apache.org
For additional commands, e-mail: mapreduce-issues-help@hadoop.apache.org


Mime
View raw message