optimize ttl (#2669)

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

@@ -117,11 +117,10 @@ public static TiSession getInstance(TiConfiguration conf) {
     }
   }
 
-
   public ChannelFactory getChannelFactory() {
     return this.channelFactory;
   }
-  
+
   public TxnKVClient createTxnClient() {
     return new TxnKVClient(conf, this.getRegionStoreClientBuilder(), this.getPDClient());
   }
@@ -224,9 +223,7 @@ public Map<String, Boolean> getStoreStatusCache() {
           storeStatusCacheExecutor.scheduleAtFixedRate(
               () -> {
                 storeStatusCache.replaceAll(
-                    (k, v) ->
-                        RegionStoreClient.isMppAlive(
-                            channelFactory.getChannel(k)));
+                    (k, v) -> RegionStoreClient.isMppAlive(channelFactory.getChannel(k)));
               },
               0,
               5,

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),

tikv-client/src/main/java/com/pingcap/tikv/operation/iterator/DAGIterator.java

@@ -286,11 +286,7 @@ public Boolean isMppStoreAlive(String address) {
       Map<String, Boolean> storeStatusCache = session.getStoreStatusCache();
       return storeStatusCache.computeIfAbsent(
           address,
-          key ->
-              RegionStoreClient.isMppAlive(
-                  session
-                      .getChannelFactory()
-                      .getChannel(address)));
+          key -> RegionStoreClient.isMppAlive(session.getChannelFactory().getChannel(address)));
     } catch (Exception e) {
       throw new TiClientInternalException("Error get MppStore Status.", e);
     }

tikv-client/src/main/java/com/pingcap/tikv/region/RegionManager.java

@@ -68,7 +68,7 @@ public RegionManager(ReadOnlyPDClient pdClient) {
   }
 
   public synchronized void setCacheInvalidateCallback(
-          Function<CacheInvalidateEvent, Void> cacheInvalidateCallback) {
+      Function<CacheInvalidateEvent, Void> cacheInvalidateCallback) {
     this.cacheInvalidateCallback = cacheInvalidateCallback;
   }