8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 20:22:12 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

[Bugfix]修复es索引create/delete死循环问题 (#1021)

Browse Source
This commit is contained in:
Richard
2023-05-30 17:03:34 +08:00
committed by EricZeng
parent 7bfe787e39
commit ffc115cb76
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java
View File

@@ -24,6 +24,7 @@ import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.util.CollectionUtils;
import java.util.*;
import java.util.stream.IntStream;
import static com.xiaojukeji.know.streaming.km.common.constant.ESConstant.*;
@@ -68,13 +69,11 @@ public class BaseMetricESDAO extends BaseESDAO {
String indexTemplate = templateLoaderUtil.getContextByFileName(indexName);
esOpClient.createIndexTemplateIfNotExist(indexName, indexTemplate);
//检查最近7天索引存在不存
for(int i = 0; i < INDEX_DAYS; i++){
String realIndex = IndexNameUtils.genDailyIndexName(indexName, i);
if(esOpClient.indexExist(realIndex)){continue;}
esOpClient.createIndex(realIndex);
}
int retainDays = indexExpireDays > INDEX_DAYS ? INDEX_DAYS : indexExpireDays;
// 检查最近【retainDays】天索引存在不存
IntStream.range(0, retainDays).mapToObj(i -> IndexNameUtils.genDailyIndexName(indexName, i))
.filter(realIndex -> !esOpClient.indexExist(realIndex))
.forEach(realIndex -> esOpClient.createIndex(realIndex));
} catch (Exception e) {
LOGGER.error("method=checkCurrentDayIndexExist||errMsg=exception!", e);
}
@@ -94,8 +93,7 @@ public class BaseMetricESDAO extends BaseESDAO {
indexExpireDays, indexList.subList(indexExpireDays, size));
}
indexList.subList(indexExpireDays, size).stream().forEach(
s -> esOpClient.delIndexByName(s));
indexList.subList(indexExpireDays, size).forEach(s -> esOpClient.delIndexByName(s));
}
}