Sha256: 52404806e3de186e7ac730bbd83f101650881acc85de730505b477ff6446f173
Contents?: true
Size: 718 Bytes
Versions: 18
Compression:
Stored size: 718 Bytes
Contents
module Mandy
class HadoopJobFailure < StandardError
attr_reader :output
def initialize(job, output)
@job, @output = job, output
end
def job_name
@job.name
end
def tracking_url
line = @output.split("\n").find {|line| line =~ /Tracking URL/ }
return nil unless line
line.split('Tracking URL: ').last
end
def hadoop_error
@output.split("\n").find {|line| line =~ /ERROR/ }
end
def to_s
output = []
output << %(Hadoop ERROR: #{hadoop_error || 'Unkown Error'})
output << %(Mandy Job Name: #{job_name})
output << %(Tracking URL: #{tracking_url}) if tracking_url
output*"\n"
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems