github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 15:12:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix charset to utf-8

Browse Source
This commit is contained in:
hffariel 2021-09-15 19:58:29 +08:00
parent 39c7065526
commit 9e9fd10b44
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksStreamLoadVisitor.java
View File

@ -168,7 +168,7 @@ public class StarRocksStreamLoadVisitor {
private String getBasicAuthHeader(String username, String password) { private String getBasicAuthHeader(String username, String password) {
String auth = username + ":" + password; String auth = username + ":" + password;
byte[] encodedAuth = Base64.encodeBase64(auth.getBytes()); byte[] encodedAuth = Base64.encodeBase64(auth.getBytes(StandardCharsets.UTF_8));
return new StringBuilder("Basic ").append(new String(encodedAuth)).toString(); return new StringBuilder("Basic ").append(new String(encodedAuth)).toString();
} }

3
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java
View File

@ -4,6 +4,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import java.io.IOException; import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.UUID; import java.util.UUID;
@ -38,7 +39,7 @@ public class StarRocksWriterManager {
try { try {
buffer.add(record); buffer.add(record);
batchCount++; batchCount++;
batchSize += record.getBytes().length; batchSize += record.getBytes(StandardCharsets.UTF_8).length;
if (batchCount >= writerOptions.getBatchRows() || batchSize >= writerOptions.getBatchSize()) { if (batchCount >= writerOptions.getBatchRows() || batchSize >= writerOptions.getBatchSize()) {
String label = createBatchLabel(); String label = createBatchLabel();
LOG.debug(String.format("StarRocks buffer Sinking triggered: rows[%d] label[%s].", batchCount, label)); LOG.debug(String.format("StarRocks buffer Sinking triggered: rows[%d] label[%s].", batchCount, label));