GraphiteWriter issue witg Gatling-2.2.0-SNAPSHOT version

Gatling (Open-Source)
1

Hi guys,

I was trying the Gatling-2.2.0-SNAPSHOT version to work around https://github.com/gatling/gatling/issues/2487 and I found the GraphiteDataWriter to have issues. I get the following errors:

[ERROR] [01/08/2015 14:32:22.421] [GatlingSystem-akka.actor.default-dispatcher-3] [akka://GatlingSystem/user/GraphiteDataWriter/graphiteSender-49/metricsSender-66] Actor io.gatling.metrics.sender.TcpSender@5b715bc doesn't support message CommandFailed(Write(ByteString(103, 97, 116, 108, 105, 110, 103, 50, 46, 99, 105, 115, 46, 80, 114, 111, 118, 105, 100, 101, 80, 97, 115, 115, 101, 110, 103, 101, 114, 72, 97, 110, 100, 108, 105, 110, 103, 73, 110, 102, 111, 114, 109, 97, 116, 105, 111, 110, 95, 49, 65, 95, 118, 52, 95, 51, 46, 111, 107, 46, 112, 101, 114, 99, 101, 110, 116, 105, 108, 101, 115, 57, 53, 45, 48, 32, 52, 51, 32, 49, 52, 50, 48, 55, 50, 51, 57, 52, 50, 10),NoAck(null)))
java.lang.IllegalArgumentException: Actor io.gatling.metrics.sender.TcpSender@5b715bc doesn't support message CommandFailed(Write(ByteString(103, 97, 116, 108, 105, 110, 103, 50, 46, 99, 105, 115, 46, 80, 114, 111, 118, 105, 100, 101, 80, 97, 115, 115, 101, 110, 103, 101, 114, 72, 97, 110, 100, 108, 105, 110, 103, 73, 110, 102, 111, 114, 109, 97, 116, 105, 111, 110, 95, 49, 65, 95, 118, 52, 95, 51, 46, 111, 107, 46, 112, 101, 114, 99, 101, 110, 116, 105, 108, 101, 115, 57, 53, 45, 48, 32, 52, 51, 32, 49, 52, 50, 48, 55, 50, 51, 57, 52, 50, 10),NoAck(null)))
  at io.gatling.core.akka.BaseActor.unhandled(BaseActor.scala:32)
  at akka.actor.Actor$$anonfun$aroundReceive$1.apply(Actor.scala:465)
  at akka.actor.Actor$$anonfun$aroundReceive$1.apply(Actor.scala:465)
  at io.gatling.metrics.sender.MetricsSender$$anonfun$connected$1.applyOrElse(MetricsSender.scala:41)
  at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
  at io.gatling.core.akka.BaseActor.aroundReceive(BaseActor.scala:22)
  at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
  at akka.actor.ActorCell.invoke(ActorCell.scala:487)
  at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
  at akka.dispatch.Mailbox.run(Mailbox.scala:221)
  at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
  at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

14:32:22.421 [ERROR] i.g.m.s.TcpSender - Actor io.gatling.metrics.sender.TcpSender@5b715bc crashed on message Some(CommandFailed(Write(ByteString(103, 97, 116, 108, 105, 110, 103, 50, 46, 99, 105, 115, 46, 80, 114, 111, 118, 105, 100, 101, 80, 97, 115, 115, 101, 110, 103, 101, 114, 72, 97, 110, 100, 108, 105, 110, 103, 73, 110, 102, 111, 114, 109, 97, 116, 105, 111, 110, 95, 49, 65, 95, 118, 52, 95, 51, 46, 111, 107, 46, 112, 101, 114, 99, 101, 110, 116, 105, 108, 101, 115, 57, 53, 45, 48, 32, 52, 51, 32, 49, 52, 50, 48, 55, 50, 51, 57, 52, 50, 10),NoAck(null))))
java.lang.IllegalArgumentException: Actor io.gatling.metrics.sender.TcpSender@5b715bc doesn't support message CommandFailed(Write(ByteString(103, 97, 116, 108, 105, 110, 103, 50, 46, 99, 105, 115, 46, 80, 114, 111, 118, 105, 100, 101, 80, 97, 115, 115, 101, 110, 103, 101, 114, 72, 97, 110, 100, 108, 105, 110, 103, 73, 110, 102, 111, 114, 109, 97, 116, 105, 111, 110, 95, 49, 65, 95, 118, 52, 95, 51, 46, 111, 107, 46, 112, 101, 114, 99, 101, 110, 116, 105, 108, 101, 115, 57, 53, 45, 48, 32, 52, 51, 32, 49, 52, 50, 48, 55, 50, 51, 57, 52, 50, 10),NoAck(null)))
  at io.gatling.core.akka.BaseActor.unhandled(BaseActor.scala:32) ~[gatling-core-2.2.0-SNAPSHOT.jar:2.2.0-SNAPSHOT]
  at akka.actor.Actor$$anonfun$aroundReceive$1.apply(Actor.scala:465) ~[akka-actor_2.11-2.3.8.jar:na]
  at akka.actor.Actor$$anonfun$aroundReceive$1.apply(Actor.scala:465) ~[akka-actor_2.11-2.3.8.jar:na]
  at io.gatling.metrics.sender.MetricsSender$$anonfun$connected$1.applyOrElse(MetricsSender.scala:41) ~[gatling-metrics-2.2.0-SNAPSHOT.jar:2.2.0-SNAPSHOT]
  at akka.actor.Actor$class.aroundReceive(Actor.scala:465) ~[akka-actor_2.11-2.3.8.jar:na]
  at io.gatling.core.akka.BaseActor.aroundReceive(BaseActor.scala:22) ~[gatling-core-2.2.0-SNAPSHOT.jar:2.2.0-SNAPSHOT]
  at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) ~[akka-actor_2.11-2.3.8.jar:na]
  at akka.actor.ActorCell.invoke(ActorCell.scala:487) ~[akka-actor_2.11-2.3.8.jar:na]
  at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254) [akka-actor_2.11-2.3.8.jar:na]
  at akka.dispatch.Mailbox.run(Mailbox.scala:221) [akka-actor_2.11-2.3.8.jar:na]
  at akka.dispatch.Mailbox.exec(Mailbox.scala:231) [akka-actor_2.11-2.3.8.jar:na]
  at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [scala-library-2.11.4.jar:na]
  at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [scala-library-2.11.4.jar:na]
  at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [scala-library-2.11.4.jar:na]
  at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [scala-library-2.11.4.jar:na]

Any idea what could be causing the error messages?

Cheers

Daniel

2

Hi Daniel,

It looks like Pierre’s non-blocking AkkaIo based refactoring still needs some love :slight_smile:
I think it shouldn’t log that badly, and should handle this event more gracefully.

What happens is that your TCP connection crashed. I think it’s supposed to reconnect, until a certain point where Graphite is considered dead.

What do you see exactly?

Cheers,

Stéphane

3

I opened an issue for this: https://github.com/gatling/gatling/issues/2490