You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hive.apache.org by na...@apache.org on 2011/04/20 18:44:44 UTC

svn commit: r1095457 - /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverCommonJoin.java

Author: namit
Date: Wed Apr 20 16:44:44 2011
New Revision: 1095457

URL: http://svn.apache.org/viewvc?rev=1095457&view=rev
Log:
HIVE-2120 auto convert map join may miss good candidates
(He Yongqiang via namit)


Modified:
    hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverCommonJoin.java

Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverCommonJoin.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverCommonJoin.java?rev=1095457&r1=1095456&r2=1095457&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverCommonJoin.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverCommonJoin.java Wed Apr 20 16:44:44 2011
@@ -212,6 +212,7 @@ public class ConditionalResolverCommonJo
         AliasFileSizePair pair = aliasFileSizeList.get(idx);
         String alias = pair.alias;
         long size = pair.size;
+        idx--;
         if (!bigAliasFound && aliasToTask.get(alias) != null) {
           // got the big table
           bigAliasFound = true;
@@ -219,7 +220,6 @@ public class ConditionalResolverCommonJo
           continue;
         }
         smallTablesFileSizeSum += size;
-        idx--;
       }
 
       // compare with threshold