You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by na...@apache.org on 2012/03/31 03:57:55 UTC
svn commit: r1307691 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java
Author: namit
Date: Sat Mar 31 01:57:54 2012
New Revision: 1307691
URL: http://svn.apache.org/viewvc?rev=1307691&view=rev
Log:
HIVE-2676 The row count that loaded to a table may not right
(binlijin via namit)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java?rev=1307691&r1=1307690&r2=1307691&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java Sat Mar 31 01:57:54 2012
@@ -381,6 +381,10 @@ public class HadoopJobExecHelper {
console.printError("[Fatal Error] " + errMsg.toString());
success = false;
} else {
+ SessionState ss = SessionState.get();
+ if (ss != null) {
+ ss.getHiveHistory().setTaskCounters(SessionState.get().getQueryId(), getId(), ctrs);
+ }
success = rj.isSuccessful();
}
}