Skip to content

Commit 64d77d2

Browse files
committed
Fix the problem when closing bucket.
1 parent 612b587 commit 64d77d2

File tree

1 file changed

+2
-0
lines changed
  • streamis-jobmanager/streamis-job-log/streamis-job-log-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/server/storage

1 file changed

+2
-0
lines changed

streamis-jobmanager/streamis-job-log/streamis-job-log-server/src/main/java/com/webank/wedatasphere/streamis/jobmanager/log/server/storage/StreamisJobLogStorage.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,8 @@ public synchronized void init() {
9797
LOG.info("Close the idle bucket: [ name: {}, last-write-time: {} ]",
9898
bucketName, dateFormat.format(bucketState.getBucketWriteTime()));
9999
bucket.close();
100+
// Delete the bucket
101+
buckets.remove(bucketName);
100102
}
101103

102104
});

0 commit comments

Comments
 (0)