hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sp...@apache.org
Subject [21/66] [abbrv] hive git commit: HIVE-12467: Add number of dynamic partitions to error message (Lars Francke reviewed by Prasanth Jayachandran)
Date Thu, 26 May 2016 15:40:43 GMT
HIVE-12467: Add number of dynamic partitions to error message (Lars Francke 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/115d225d
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/115d225d
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/115d225d

Branch: refs/heads/java8
Commit: 115d225d8d311e1d1fa42e8f103c214b26c209a2
Parents: 8a67958
Author: Prasanth Jayachandran <prasanthj@apache.org>
Authored: Tue May 24 12:27:09 2016 -0700
Committer: Prasanth Jayachandran <prasanthj@apache.org>
Committed: Tue May 24 12:27:09 2016 -0700

----------------------------------------------------------------------
 ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/115d225d/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
index 3ec63ee..cd5e7e7 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
@@ -938,7 +938,8 @@ public class FileSinkOperator extends TerminalOperator<FileSinkDesc>
implements
           // we cannot proceed and need to tell the hive client that retries won't succeed
either
           throw new HiveFatalException(
                ErrorMsg.DYNAMIC_PARTITIONS_TOO_MANY_PER_NODE_ERROR.getErrorCodedMsg()
-               + "Maximum was set to: " + maxPartitions);
+               + "Maximum was set to " + maxPartitions + " partitions per node"
+               + ", number of dynamic partitions on this node: " + valToPaths.size());
         }
 
         if (!conf.getDpSortState().equals(DPSortState.NONE) && prevFsp != null) {


Mime
View raw message