diff --git a/jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/device/PersistenceDeviceSessionManager.java b/jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/device/PersistenceDeviceSessionManager.java index cb211fcf..6e4a5a9d 100644 --- a/jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/device/PersistenceDeviceSessionManager.java +++ b/jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/device/PersistenceDeviceSessionManager.java @@ -96,6 +96,7 @@ public class PersistenceDeviceSessionManager extends ClusterDeviceSessionManager .map(session -> session.unwrap(PersistentSession.class)) .as(this::tryPersistent) .block(); + repository.store.compactMoveChunks(); repository.store.close(); }