diff --git a/lib/addax-rdbms/src/main/java/com/wgzhao/addax/rdbms/writer/CommonRdbmsWriter.java b/lib/addax-rdbms/src/main/java/com/wgzhao/addax/rdbms/writer/CommonRdbmsWriter.java
index 59ddf584f..8af9f4783 100644
--- a/lib/addax-rdbms/src/main/java/com/wgzhao/addax/rdbms/writer/CommonRdbmsWriter.java
+++ b/lib/addax-rdbms/src/main/java/com/wgzhao/addax/rdbms/writer/CommonRdbmsWriter.java
@@ -561,7 +561,7 @@ protected PreparedStatement fillPreparedStatementColumnType(PreparedStatement pr
                     break;
 
                 default:
-                    Map map = this.resultSetMetaData.get(columnIndex);
+                    Map<String, Object> map = this.resultSetMetaData.get(columnIndex);
                     throw AddaxException.asAddaxException(
                             DBUtilErrorCode.UNSUPPORTED_TYPE,
                             String.format(
diff --git a/plugin/reader/accessreader/src/main/java/com/wgzhao/addax/plugin/reader/accessreader/AccessReader.java b/plugin/reader/accessreader/src/main/java/com/wgzhao/addax/plugin/reader/accessreader/AccessReader.java
index b6b67c4f2..8011c7a18 100644
--- a/plugin/reader/accessreader/src/main/java/com/wgzhao/addax/plugin/reader/accessreader/AccessReader.java
+++ b/plugin/reader/accessreader/src/main/java/com/wgzhao/addax/plugin/reader/accessreader/AccessReader.java
@@ -7,8 +7,6 @@
 import com.wgzhao.addax.common.util.Configuration;
 import com.wgzhao.addax.rdbms.reader.CommonRdbmsReader;
 import com.wgzhao.addax.rdbms.util.DataBaseType;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.List;
 
@@ -17,8 +15,6 @@ public class AccessReader extends Reader {
 
     public static class Job extends Reader.Job {
 
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-
         private Configuration configuration = null;
 
         private CommonRdbmsReader.Job commonRdbmsReaderJob;
diff --git a/plugin/reader/databendreader/src/main/java/com/wgzhao/addax/plugin/reader/databendreader/DatabendReader.java b/plugin/reader/databendreader/src/main/java/com/wgzhao/addax/plugin/reader/databendreader/DatabendReader.java
index 764752d43..c6c83c817 100644
--- a/plugin/reader/databendreader/src/main/java/com/wgzhao/addax/plugin/reader/databendreader/DatabendReader.java
+++ b/plugin/reader/databendreader/src/main/java/com/wgzhao/addax/plugin/reader/databendreader/DatabendReader.java
@@ -26,8 +26,6 @@
 import com.wgzhao.addax.common.util.Configuration;
 import com.wgzhao.addax.rdbms.reader.CommonRdbmsReader;
 import com.wgzhao.addax.rdbms.util.DataBaseType;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.List;
 
@@ -40,8 +38,6 @@ public class DatabendReader
     public static class Job
             extends Reader.Job
     {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-
         private Configuration originalConfig = null;
         private CommonRdbmsReader.Job commonRdbmsReaderJob;
 
diff --git a/plugin/reader/datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/DataReader.java b/plugin/reader/datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/DataReader.java
index 1379b6adb..cd7734c4f 100644
--- a/plugin/reader/datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/DataReader.java
+++ b/plugin/reader/datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/DataReader.java
@@ -48,8 +48,6 @@
 import org.apache.commons.lang3.time.DateUtils;
 import org.apache.commons.rng.UniformRandomProvider;
 import org.apache.commons.rng.simple.RandomSource;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.math.BigDecimal;
 import java.text.ParseException;
@@ -95,8 +93,6 @@ private static boolean isTypeIllegal(String typeString)
     public static class Job
             extends Reader.Job
     {
-
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
         private Configuration originalConfig;
         private static final List<String> validUnits = Arrays.asList("d", "day", "M", "month", "y", "year", "h", "hour", "m", "minute",
                 "s", "second", "w", "week");
diff --git a/plugin/reader/influxdb2reader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDB2Reader.java b/plugin/reader/influxdb2reader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDB2Reader.java
index 54111a4f2..96a92f55f 100644
--- a/plugin/reader/influxdb2reader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDB2Reader.java
+++ b/plugin/reader/influxdb2reader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDB2Reader.java
@@ -54,8 +54,6 @@ public class InfluxDB2Reader
     public static class Job
             extends Reader.Job
     {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-
         private Configuration originalConfig = null;
         private String endpoint;
         private List<String> tables;
diff --git a/plugin/reader/influxdbreader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDBReader.java b/plugin/reader/influxdbreader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDBReader.java
index 8877a3faf..d9d737916 100644
--- a/plugin/reader/influxdbreader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDBReader.java
+++ b/plugin/reader/influxdbreader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDBReader.java
@@ -24,8 +24,6 @@
 import com.wgzhao.addax.common.spi.Reader;
 import com.wgzhao.addax.common.util.Configuration;
 import org.apache.commons.lang3.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -37,8 +35,6 @@ public class InfluxDBReader
     public static class Job
             extends Reader.Job
     {
-        private static final Logger LOG = LoggerFactory
-                .getLogger(Job.class);
 
         private Configuration originalConfig = null;
 
diff --git a/plugin/writer/databendwriter/src/main/java/com/wgzhao/addax/plugin/writer/databendwriter/DatabendWriter.java b/plugin/writer/databendwriter/src/main/java/com/wgzhao/addax/plugin/writer/databendwriter/DatabendWriter.java
index 10a7f9710..1ea3878dc 100755
--- a/plugin/writer/databendwriter/src/main/java/com/wgzhao/addax/plugin/writer/databendwriter/DatabendWriter.java
+++ b/plugin/writer/databendwriter/src/main/java/com/wgzhao/addax/plugin/writer/databendwriter/DatabendWriter.java
@@ -7,8 +7,6 @@
 import com.wgzhao.addax.plugin.writer.databendwriter.util.DatabendWriterUtil;
 import com.wgzhao.addax.rdbms.util.DataBaseType;
 import com.wgzhao.addax.rdbms.writer.CommonRdbmsWriter;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
@@ -20,7 +18,6 @@ public class DatabendWriter extends Writer {
 
     public static class Job
             extends Writer.Job {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
         private Configuration originalConfig;
         private CommonRdbmsWriter.Job commonRdbmsWriterMaster;
 
@@ -62,7 +59,6 @@ public void destroy() {
 
 
     public static class Task extends Writer.Task {
-        private static final Logger LOG = LoggerFactory.getLogger(Task.class);
 
         private Configuration writerSliceConfig;
 
diff --git a/plugin/writer/influxdbwriter/src/main/java/com/wgzhao/addax/plugin/writer/influxdbwriter/InfluxDBWriter.java b/plugin/writer/influxdbwriter/src/main/java/com/wgzhao/addax/plugin/writer/influxdbwriter/InfluxDBWriter.java
index 9c81811cb..c55b56f54 100644
--- a/plugin/writer/influxdbwriter/src/main/java/com/wgzhao/addax/plugin/writer/influxdbwriter/InfluxDBWriter.java
+++ b/plugin/writer/influxdbwriter/src/main/java/com/wgzhao/addax/plugin/writer/influxdbwriter/InfluxDBWriter.java
@@ -26,8 +26,6 @@
 import org.influxdb.InfluxDB;
 import org.influxdb.InfluxDBFactory;
 import org.influxdb.dto.Query;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -39,8 +37,6 @@ public class InfluxDBWriter
     public static class Job
             extends Writer.Job
     {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-
         private Configuration originalConfig = null;
 
         private String endpoint;
diff --git a/plugin/writer/kafkawriter/src/main/java/com/wgzhao/addax/plugin/writer/kafkawriter/KafkaWriter.java b/plugin/writer/kafkawriter/src/main/java/com/wgzhao/addax/plugin/writer/kafkawriter/KafkaWriter.java
index 5d942a9c9..e2f2aac5d 100644
--- a/plugin/writer/kafkawriter/src/main/java/com/wgzhao/addax/plugin/writer/kafkawriter/KafkaWriter.java
+++ b/plugin/writer/kafkawriter/src/main/java/com/wgzhao/addax/plugin/writer/kafkawriter/KafkaWriter.java
@@ -25,8 +25,6 @@
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringSerializer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.Collections;
 import java.util.HashMap;
@@ -48,7 +46,6 @@ public class KafkaWriter
     public static class Job
             extends Writer.Job
     {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
         private Configuration config = null;
 
         @Override