remove logger

Author: dapeng

kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/CustomerKeyedSerializationSchema.java

@@ -2,23 +2,15 @@
 
 
 import com.dtstack.flink.sql.format.SerializationMetricWrapper;
-import org.apache.flink.api.common.functions.RuntimeContext;
 import org.apache.flink.api.common.serialization.SerializationSchema;
-import org.apache.flink.formats.json.JsonRowSchemaConverter;
 import org.apache.flink.formats.json.JsonRowSerializationSchema;
-import org.apache.flink.metrics.Counter;
-import org.apache.flink.metrics.Meter;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode;
 import org.apache.flink.streaming.util.serialization.KeyedSerializationSchema;
 import org.apache.flink.types.Row;
-import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 public class CustomerKeyedSerializationSchema implements KeyedSerializationSchema<Row> {
 
-    private Logger log = LoggerFactory.getLogger(getClass());
-
     private static final long serialVersionUID = 1L;
     private final SerializationMetricWrapper serializationMetricWrapper;
     private String[] partitionKeys;
@@ -61,7 +53,7 @@ private byte[] serializeJsonKey(JsonRowSerializationSchema jsonRowSerializationS
             }
             return sb.toString().getBytes();
         }catch (Exception e){
-            log.error("serializeJsonKey error", e);
+
         }
         return null;