From 9f9e80a2d293f7a88d98d017e6df6d56f127cdcd Mon Sep 17 00:00:00 2001 From: PengFei Li Date: Tue, 14 Jan 2025 19:57:47 +0800 Subject: [PATCH] Add TODO Signed-off-by: PengFei Li --- .../java/com/starrocks/load/batchwrite/BatchWriteMgr.java | 2 +- .../com/starrocks/load/batchwrite/TxnStateDispatcher.java | 5 ++++- 2 files changed, 5 insertions(+), 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 index bd06b6696a4e8..82ab0214735ba 100644 --- 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 index fef24f1d89607..98ba42b970333 100644 --- 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);