You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pr...@apache.org on 2016/05/24 19:27:21 UTC
hive git commit: HIVE-12467: Add number of dynamic partitions to
error message (Lars Francke reviewed by Prasanth Jayachandran)
Repository: hive
Updated Branches:
refs/heads/master 8a6795895 -> 115d225d8
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/master
Commit: 115d225d8d311e1d1fa42e8f103c214b26c209a2
Parents: 8a67958
Author: Prasanth Jayachandran <pr...@apache.org>
Authored: Tue May 24 12:27:09 2016 -0700
Committer: Prasanth Jayachandran <pr...@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) {