We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d270101 commit 5eaf291Copy full SHA for 5eaf291
app/lib/client/zk/mrtzk.rb
@@ -90,7 +90,9 @@ def metrics
90
next unless zk.exists?("/batches/#{bid}/states/batch-processing")
91
92
zk.children("/batches/#{bid}/states/batch-processing").sort.each do |jid|
93
+ puts "/jobs/#{jid}/space_needed"
94
if zk.exists?("/jobs/#{jid}/space_needed")
95
+ puts "Space: #{zk.get("/jobs/#{jid}/space_needed")[0].to_i}"
96
metrics[:bytes_in_process] += zk.get("/jobs/#{jid}/space_needed")[0].to_i
97
end
98
0 commit comments