diff --git a/src/main/java/org/tikv/common/TiSession.java b/src/main/java/org/tikv/common/TiSession.java index f8ad6eba08e..9618562b101 100644 --- a/src/main/java/org/tikv/common/TiSession.java +++ b/src/main/java/org/tikv/common/TiSession.java @@ -392,7 +392,8 @@ public SwitchTiKVModeClient getSwitchTiKVModeClient() { if (res == null) { synchronized (this) { if (switchTiKVModeClient == null) { - switchTiKVModeClient = new SwitchTiKVModeClient(getPDClient(), getImporterRegionStoreClientBuilder()); + switchTiKVModeClient = + new SwitchTiKVModeClient(getPDClient(), getImporterRegionStoreClientBuilder()); } res = switchTiKVModeClient; } @@ -589,7 +590,7 @@ private synchronized void cleanAfterTerminated() throws InterruptedException { catalog.close(); } - if(switchTiKVModeClient != null) { + if (switchTiKVModeClient != null) { switchTiKVModeClient.stopKeepTiKVToImportMode(); } }