Skip to content

Commit 94cd7ff

Browse files
Kapil Rastogiashishagg
authored andcommitted
Additional logging post failed retries (#184)
* Additional logging post failed retries * Additional logging post failed retries
1 parent 4f5cef6 commit 94cd7ff

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

indexer/src/main/scala/com/expedia/www/haystack/trace/indexer/writers/cassandra/CassandraTraceWriter.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ class CassandraTraceWriter(cassandra: CassandraSession,
6767
onSuccess = (_: Any) => inflightRequestsSemaphore.release(),
6868
onFailure = (ex) => {
6969
inflightRequestsSemaphore.release()
70-
LOGGER.error("Fail to write to cassandra after {} retry attempts", config.retryConfig.maxRetries, ex)
70+
LOGGER.error(s"Fail to write to cassandra after ${config.retryConfig.maxRetries} retry attempts for ${traceId}, ${packedSpanBuffer.protoObj.getChildSpans(0).getServiceName}, ${packedSpanBuffer.protoObj.getChildSpans(0).getOperationName}", ex)
7171
})
7272
}
7373

@@ -78,7 +78,7 @@ class CassandraTraceWriter(cassandra: CassandraSession,
7878
*
7979
* @param traceId : trace id
8080
* @param packedSpanBuffer : list of spans belonging to this traceId - span buffer
81-
* @param isLastSpanBuffer tells if this is the last record, so the writer can flush
81+
* @param isLastSpanBuffer tells if this is the last record, so the writer can flush``
8282
* @return
8383
*/
8484
override def writeAsync(traceId: String, packedSpanBuffer: PackedMessage[SpanBuffer], isLastSpanBuffer: Boolean): Unit = {

0 commit comments

Comments
 (0)