HIVE-16801: Vectorization: throwExpandError should be an immediate fatal (Gopal V, reviewed by Prasanth Jayachandran)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/3f5e6528 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/3f5e6528 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/3f5e6528 Branch: refs/heads/hive-14535 Commit: 3f5e65288eacbff9d2c373d3bd4e1eaa74517f67 Parents: b560f49 Author: Gopal V <[email protected]> Authored: Thu Jun 1 22:59:50 2017 -0700 Committer: Gopal V <[email protected]> Committed: Thu Jun 1 22:59:50 2017 -0700 ---------------------------------------------------------------------- .../ql/exec/vector/mapjoin/fast/VectorMapJoinFastHashTable.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/3f5e6528/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VectorMapJoinFastHashTable.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VectorMapJoinFastHashTable.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VectorMapJoinFastHashTable.java index 1f182ee..ce9a962 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VectorMapJoinFastHashTable.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VectorMapJoinFastHashTable.java @@ -21,6 +21,7 @@ package org.apache.hadoop.hive.ql.exec.vector.mapjoin.fast; import org.apache.hadoop.hive.ql.util.JavaDataModel; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.apache.hadoop.hive.ql.exec.mapjoin.MapJoinMemoryExhaustionError; import org.apache.hadoop.hive.ql.exec.vector.mapjoin.hashtable.VectorMapJoinHashTable; public abstract class VectorMapJoinFastHashTable implements VectorMapJoinHashTable { @@ -47,7 +48,7 @@ public abstract class VectorMapJoinFastHashTable implements VectorMapJoinHashTab public static final int ONE_SIXTH_LIMIT = HIGHEST_INT_POWER_OF_2 / 6; public void throwExpandError(int limit, String dataTypeName) { - throw new RuntimeException( + throw new MapJoinMemoryExhaustionError( "Vector MapJoin " + dataTypeName + " Hash Table cannot grow any more -- use a smaller container size. " + "Current logical size is " + logicalHashBucketCount + " and " + "the limit is " + limit + ". " +
