diff --git a/src/main/java/org/tikv/common/importer/ImporterStoreClient.java b/src/main/java/org/tikv/common/importer/ImporterStoreClient.java index 006bf517334..79c302c314c 100644 --- a/src/main/java/org/tikv/common/importer/ImporterStoreClient.java +++ b/src/main/java/org/tikv/common/importer/ImporterStoreClient.java @@ -167,7 +167,7 @@ public void switchMode(ImportSstpb.SwitchMode mode) { @Override protected ImportSSTGrpc.ImportSSTBlockingStub getBlockingStub() { - return blockingStub.withDeadlineAfter(conf.getTimeout(), TimeUnit.MILLISECONDS); + return blockingStub.withDeadlineAfter(conf.getIngestTimeout(), TimeUnit.MILLISECONDS); } @Override