guard against unknow query formats on the Cassandra Session instrumen…

…tation, fixes #1058
kamon-io · Oct 5, 2021 · c5ac1ea · c5ac1ea
1 parent cd3bb14
commit c5ac1ea
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...cassandra/src/main/scala/kamon/instrumentation/cassandra/driver/InstrumentedSession.scala b/...cassandra/src/main/scala/kamon/instrumentation/cassandra/driver/InstrumentedSession.scala
@@ -160,8 +160,9 @@ class InstrumentedSession(underlying: Session) extends AbstractSession {
     * @return dml statement type, none if not a dml statement
     */
   private def extractStatementType(query: String): Option[String] = {
-    Option(query.substring(0, query.indexOf(" ")).toLowerCase)
+    Try(query.substring(0, query.indexOf(" ")).toLowerCase)
       .filter(DmlStatementPrefixes.contains)
+      .toOption
   }
 
   private def unsafeExtractExecutor(session: Session): ListeningExecutorService = {