From 96b0563fcfa27151ae156f88cb3ba280453205be Mon Sep 17 00:00:00 2001 From: Evan Langlais Date: Wed, 6 Mar 2019 16:18:00 -0500 Subject: [PATCH] Reenabling logger --- src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala index 71550ff..bdad99b 100644 --- a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala +++ b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala @@ -15,6 +15,10 @@ import scala.collection.JavaConversions._ class OpenTSDBOutput extends Serializable { + object Holder extends Serializable { + @transient lazy val logger = Logger.getLogger(getClass.getName) + } + def putOpentsdb[T](opentsdbIP: String, stream: DStream[DataPackage]) = { stream.mapPartitions(partition => { var count = 0; @@ -56,6 +60,7 @@ class OpenTSDBOutput extends Serializable { } } body = body.concat("]"); + Holder.logger.info(body); var openTSDBUrl = "http://" + opentsdbIP + "/api/put" try { val httpClient = new DefaultHttpClient()