Reenabling logger

SeniorDesignGroup5 · Mar 6, 2019 · 96b0563 · 96b0563
1 parent d1e00eb
commit 96b0563
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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()