diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java index bdde81a..872c223 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java @@ -384,7 +384,7 @@ private boolean pushRecordVector() { } /** - * + * * @param keyWritable * @param values * @param tag @@ -470,9 +470,10 @@ private void processVectorGroup(BytesWritable keyWritable, rowString = "[Error getting row data with exception " + StringUtils.stringifyException(e2) + " ]"; } + l4j.error("Hive Runtime Error while processing vector batch (tag=" + tag + + ") (vectorizedVertexNum " + vectorizedVertexNum + ") " + rowString, e); throw new HiveException("Hive Runtime Error while processing vector batch (tag=" - + tag + ") (vectorizedVertexNum " + vectorizedVertexNum + ") " + - rowString, e); + + tag + ") (vectorizedVertexNum " + vectorizedVertexNum + ")", e); } }