Skip to content

Commit 0d294a1

Browse files
author
krastogi
committed
Adding metric to track missing trace result from cassandra
1 parent 0867995 commit 0d294a1

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

reader/src/main/scala/com/expedia/www/haystack/trace/reader/stores/readers/cassandra/CassandraReadRawTracesResultListener.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class CassandraReadRawTracesResultListener(asyncResult: ResultSetFuture,
4040
timer: Timer.Context,
4141
failure: Meter,
4242
tracesFailure: Meter,
43-
raceIdCount: Int) extends Runnable {
43+
traceIdCount: Int) extends Runnable {
4444
override def run(): Unit = {
4545
timer.close()
4646

@@ -49,7 +49,7 @@ class CassandraReadRawTracesResultListener(asyncResult: ResultSetFuture,
4949
.flatMap(tryDeserialize)
5050
match {
5151
case Success(traces) =>
52-
tracesFailure.mark(raceIdCount - traces.length)
52+
tracesFailure.mark(traceIdCount - traces.length)
5353
promise.success(traces)
5454
case Failure(ex) =>
5555
if (fatalError(ex)) {
@@ -59,7 +59,7 @@ class CassandraReadRawTracesResultListener(asyncResult: ResultSetFuture,
5959
LOGGER.error("Failed in reading the record from cassandra", ex)
6060
}
6161
failure.mark()
62-
tracesFailure.mark(raceIdCount)
62+
tracesFailure.mark(traceIdCount)
6363
promise.failure(ex)
6464
}
6565
}

0 commit comments

Comments
 (0)