This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new cf057bfb096 branch-3.0: [fix](load) fix concurrent read and write to
runningTxnIds #51615 (#51639)
cf057bfb096 is described below
commit cf057bfb0960e9622e2e187a5eac86d45b1a8156
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jun 11 20:57:03 2025 +0800
branch-3.0: [fix](load) fix concurrent read and write to runningTxnIds
#51615 (#51639)
Cherry-picked from #51615
Co-authored-by: hui lai <lai...@selectdb.com>
---
.../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 e5b01c50e26..bd20e9b78d1 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
@@ -21,13 +21,13 @@ import org.apache.doris.common.io.Text;
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;
import java.io.IOException;
import java.util.Map;
import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
public class RoutineLoadStatistic {
/*
@@ -65,7 +65,7 @@ public class RoutineLoadStatistic {
// 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();
public static RoutineLoadStatistic read(DataInput in) throws IOException {
String json = Text.readString(in);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
