bug: fixing logging for table not existing

lensesio · Sep 8, 2017 · a737953 · a737953
1 parent 8b2ced9
commit a737953
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-kudu/src/main/scala/com/datamountaineer/streamreactor/connect/kudu/sink/KuduWriter.scala b/...-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: _*)