kluyg

 ERROR [Thread-195] 2015-07-14 20:24:26,689 Uncaught exception on Thread-195
 java.lang.OutOfMemoryError: Java heap space
        at java.lang.reflect.Method.copy(Method.java:153)
        at java.lang.reflect.ReflectAccess.copyMethod(ReflectAccess.java:140)
        at sun.reflect.ReflectionFactory.copyMethod(ReflectionFactory.java:302)
        at java.lang.Class.copyMethods(Class.java:3124)
        at java.lang.Class.getMethods(Class.java:1615)
        at clojure.lang.Reflector.getMethods(Reflector.java:357)
        at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:27)
        at opsagent.proc$grab_stream.invoke(proc.clj:28)

kluyg

  WARN [Thread-2] 2015-07-14 18:42:50,411 Cassandra operation queue is full, discarding cassandra operation
  WARN [Thread-2] 2015-07-14 18:42:50,411 7808 operations dropped so far.
  WARN [rollup-snapshot] 2015-07-14 18:42:50,412 Cassandra operation queue is full, discarding cassandra operation
  WARN [rollup-snapshot] 2015-07-14 18:42:50,412 7808 operations dropped so far.
  WARN [rollup-snapshot] 2015-07-14 18:42:50,807 Cassandra operation queue is full, discarding cassandra operation
  WARN [rollup-snapshot] 2015-07-14 18:42:51,000 7809 operations dropped so far.
  WARN [rollup-snapshot] 2015-07-14 18:42:51,001 Cassandra operation queue is full, discarding cassandra operation
  WARN [rollup-snapshot] 2015-07-14 18:42:51,001 7810 operations dropped so far.
  WARN [rollup-snapshot] 2015-07-14 18:42:51,192 Cassandra operation queue is full, discarding cassandra operation
  WARN [rollup-snapshot] 2015-07-14 18:42:51,382 7811 operations dropped so far.

kluyg

class MyRetryPolicy(maxRetries: Int) extends RetryPolicy {
  override def onReadTimeout(statement: Statement,
                             cl: ConsistencyLevel,
                             requiredResponses: Int,
                             receivedResponses: Int,
                             dataRetrieved: Boolean,
                             nbRetry: Int): RetryDecision = {
    if (nbRetry < maxRetries) RetryDecision.retry(cl) else RetryDecision.rethrow()
  }