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()) {