File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
src/main/scala/lerna/akka/entityreplication/raft Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -466,11 +466,7 @@ private[raft] class RaftActor(
466466 ) {
467467 val estimatedCompactedLogSize : Int =
468468 currentData.estimatedReplicatedLogSizeAfterCompaction(settings.compactionPreserveLogSize)
469- if (snapshotSynchronizationIsInProgress) {
470- // Snapshot updates during synchronizing snapshot will break consistency
471- if (log.isInfoEnabled)
472- log.info(" Skipping compaction because snapshot synchronization is in progress" )
473- } else if (estimatedCompactedLogSize >= settings.compactionLogSizeThreshold) {
469+ if (estimatedCompactedLogSize >= settings.compactionLogSizeThreshold) {
474470 if (log.isWarningEnabled) {
475471 log.warning(
476472 " [{}] Skipping compaction since compaction might not delete enough entries " +
@@ -484,6 +480,10 @@ private[raft] class RaftActor(
484480 currentData.eventSourcingIndex,
485481 )
486482 }
483+ } else if (snapshotSynchronizationIsInProgress) {
484+ // Snapshot updates during synchronizing snapshot will break consistency
485+ if (log.isInfoEnabled)
486+ log.info(" Skipping compaction because snapshot synchronization is in progress" )
487487 } else {
488488 val (term, logEntryIndex, entityIds) = currentData.resolveSnapshotTargets()
489489 applyDomainEvent(SnapshottingStarted (term, logEntryIndex, entityIds)) { _ =>
You can’t perform that action at this time.
0 commit comments