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

add debug log

Browse Source
This commit is contained in:
fariel 2021-03-13 17:08:46 +08:00
parent adfb2581d3
commit 51b42804be
2 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisStreamLoadVisitor.java
View File

@ -1,7 +1,6 @@
package com.dorisdb.connector.datax.plugin.writer.doriswriter.manager;
import java.io.IOException;
import java.io.Serializable;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
@ -27,9 +26,7 @@ import java.util.List;
import java.util.Map;
public class DorisStreamLoadVisitor implements Serializable {
private static final long serialVersionUID = 1L;
public class DorisStreamLoadVisitor {
private static final Logger LOG = LoggerFactory.getLogger(DorisStreamLoadVisitor.class);
@ -57,9 +54,10 @@ public class DorisStreamLoadVisitor implements Serializable {
if (null == loadResult || !loadResult.containsKey(keyStatus)) {
throw new IOException("Unable to flush data to doris: unknown result status.");
}
LOG.debug(new StringBuilder("StreamLoad response:\n").append(JSON.toJSONString(loadResult)).toString());
if (loadResult.get(keyStatus).equals("Fail")) {
throw new IOException(
new StringBuilder("Failed to flush data to doris.").append(loadResult.get("Message").toString()).toString()
new StringBuilder("Failed to flush data to doris.\n").append(JSON.toJSONString(loadResult)).toString()
);
}
}

5
doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisWriterManager.java
View File

@ -4,16 +4,13 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
import com.dorisdb.connector.datax.plugin.writer.doriswriter.DorisWriterOptions;
public class DorisWriterManager implements Serializable {
private static final long serialVersionUID = 1L;
public class DorisWriterManager {
private static final Logger LOG = LoggerFactory.getLogger(DorisWriterManager.class);