modified TimeoutSpec

openzipkin · Jun 28, 2012 · dac24b7 · dac24b7
1 parent 8070184
commit dac24b7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/zipkin-hadoop/src/test/scala/com/twitter/zipkin/hadoop/TimeoutsSpec.scala b/zipkin-hadoop/src/test/scala/com/twitter/zipkin/hadoop/TimeoutsSpec.scala
@@ -60,6 +60,7 @@ class TimeoutsSpec extends Specification with TupleConversions {
         arg("input", "inputFile").
         arg("output", "outputFile").
         arg("date", "2012-01-01T01:00").
+        arg("error_type", "finagle.timeout").
         source(PreprocessedSpanSource(), (Util.repeatSpan(span, 101, 120, 1) ::: (Util.repeatSpan(span1, 20, 300, 102)) ::: (Util.repeatSpan(span2, 30, 400, 300)))).
         sink[(String, String, Long)](Tsv("outputFile")) {
         val map = new HashMap[String, Long]()