diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/optimized/VectorMapJoinOptimizedHashMap.java ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/optimized/VectorMapJoinOptimizedHashMap.java index e56c821..292e72c 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/optimized/VectorMapJoinOptimizedHashMap.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/optimized/VectorMapJoinOptimizedHashMap.java @@ -66,12 +66,12 @@ public boolean isSingleRow() { @Override public boolean isCappedCountAvailable() { - return false; + return true; } @Override public int cappedCount() { - return 0; + return hasRows() ? (isSingleRow() ? 1 : 2) : 0; } @Override