From 06befc45ede260c4d3217079363cb9521176d6bf Mon Sep 17 00:00:00 2001
From: kangkaisen <kangkaisen@apache.org>
Date: Mon, 11 Nov 2019 14:20:32 +0800
Subject: [PATCH] Support decrease edit_log_roll_num config (#2171)

---
 fe/src/main/java/org/apache/doris/persist/EditLog.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/fe/src/main/java/org/apache/doris/persist/EditLog.java b/fe/src/main/java/org/apache/doris/persist/EditLog.java
index 41def65dc8..81f5743469 100644
--- a/fe/src/main/java/org/apache/doris/persist/EditLog.java
+++ b/fe/src/main/java/org/apache/doris/persist/EditLog.java
@@ -762,8 +762,9 @@ public class EditLog {
                     txId, numTransactions, totalTimeTransactions, op);
         }
 
-        if (txId == Config.edit_log_roll_num) {
-            LOG.info("txId is equal to edit_log_roll_num {}, will roll edit.", txId);
+        if (txId >= Config.edit_log_roll_num) {
+            LOG.info("txId {} is equal to or larger than edit_log_roll_num {}, will roll edit.",
+                    txId, Config.edit_log_roll_num);
             rollEditLog();
             txId = 0;
         }