This is an automated email from the ASF dual-hosted git repository.
dcapwell pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/cassandra-easy-stress.git
The following commit(s) were added to refs/heads/main by this push:
new 61ebe7e Easy Cass Stress bumps error metric when producing faster
than cassandra can handle, but doesnt call collect so parquet output shows 0
errors (#98)
61ebe7e is described below
commit 61ebe7eaf9d38ce03f95ff3aff341eff7da776f3
Author: dcapwell <[email protected]>
AuthorDate: Wed Jun 24 15:58:09 2026 -0400
Easy Cass Stress bumps error metric when producing faster than cassandra
can handle, but doesnt call collect so parquet output shows 0 errors (#98)
Reviewed by Jon Haddad
---
src/main/kotlin/org/apache/cassandra/easystress/RequestQueue.kt | 3 +++
1 file changed, 3 insertions(+)
diff --git a/src/main/kotlin/org/apache/cassandra/easystress/RequestQueue.kt
b/src/main/kotlin/org/apache/cassandra/easystress/RequestQueue.kt
index 68cbaff..78c5bba 100644
--- a/src/main/kotlin/org/apache/cassandra/easystress/RequestQueue.kt
+++ b/src/main/kotlin/org/apache/cassandra/easystress/RequestQueue.kt
@@ -44,6 +44,7 @@ class RequestQueue(
companion object {
val log = logger()
+ private val QueueFullException = RuntimeException("Request queue is
full, operation dropped")
}
init {
@@ -97,6 +98,8 @@ class RequestQueue(
if (!queue.offer(op)) {
context.metrics.errors.mark()
+ val now = System.nanoTime()
+ context.collect(op, Either.Right(QueueFullException),
now, now)
}
executed++
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
