diff --git a/kafka-connect-kudu/src/main/scala/com/datamountaineer/streamreactor/connect/kudu/sink/KuduWriter.scala b/kafka-connect-kudu/src/main/scala/com/datamountaineer/streamreactor/connect/kudu/sink/KuduWriter.scala
index 37916cea6..c2e536d8b 100644
--- a/kafka-connect-kudu/src/main/scala/com/datamountaineer/streamreactor/connect/kudu/sink/KuduWriter.scala
+++ b/kafka-connect-kudu/src/main/scala/com/datamountaineer/streamreactor/connect/kudu/sink/KuduWriter.scala
@@ -55,7 +55,7 @@ class KuduWriter(client: KuduClient, setting: KuduSettings) extends StrictLoggin
   //pre create tables
   Try(DbHandler.createTables(setting, client)) match {
     case Success(_) =>
-    case Failure(f) => logger.warn("Unable to create tables at startup! Tables will be created on delivery of the first record", f)
+    case Failure(f) => logger.warn("Unable to create tables at startup! Tables will be created on delivery of the first record", f.getMessage)
   }
   //cache tables
   private lazy val kuduTablesCache = collection.mutable.Map(DbHandler.buildTableCache(setting, client).toSeq: _*)