HADOOP-4732. Pass connection and read timeouts in the correct order when

setting up fetch in reduce. Contributed by Amareshwari Sriramadasu.


git-svn-id: https://svn.apache.org/repos/asf/hadoop/core/trunk@721761 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -230,6 +230,9 @@ Trunk (unreleased changes)
     HADOOP-4669. Use correct operator when evaluating whether access time is
     enabled (Dhruba Borthakur via cdouglas)
 
+    HADOOP-4732. Pass connection and read timeouts in the correct order when
+    setting up fetch in reduce. (Amareshwari Sriramadasu via cdouglas)
+
 Release 0.19.1 - Unreleased
 
   BUG FIXES

src/mapred/org/apache/hadoop/mapred/ReduceTask.java

@@ -1222,8 +1222,8 @@ class ReduceTask extends Task {
         // Connect
         URLConnection connection = 
           mapOutputLoc.getOutputLocation().openConnection();
-        InputStream input = getInputStream(connection, DEFAULT_READ_TIMEOUT, 
-                                           STALLED_COPY_TIMEOUT);
+        InputStream input = getInputStream(connection, STALLED_COPY_TIMEOUT,
+                                           DEFAULT_READ_TIMEOUT); 
 
         //We will put a file in memory if it meets certain criteria:
         //1. The size of the (decompressed) file should be less than 25% of 
@@ -1319,8 +1319,8 @@ class ReduceTask extends Task {
           // Reconnect
           try {
             connection = mapOutputLoc.getOutputLocation().openConnection();
-            input = getInputStream(connection, DEFAULT_READ_TIMEOUT, 
-                STALLED_COPY_TIMEOUT);
+            input = getInputStream(connection, STALLED_COPY_TIMEOUT, 
+                                   DEFAULT_READ_TIMEOUT);
           } catch (IOException ioe) {
             LOG.info("Failed reopen connection to fetch map-output from " + 
                      mapOutputLoc.getHost());