up

WeDataSphere · May 29, 2023 · 1d41ac2 · 1d41ac2
1 parent d304b8e
commit 1d41ac2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...com/webank/wedatasphere/streamis/jobmanager/log/server/storage/StreamisJobLogStorage.java b/...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;