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

don't set the columns header with json format

Browse Source
This commit is contained in:
hffariel 2021-12-07 11:48:51 +08:00
parent fa4505775d
commit 1e57429883
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

@ -137,7 +137,7 @@ public class StarRocksStreamLoadVisitor {
try (CloseableHttpClient httpclient = httpClientBuilder.build()) { try (CloseableHttpClient httpclient = httpClientBuilder.build()) {
HttpPut httpPut = new HttpPut(loadUrl); HttpPut httpPut = new HttpPut(loadUrl);
List<String> cols = writerOptions.getColumns(); List<String> cols = writerOptions.getColumns();
if (null != cols && !cols.isEmpty()) { if (null != cols && !cols.isEmpty() && StarRocksWriterOptions.StreamLoadFormat.CSV.equals(writerOptions.getStreamLoadFormat())) {
httpPut.setHeader("columns", String.join(",", cols.stream().map(f -> String.format("`%s`", f)).collect(Collectors.toList()))); httpPut.setHeader("columns", String.join(",", cols.stream().map(f -> String.format("`%s`", f)).collect(Collectors.toList())));
} }
if (null != writerOptions.getLoadProps()) { if (null != writerOptions.getLoadProps()) {