Skip to content

Commit 52fae4e

Browse files
committed
Use local data dirs for IoTConsensus snapshot receive
1 parent 5ec376a commit 52fae4e

2 files changed

Lines changed: 1 addition & 2 deletions

File tree

iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,6 @@
108108
public class IoTConsensusServerImpl {
109109

110110
public static final String SNAPSHOT_DIR_NAME = "snapshot";
111-
private static final String SNAPSHOT_LOG_NAME = "snapshot.log";
112111
private static final Pattern SNAPSHOT_INDEX_PATTEN = Pattern.compile(".*[^\\d](?=(\\d+))");
113112
private static final PerformanceOverviewMetrics PERFORMANCE_OVERVIEW_METRICS =
114113
PerformanceOverviewMetrics.getInstance();

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/DataRegionConsensusImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ private static ConsensusConfig buildConsensusConfig() {
140140
.setThisNodeId(CONF.getDataNodeId())
141141
.setThisNode(new TEndPoint(CONF.getInternalAddress(), CONF.getDataRegionConsensusPort()))
142142
.setStorageDir(CONF.getDataRegionConsensusDir())
143-
.setRecvSnapshotDirs(Arrays.asList(CONF.getDataDirs()))
143+
.setRecvSnapshotDirs(Arrays.asList(CONF.getLocalDataDirs()))
144144
.setConsensusGroupType(TConsensusGroupType.DataRegion)
145145
.setIoTConsensusConfig(
146146
IoTConsensusConfig.newBuilder()

0 commit comments

Comments
 (0)