Fix copilot suggestions

Author: mzitnik

flink-connector-clickhouse-base/src/main/java/org/apache/flink/connector/clickhouse/convertor/ClickHouseConvertor.java

@@ -7,6 +7,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.nio.charset.StandardCharsets;
+
 
 public class ClickHouseConvertor<InputT> implements ElementConverter<InputT, ClickHousePayload> {
     private static final Logger LOG = LoggerFactory.getLogger(ClickHouseConvertor.class);
@@ -54,7 +56,7 @@ public ClickHousePayload apply( InputT o, SinkWriter.Context context) {
                 return new ClickHousePayload(null);
             }
             if (payload.endsWith("\n"))
-                return new ClickHousePayload(payload.getBytes());
+                return new ClickHousePayload(payload.getBytes(StandardCharsets.UTF_8));
             return new ClickHousePayload((payload + "\n").getBytes());
         }
         if (type == Types.POJO) {

flink-connector-clickhouse-base/src/main/java/org/apache/flink/connector/clickhouse/sink/ClickHouseAsyncSinkSerializer.java

@@ -10,7 +10,7 @@
 import java.io.IOException;
 
 public class ClickHouseAsyncSinkSerializer extends AsyncSinkWriterStateSerializer<ClickHousePayload> {
-    private static final Logger LOG = LoggerFactory.getLogger(AsyncSinkWriterStateSerializer.class);
+    private static final Logger LOG = LoggerFactory.getLogger(ClickHouseAsyncSinkSerializer.class);
 
     @Override
     protected void serializeRequestToStream(ClickHousePayload clickHousePayload, DataOutputStream dataOutputStream) throws IOException {

flink-connector-clickhouse-base/src/test/java/org/apache/flink/connector/clickhouse/sink/ClickHouseSinkTests.java

@@ -212,7 +212,7 @@ void SimplePOJODataTest() throws Exception {
         env.setParallelism(5);
 
         ClickHouseClientConfig clickHouseClientConfig = new ClickHouseClientConfig(getServerURL(), getUsername(), getPassword(), getDatabase(), tableName);
-        ElementConverter<SimplePOJO, ClickHousePayload> convertorCovid = new ClickHouseConvertor<>(CovidPOJO.class, simplePOJOConvertor);
+        ElementConverter<SimplePOJO, ClickHousePayload> convertorCovid = new ClickHouseConvertor<>(SimplePOJO.class, simplePOJOConvertor);
 
         ClickHouseAsyncSink<SimplePOJO> simplePOJOSink = new ClickHouseAsyncSink<>(
                 convertorCovid,