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 <[email protected]>
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()) {

Reply via email to