This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 68ff6dbd [Chore](log) improvment log for stream load (#515)
68ff6dbd is described below
commit 68ff6dbd56d467978c39c1dac78730db91bad06a
Author: wudi <676366...@qq.com>
AuthorDate: Fri Nov 22 11:01:19 2024 +0800
[Chore](log) improvment log for stream load (#515)
---
.../java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
index 44ff573e..02c2df49 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
@@ -268,7 +268,14 @@ public class DorisStreamLoad implements Serializable {
if (statusCode == 200 && response.getEntity() != null) {
String loadResult = EntityUtils.toString(response.getEntity());
LOG.info("load Result {}", loadResult);
- return OBJECT_MAPPER.readValue(loadResult, RespContent.class);
+ RespContent respContent = OBJECT_MAPPER.readValue(loadResult,
RespContent.class);
+ if (respContent == null
+ || respContent.getLabel() == null
+ || respContent.getTxnId() == null) {
+ throw new DorisRuntimeException("Response error : " +
loadResult);
+ } else {
+ return respContent;
+ }
}
throw new StreamLoadException("stream load error: " +
response.getStatusLine().toString());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
