test/test_i_mapreduce.rb in pmux-0.1.1 vs test/test_i_mapreduce.rb in pmux-0.1.2
- old
+ new
@@ -51,11 +51,11 @@
end
class Pmux::Cleaner
def run lim_time=nil
lim_time = Time.now - 3600
- clean @glob_pat, lim_time
+ @glob_pats.each {|glob_pat| clean glob_pat, lim_time}
end
end
class TestIMapreduce < Test::Unit::TestCase
# gflocatorを生成し、そのサーバへのconnection(socket)を返す
@@ -145,11 +145,12 @@
er = nil
dispatcher.on_error {|r| er = r}
job = Pmux::Job.new options, files
job.mk_reducer_addrs addrs
dispatcher.run job
+ assert job.failed
assert_match %r{/notexist: No such file or directory}, er['error_message']
- ae 420, writer.lines.size
+ ae 0, writer.lines.size
end
# mr test; num_r=0, 4 files, ff=2
def test_run_mr_f
root_dir = "#{$test_dir}/.t"