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()