Changing body

SeniorDesignGroup5 · Mar 6, 2019 · d1e00eb · d1e00eb
1 parent 16eae2d
commit d1e00eb
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala
@@ -14,8 +14,6 @@ import org.json4s.JsonDSL._
 import scala.collection.JavaConversions._
 
 class OpenTSDBOutput extends Serializable {
-
-  private[this] val logger = Logger.getLogger(getClass().getName());
 
   def putOpentsdb[T](opentsdbIP: String, stream: DStream[DataPackage]) = {
     stream.mapPartitions(partition => {
@@ -53,13 +51,11 @@ class OpenTSDBOutput extends Serializable {
                     |        "timestamp": $timestamp,
                     |        "tags": {"generator": $generator_id, "state": "$state", "region": "$region"}
                     |},""";
-                body.concat(pstring);
+                pstring.stripMargin;
+                body = body.concat(pstring);
              }
           }
-          body.concat("]");
-
-          logger.info(body);
-
+          body = body.concat("]");
           var openTSDBUrl = "http://" + opentsdbIP + "/api/put"
           try {
                 val httpClient = new DefaultHttpClient()