optimize ttl (#2669) (#2672)

Author: ti-chi-bot

tikv-client/src/main/java/com/pingcap/tikv/TwoPhaseCommitter.java

@@ -82,10 +82,14 @@ public class TwoPhaseCommitter {
   private final ExecutorService executorService;
 
   public TwoPhaseCommitter(TiConfiguration conf, long startTime) {
+    this(conf, startTime, DEFAULT_BATCH_WRITE_LOCK_TTL);
+  }
+
+  public TwoPhaseCommitter(TiConfiguration conf, long startTime, long lockTTL) {
     this.kvClient = TiSession.getInstance(conf).createTxnClient();
     this.regionManager = kvClient.getRegionManager();
     this.startTs = startTime;
-    this.lockTTL = DEFAULT_BATCH_WRITE_LOCK_TTL;
+    this.lockTTL = lockTTL;
     this.retryCommitSecondaryKeys = true;
     this.txnPrewriteBatchSize = TXN_COMMIT_BATCH_SIZE;
     this.txnCommitBatchSize = TXN_COMMIT_BATCH_SIZE;

tikv-client/src/main/java/com/pingcap/tikv/allocator/RowIDAllocator.java

@@ -61,6 +61,7 @@ public final class RowIDAllocator implements Serializable {
   private final long step;
   private long end;
   private TiTimestamp timestamp;
+  private final long RowIDAllocatorTTL = 10000;
 
   private static final Logger LOG = LoggerFactory.getLogger(RowIDAllocator.class);
 
@@ -141,8 +142,10 @@ private void set(@Nonnull List<BytePairWrapper> pairs, @Nonnull TiTimestamp time
     if (!iterator.hasNext()) {
       return;
     }
+
     TiSession session = TiSession.getInstance(conf);
-    TwoPhaseCommitter twoPhaseCommitter = new TwoPhaseCommitter(conf, timestamp.getVersion());
+    TwoPhaseCommitter twoPhaseCommitter =
+        new TwoPhaseCommitter(conf, timestamp.getVersion(), RowIDAllocatorTTL);
     BytePairWrapper primaryPair = iterator.next();
     twoPhaseCommitter.prewritePrimaryKey(
         ConcreteBackOffer.newCustomBackOff(BackOffer.PREWRITE_MAX_BACKOFF),