|
@@ -94,7 +94,7 @@ public class PackageHandler {
|
|
|
|
|
|
List<DBVal> dbVals = new ArrayList<>();
|
|
List<DBVal> dbVals = new ArrayList<>();
|
|
|
|
|
|
- log.debug("[{}]开始保存至磁盘", bufferIndex);
|
|
|
|
|
|
+ log.info("[{}]开始保存至磁盘", bufferIndex);
|
|
|
|
|
|
// 拼接即将写入磁盘的文件,并获取每一个longIndex
|
|
// 拼接即将写入磁盘的文件,并获取每一个longIndex
|
|
List<LogItem> logItems = new ArrayList<>(Globals.MAX_LOG_ITEM);
|
|
List<LogItem> logItems = new ArrayList<>(Globals.MAX_LOG_ITEM);
|
|
@@ -129,13 +129,13 @@ public class PackageHandler {
|
|
}
|
|
}
|
|
spentTimeCalculator.end();
|
|
spentTimeCalculator.end();
|
|
int insertCount = doubleIndexes.size();
|
|
int insertCount = doubleIndexes.size();
|
|
- log.debug("[{}]写入磁盘成功,写入磁盘花费总时间:{}ms 插入{}条", bufferIndex, spentTimeCalculator.getSpendTime(),
|
|
|
|
|
|
+ log.info("[{}]写入磁盘成功,写入磁盘花费总时间:{}ms 插入{}条", bufferIndex, spentTimeCalculator.getSpendTime(),
|
|
insertCount);
|
|
insertCount);
|
|
statisticService.increDataCountDiskSuccess(insertCount);
|
|
statisticService.increDataCountDiskSuccess(insertCount);
|
|
savePackageResult.setSaveDiskSuccess(true);
|
|
savePackageResult.setSaveDiskSuccess(true);
|
|
|
|
|
|
// 写入数据库
|
|
// 写入数据库
|
|
- log.debug("[{}]开始尝试插入ResoDB", bufferIndex);
|
|
|
|
|
|
+ log.info("[{}]开始尝试插入ResoDB", bufferIndex);
|
|
|
|
|
|
for (int i = 0; i < insertCount; i++) {
|
|
for (int i = 0; i < insertCount; i++) {
|
|
dbVals.get(i).setValue(doubleIndexes.get(i));
|
|
dbVals.get(i).setValue(doubleIndexes.get(i));
|
|
@@ -149,7 +149,7 @@ public class PackageHandler {
|
|
statisticService.increDataCountTsdbSuccess(insertCount);
|
|
statisticService.increDataCountTsdbSuccess(insertCount);
|
|
savePackageResult.setSaveTsdbSuccess(true);
|
|
savePackageResult.setSaveTsdbSuccess(true);
|
|
// log.debug("插入ResoDB结束,point={},插入{}条", dbVals, insertCount);
|
|
// log.debug("插入ResoDB结束,point={},插入{}条", dbVals, insertCount);
|
|
- log.debug("[{}]写入硬盘并插入时序数据库花费总时间:{}ms 插入{}条", bufferIndex, spentTimeCalculator.getSpendTime(), insertCount);
|
|
|
|
|
|
+ log.info("[{}]写入硬盘并插入时序数据库花费总时间:{}ms 插入{}条", bufferIndex, spentTimeCalculator.getSpendTime(), insertCount);
|
|
} else {
|
|
} else {
|
|
log.error("[{}]写入硬盘并插入时序数据库花费总时间:{}ms 插入失败", bufferIndex, spentTimeCalculator.getSpendTime());
|
|
log.error("[{}]写入硬盘并插入时序数据库花费总时间:{}ms 插入失败", bufferIndex, spentTimeCalculator.getSpendTime());
|
|
}
|
|
}
|