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

fix npe

Browse Source
This commit is contained in:
fariel 2021-09-09 15:30:01 +08:00
parent 1e03c200f7
commit 16a6151919
1 changed files with 1 additions and 1 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

@ -96,7 +96,7 @@ public class StarRocksStreamLoadVisitor {
private byte[] joinRows(List<String> rows, int totalBytes) { private byte[] joinRows(List<String> rows, int totalBytes) {
if (StarRocksWriterOptions.StreamLoadFormat.CSV.equals(writerOptions.getStreamLoadFormat())) { if (StarRocksWriterOptions.StreamLoadFormat.CSV.equals(writerOptions.getStreamLoadFormat())) {
Map<String, Object> props = writerOptions.getLoadProps(); Map<String, Object> props = writerOptions.getLoadProps();
byte[] lineDelimiter = (props.containsKey("row_delimiter") ? StarRocksDelimiterParser.parse(String.valueOf(props.get("row_delimiter")), "\n") : "\n").getBytes(StandardCharsets.UTF_8); byte[] lineDelimiter = StarRocksDelimiterParser.parse((String)props.get("row_delimiter"), "\n").getBytes(StandardCharsets.UTF_8);
ByteBuffer bos = ByteBuffer.allocate(totalBytes + rows.size() * lineDelimiter.length); ByteBuffer bos = ByteBuffer.allocate(totalBytes + rows.size() * lineDelimiter.length);
for (String row : rows) { for (String row : rows) {
bos.put(row.getBytes(StandardCharsets.UTF_8)); bos.put(row.getBytes(StandardCharsets.UTF_8));