This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new a461ff3c8a7 branch-2.1: [fix](load) fix concurrent read and write to
runningTxnIds #51615 (#51640)
a461ff3c8a7 is described below
commit a461ff3c8a77002fbe470afc243bc4e62f1fa581
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jun 17 09:26:33 2025 +0800
branch-2.1: [fix](load) fix concurrent read and write to runningTxnIds
#51615 (#51640)
Cherry-picked from #51615
Co-authored-by: hui lai <[email protected]>
---
.../java/org/apache/doris/load/routineload/RoutineLoadStatistic.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadStatistic.java
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadStatistic.java
index f7c089cfbc3..dc07ce7e8ba 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadStatistic.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadStatistic.java
@@ -22,7 +22,6 @@ import org.apache.doris.common.io.Writable;
import org.apache.doris.persist.gson.GsonUtils;
import com.google.common.collect.Maps;
-import com.google.common.collect.Sets;
import com.google.gson.annotations.SerializedName;
import java.io.DataInput;
@@ -30,6 +29,7 @@ import java.io.DataOutput;
import java.io.IOException;
import java.util.Map;
import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
public class RoutineLoadStatistic implements Writable {
/*
@@ -67,7 +67,7 @@ public class RoutineLoadStatistic implements Writable {
// Save all transactions current running. Including PREPARE, COMMITTED.
// No need to persist, only for tracing txn of routine load job.
- public Set<Long> runningTxnIds = Sets.newHashSet();
+ public Set<Long> runningTxnIds = ConcurrentHashMap.newKeySet();
@Override
public void write(DataOutput out) throws IOException {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
