This is an automated email from the ASF dual-hosted git repository.
JNSimba 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 a0164d96 [Fix] fix DorisWriter abort wrong transaction (#683)
a0164d96 is described below
commit a0164d96e3d502ba7cd958bcc4787e994909ce6b
Author: Glenn <[email protected]>
AuthorDate: Tue Aug 18 11:51:43 2026 +0800
[Fix] fix DorisWriter abort wrong transaction (#683)
Co-authored-by: tanjialiang <[email protected]>
---
.../src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink-doris-connector/flink-doris-connector-base/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java
b/flink-doris-connector/flink-doris-connector-base/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java
index 19a3d8ad..69a3e04e 100644
---
a/flink-doris-connector/flink-doris-connector-base/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java
+++
b/flink-doris-connector/flink-doris-connector-base/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java
@@ -257,8 +257,8 @@ public class DorisWriter<IN> {
// the txn of successful precommit cannot be aborted.
if (executionOptions.enabled2PC() && multiTableLoad) {
LOG.info("Try to abort may have successfully preCommitted label.");
- for (Map.Entry<String, DorisStreamLoad> entry :
dorisStreamLoadMap.entrySet()) {
- DorisStreamLoad abortLoader = entry.getValue();
+ for (String key : loadingMap.keySet()) {
+ DorisStreamLoad abortLoader = dorisStreamLoadMap.get(key);
try {
abortLoader.abortTransactionByLabel(abortLoader.getCurrentLabel());
} catch (Exception ex) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
