lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(queue): 修复queue备份文件名错误导致deque也存在数据

Browse Source
This commit is contained in:
兰缘小妖
2024-02-04 16:31:54 +08:00
parent b9175dc1e4
commit f6eb68199c
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java
View File

@@ -18,7 +18,7 @@ public interface Constants {
ConcurrentHashMap<String, PriorityBlockingQueue<QueueItem<?>>> QUEUE_MAP = new ConcurrentHashMap<>(10); ConcurrentHashMap<String, PriorityBlockingQueue<QueueItem<?>>> QUEUE_MAP = new ConcurrentHashMap<>(10);
String DEQUE_SAVE_FILENAME = "save_data_deque"; String DEQUE_SAVE_FILENAME = "save_data_deque";
String QUEUE_SAVE_FILENAME = "save_data_deque"; String QUEUE_SAVE_FILENAME = "save_data_queue";
TimeUnit TIMEOUT_UNIT = TimeUnit.SECONDS; TimeUnit TIMEOUT_UNIT = TimeUnit.SECONDS;
long POLL_TIMEOUT = 1; long POLL_TIMEOUT = 1;

2
service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java
View File

@@ -48,7 +48,7 @@ public class AutoSaveService {
} }
private void save(Map<String, ? extends Queue<?>> o, String name) throws IOException { private void save(Map<String, ? extends Queue<?>> o, String name) throws IOException {
if (o == null) { if (o == null || o.isEmpty()) {
return; return;
} }
Map<String, List<?>> map = new HashMap<>(o.size()); Map<String, List<?>> map = new HashMap<>(o.size());