Add TODO

Signed-off-by: PengFei Li <lpengfei2016@gmail.com>
StarRocks · Jan 15, 2025 · 9f9e80a · 9f9e80a
1 parent 02c3ba1
commit 9f9e80a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/load/batchwrite/BatchWriteMgr.java b/fe/fe-core/src/main/java/com/starrocks/load/batchwrite/BatchWriteMgr.java
@@ -63,7 +63,7 @@ public class BatchWriteMgr extends FrontendDaemon {
     private final TxnStateDispatcher txnStateDispatcher;
 
     public BatchWriteMgr() {
-        super("group-commit-mgr", Config.merge_commit_gc_check_interval_ms);
+        super("merge-commit-mgr", Config.merge_commit_gc_check_interval_ms);
         this.idGenerator = new AtomicLong(0L);
         this.isomorphicBatchWriteMap = new ConcurrentHashMap<>();
         this.lock = new ReentrantReadWriteLock();

diff --git a/fe/fe-core/src/main/java/com/starrocks/load/batchwrite/TxnStateDispatcher.java b/fe/fe-core/src/main/java/com/starrocks/load/batchwrite/TxnStateDispatcher.java
@@ -39,7 +39,10 @@
 import java.util.concurrent.atomic.AtomicLong;
 import javax.annotation.Nullable;
 
-/** Dispatch transaction state to backends after the load finished. */
+/**
+ * Dispatch transaction state to backends after the load finished.
+ * TODO send txn states on the same backend in batch
+ */
 public class TxnStateDispatcher {
 
     private static final Logger LOG = LoggerFactory.getLogger(TxnStateDispatcher.class);