hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From na...@apache.org
Subject svn commit: r782717 - in /hadoop/hive/trunk: CHANGES.txt ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java
Date Mon, 08 Jun 2009 18:22:11 GMT
Author: namit
Date: Mon Jun  8 18:22:11 2009
New Revision: 782717

URL: http://svn.apache.org/viewvc?rev=782717&view=rev
Log:
HIVE-547. Better logging in ExecDriver
(Zheng Shao via namit)


Modified:
    hadoop/hive/trunk/CHANGES.txt
    hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java

Modified: hadoop/hive/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/CHANGES.txt?rev=782717&r1=782716&r2=782717&view=diff
==============================================================================
--- hadoop/hive/trunk/CHANGES.txt (original)
+++ hadoop/hive/trunk/CHANGES.txt Mon Jun  8 18:22:11 2009
@@ -229,6 +229,9 @@
     HIVE-544. Fix predicate push for exprFieldNodeDesc.
     (Prasad Chakka via zshao)
 
+    HIVE-547. Better logging in ExecDriver
+    (Zheng Shao via namit)
+
 Release 0.3.1 - Unreleased
 
   INCOMPATIBLE CHANGES

Modified: hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java?rev=782717&r1=782716&r2=782717&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java (original)
+++ hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java Mon Jun 
8 18:22:11 2009
@@ -19,6 +19,8 @@
 package org.apache.hadoop.hive.ql.exec;
 
 import java.io.*;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
 import java.util.*;
 import java.net.URI;
 import java.net.URLEncoder;
@@ -183,6 +185,8 @@
    */
   public RunningJob jobProgress(JobClient jc, RunningJob rj) throws IOException {
     String lastReport = "";
+    SimpleDateFormat dateFormat
+        = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss,SSS");
     while (!rj.isComplete()) {
       try {
         Thread.sleep(1000);
@@ -190,7 +194,8 @@
       }
       rj = jc.getJob(rj.getJobID());
       String report = null;
-      report = " map = " + Math.round(rj.mapProgress() * 100) + "%,  reduce ="
+      report = dateFormat.format(Calendar.getInstance().getTime())
+          + " map = " + Math.round(rj.mapProgress() * 100) + "%,  reduce ="
           + Math.round(rj.reduceProgress() * 100) + "%";
 
       if (!report.equals(lastReport)) {



Mime
View raw message