From d1e00ebcd06f67e0e55cc45d544699aa00d6aa24 Mon Sep 17 00:00:00 2001 From: Evan Langlais Date: Wed, 6 Mar 2019 16:09:25 -0500 Subject: [PATCH] Changing body --- src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala index c4b360d..71550ff 100644 --- 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()