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 fef24f1d89607f..98ba42b970333e 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);