You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ro...@apache.org on 2014/02/26 00:45:59 UTC
svn commit: r1571868 - in /pig/trunk: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
Author: rohini
Date: Tue Feb 25 23:45:58 2014
New Revision: 1571868
URL: http://svn.apache.org/r1571868
Log:
PIG-3778: Log list of running jobs along with progress (rohini)
Modified:
pig/trunk/CHANGES.txt
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1571868&r1=1571867&r2=1571868&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Tue Feb 25 23:45:58 2014
@@ -30,6 +30,8 @@ PIG-2207: Support custom counters for ag
IMPROVEMENTS
+PIG-3778: Log list of running jobs along with progress (rohini)
+
PIG-3675: Documentation for AccumuloStorage (elserj via daijy)
PIG-3648: Make the sample size for RandomSampleLoader configurable (cheolsoo)
Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java?rev=1571868&r1=1571867&r2=1571868&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java Tue Feb 25 23:45:58 2014
@@ -341,6 +341,20 @@ public class MapReduceLauncher extends L
double prog = (numMRJobsCompl+calculateProgress(jc, statsJobClient))/totalMRJobs;
if (notifyProgress(prog, lastProg)) {
+ List<Job> runnJobs = jc.getRunningJobs();
+ if (runnJobs != null) {
+ StringBuilder msg = new StringBuilder();
+ for (Object object : runnJobs) {
+ Job j = (Job) object;
+ if (j != null) {
+ msg.append(j.getAssignedJobID()).append(",");
+ }
+ }
+ if (msg.length() > 0) {
+ msg.setCharAt(msg.length() - 1, ']');
+ log.info("Running jobs are [" + msg);
+ }
+ }
lastProg = prog;
}