remove printing of settings

lensesio · Aug 31, 2016 · 3f17b28 · 3f17b28
1 parent 2756b6d
commit 3f17b28
Show file tree

Hide file tree

Showing 5 changed files with 1 addition and 13 deletions.
diff --git a/...uxdb/src/main/scala/com/datamountaineer/streamreactor/connect/influx/InfluxSinkTask.scala b/...uxdb/src/main/scala/com/datamountaineer/streamreactor/connect/influx/InfluxSinkTask.scala
@@ -61,13 +61,11 @@ class InfluxSinkTask extends SinkTask with StrictLogging {
     val sinkConfig = InfluxSinkConfig(props)
     val influxSettings = InfluxSettings(sinkConfig)
 
-
     //if error policy is retry set retry interval
     if (influxSettings.errorPolicy.equals(ErrorPolicyEnum.RETRY)) {
       context.timeout(sinkConfig.getInt(InfluxSinkConfig.ERROR_RETRY_INTERVAL_CONFIG).toLong)
     }
 
-    logger.info(s"Settings:$influxSettings")
     writer = Some(WriterFactoryFn(influxSettings))
   }
 

diff --git a/...onnect-jms/src/main/scala/com/datamountaineer/streamreactor/connect/jms/JMSSinkTask.scala b/...onnect-jms/src/main/scala/com/datamountaineer/streamreactor/connect/jms/JMSSinkTask.scala
@@ -67,10 +67,6 @@ class JMSSinkTask extends SinkTask with StrictLogging {
       context.timeout(sinkConfig.getInt(JMSSinkConfig.ERROR_RETRY_INTERVAL).toLong)
     }
 
-    logger.info(
-      s"""Settings:
-          |$settings
-      """.stripMargin)
     writer = Some(JMSWriter(settings))
   }
 

diff --git a/...s/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/RedisSinkTask.scala b/...s/src/main/scala/com/datamountaineer/streamreactor/connect/redis/sink/RedisSinkTask.scala
@@ -70,10 +70,6 @@ class RedisSinkTask extends SinkTask with StrictLogging {
       context.timeout(sinkConfig.getInt(RedisSinkConfig.ERROR_RETRY_INTERVAL).toLong)
     }
 
-    logger.info(
-      s"""Settings:
-          |$settings
-      """.stripMargin)
     writer = Some(RedisDbWriterFactory(settings))
   }
 

diff --git a/...ain/scala/com/datamountaineer/streamreactor/connect/redis/sink/writer/RedisDbWriter.scala b/...ain/scala/com/datamountaineer/streamreactor/connect/redis/sink/writer/RedisDbWriter.scala
@@ -32,7 +32,7 @@ import scala.util.Try
 case class RedisDbWriter(sinkSettings: RedisSinkSettings) extends DbWriter with StrictLogging with ConverterUtil with ErrorHandler {
   private val connection = sinkSettings.connection
   private val jedis = new Jedis(connection.host, connection.port)
-  connection.password.foreach(jedis.auth)
+  connection.password.foreach(p => jedis.auth(p))
 
   //initialize error tracker
   initialize(sinkSettings.taskRetries, sinkSettings.errorPolicy)

diff --git a/...voltdb/src/main/scala/com/datamountaineer/streamreactor/connect/voltdb/VoltSinkTask.scala b/...voltdb/src/main/scala/com/datamountaineer/streamreactor/connect/voltdb/VoltSinkTask.scala
@@ -67,8 +67,6 @@ class VoltSinkTask extends SinkTask with StrictLogging {
     if (voltSettings.errorPolicy.equals(ErrorPolicyEnum.RETRY)) {
       context.timeout(sinkConfig.getInt(VoltSinkConfig.ERROR_RETRY_INTERVAL_CONFIG).toLong)
     }
-
-    logger.info(s"Settings:$VoltSettings")
     writer = Some(new VoltDbWriter(voltSettings))
   }