azkaban-memoizeit
Details
src/tl/flowstats.tl 20(+20 -0)
diff --git a/src/tl/flowstats.tl b/src/tl/flowstats.tl
index 8cf6455..cbd1ec4 100644
--- a/src/tl/flowstats.tl
+++ b/src/tl/flowstats.tl
@@ -17,3 +17,23 @@
</tbody>
</table>
</div>
+
+ <div class="panel panel-default">
+ <div class="panel-heading">Parameters</div>
+ <table class="table table-striped table-bordered table-condensed">
+ <tbody>
+ <tr>
+ <td class="property-key">Max -Xmx</td>
+ <td class="property-value-half">{stats.maxXmx}</td>
+ <td class="property-key">-Xms</td>
+ <td class="property-value-half">{stats.maxXms}</td>
+ </tr>
+ <tr>
+ <td class="property-key">Max <code>mapred.job.map.memory.mb</code></td>
+ <td class="property-value-half">{stats.maxJobMapMemoryMb}</td>
+ <td class="property-key">Max <code>mapred.job.reduce.memory.mb</code></td>
+ <td class="property-value-half">{stats.maxJobReduceMemoryMb}</td>
+ </tr>
+ </tbody>
+ </table>
+ </div>
diff --git a/src/web/js/azkaban.flow.stats.view.js b/src/web/js/azkaban.flow.stats.view.js
index df850e1..64d0455 100644
--- a/src/web/js/azkaban.flow.stats.view.js
+++ b/src/web/js/azkaban.flow.stats.view.js
@@ -89,6 +89,10 @@ azkaban.FlowStatsView = Backbone.View.extend({
}
aggregateStats.totalMapSlots += mappers;
aggregateStats.totalReduceSlots += reducers;
+
+ var jobMapMemoryMb = conf['mapred.job.map.memory.mb'];
+ var jobReduceMemoryMb = conf['mapred.job.reduce.memory.mb'];
+ var childJavaOpts = conf['mapred.child.java.opts'];
},
analyzeExecution: function(execId) {