You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/10/16 03:58:05 UTC
[iotdb] branch add_restart_logs updated: add series sort time
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch add_restart_logs
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/add_restart_logs by this push:
new 929295f add series sort time
929295f is described below
commit 929295fcceef9ff1202bfb1e10409c3bcb7913bc
Author: jt <jt...@163.com>
AuthorDate: Fri Oct 16 11:57:40 2020 +0800
add series sort time
---
.../main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
index b05e348..3b80b13 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
@@ -88,7 +88,9 @@ public class MemTableFlushTask {
IWritableMemChunk series = memTable.getMemTableMap().get(deviceId).get(measurementId);
MeasurementSchema desc = series.getSchema();
TVList tvList = series.getSortedTVList();
- sortTime += System.currentTimeMillis() - startTime;
+ long seriesSortTime = System.currentTimeMillis() - startTime;
+ sortTime += seriesSortTime;
+ logger.debug("{}.{} sort costs {}", deviceId, measurementId, seriesSortTime);
encodingTaskQueue.add(new Pair<>(tvList, desc));
// register active time series to the ActiveTimeSeriesCounter
if (IoTDBDescriptor.getInstance().getConfig().isEnableParameterAdapter()) {