diff --git a/streamis-jobmanager/streamis-job-log/streamis-job-log-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/server/storage/StreamisJobLogStorage.java b/streamis-jobmanager/streamis-job-log/streamis-job-log-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/server/storage/StreamisJobLogStorage.java
index 77dddc0be..5f3134a72 100644
--- a/streamis-jobmanager/streamis-job-log/streamis-job-log-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/server/storage/StreamisJobLogStorage.java
+++ b/streamis-jobmanager/streamis-job-log/streamis-job-log-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/server/storage/StreamisJobLogStorage.java
@@ -160,7 +160,8 @@ public synchronized void init() throws Exception{
                                 LOG.info("Close the idle bucket: [ name: {}, last-write-time: {} ]",
                                         bucketName, dateFormat.format(bucketState.getBucketWriteTime()));
                                 closeBucket = true;
-                            } if (Objects.nonNull(bucketDriftPolicy) && bucketDriftPolicy.onPolicy(bucket, contexts)){
+                            }
+                            if (Objects.nonNull(bucketDriftPolicy) && bucketDriftPolicy.onPolicy(bucket, contexts)){
                                 LOG.info("Drift the bucket: [ name: {}, last-write-time: {} ]", bucketName,
                                         dateFormat.format(bucketState.getBucketWriteTime()));
                                 closeBucket = true;