This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 8429353e79e [fix](routine-load) fix routine load lock do not release
(#33275)
8429353e79e is described below
commit 8429353e79ea367a342af3a27a3c4deb26acb541
Author: HHoflittlefish777 <[email protected]>
AuthorDate: Sat Apr 6 08:49:18 2024 +0800
[fix](routine-load) fix routine load lock do not release (#33275)
---
.../main/java/org/apache/doris/load/routineload/RoutineLoadJob.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
index 1af051e183c..121d73b5d75 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
@@ -1102,7 +1102,9 @@ public abstract class RoutineLoadJob extends
AbstractTxnStateChangeCallback impl
@Override
public void afterCommitted(TransactionState txnState, boolean txnOperated)
throws UserException {
long taskBeId = -1L;
- writeLock();
+ if (Config.isCloudMode()) {
+ writeLock();
+ }
try {
if (txnOperated) {
// find task in job
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
