Support cancel and fix error timer window

CalvinKirs · Nov 30, 2023 · 2f7d808 · 2f7d808
1 parent 9163e8a
commit 2f7d808
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/txn/Transaction.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/txn/Transaction.java
@@ -47,7 +47,6 @@
 import com.google.common.base.Strings;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Lists;
-import lombok.Getter;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
@@ -67,7 +66,6 @@ public class Transaction {
     private int filteredRows = 0;
     private TransactionStatus txnStatus = TransactionStatus.ABORTED;
     private String errMsg = "";
-    @Getter
     private final Coordinator coordinator;
 
     /**
@@ -247,4 +245,8 @@ public void executeInsertIntoTableCommand(StmtExecutor executor, long jobId) {
         // update it, so that user can get loaded rows in fe.audit.log
         ctx.updateReturnRows((int) loadedRows);
     }
+
+    public Coordinator getCoordinator() {
+        return coordinator;
+    }
 }