You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by fa...@apache.org on 2022/07/04 02:47:39 UTC
[incubator-seatunnel] branch dev updated: Fix the bug Unrecognized field "TwoPhaseCommit" after doris 0.15 (#2054)
This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 418e40818 Fix the bug Unrecognized field "TwoPhaseCommit" after doris 0.15 (#2054)
418e40818 is described below
commit 418e40818d108c4b4330061dde688ac9eb9f8363
Author: Hong Liu <84...@qq.com>
AuthorDate: Mon Jul 4 10:47:34 2022 +0800
Fix the bug Unrecognized field "TwoPhaseCommit" after doris 0.15 (#2054)
Co-authored-by: smallhibiscus <844981280>
---
.../org/apache/seatunnel/flink/doris/sink/RespContent.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/RespContent.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/RespContent.java
index 2f1886117..67bf3781e 100644
--- a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/RespContent.java
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/RespContent.java
@@ -38,6 +38,9 @@ public class RespContent implements Serializable {
*/
@JsonProperty("Label")
private String label;
+
+ @JsonProperty("TwoPhaseCommit")
+ private String twoPhaseCommit;
/**
* Import complete status.
* "Success": Indicates that the import was successful.
@@ -140,6 +143,14 @@ public class RespContent implements Serializable {
this.label = label;
}
+ public String getTwoPhaseCommit() {
+ return twoPhaseCommit;
+ }
+
+ public void setTwoPhaseCommit(String twoPhaseCommit) {
+ this.twoPhaseCommit = twoPhaseCommit;
+ }
+
public String getStatus() {
return status;
}
@@ -265,6 +276,7 @@ public class RespContent implements Serializable {
return "RespContent{" +
"txnId=" + txnId +
", label='" + label + '\'' +
+ ", twoPhaseCommit='" + twoPhaseCommit + '\'' +
", status='" + status + '\'' +
", existingJobStatus='" + existingJobStatus + '\'' +
", message='" + message + '\'' +