This is an automated email from the ASF dual-hosted git repository.

ejttianyu pushed a commit to branch dynamic_compaction
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dynamic_compaction by this 
push:
     new 024b266  finish hitter
024b266 is described below

commit 024b266b12f56603250990078e1da5d1388a14c0
Author: EJTTianyu <[email protected]>
AuthorDate: Sat May 22 03:38:44 2021 +0800

    finish hitter
---
 .../level/hitter/HitterLevelCompactionTsFileManagement.java           | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
index 2761feb..7b004a7 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/compaction/level/hitter/HitterLevelCompactionTsFileManagement.java
@@ -125,7 +125,7 @@ public class HitterLevelCompactionTsFileManagement extends 
LevelCompactionTsFile
           File newLevelFile = 
createTempTsFileName(mergeResources.get(i).get(0).getTsFile());
           TsFileResource newResource = new TsFileResource(newLevelFile);
           // merge, read  heavy hitters time series from source files and 
write to target file
-          List<PartialPath> unmergedPaths = QueryHitterManager.getQueryHitter()
+          List<PartialPath> unmergedPaths = 
QueryHitterManager.getInstance().getQueryHitter()
               .getTopCompactionSeries(new PartialPath(storageGroupName));
           long st = System.nanoTime();
           CompactionUtils
@@ -267,7 +267,7 @@ public class HitterLevelCompactionTsFileManagement extends 
LevelCompactionTsFile
           File newLevelFile = 
createNewTsFileName(mergeResources.get(i).get(0).getTsFile(), i + 1);
           TsFileResource newResource = new TsFileResource(newLevelFile);
           // merge, read  heavy hitters time series from source files and 
write to target file
-          List<PartialPath> unmergedPaths = QueryHitterManager.getQueryHitter()
+          List<PartialPath> unmergedPaths = 
QueryHitterManager.getInstance().getQueryHitter()
               .getTopCompactionSeries(new PartialPath(storageGroupName));
           long st = System.nanoTime();
           CompactionUtils

Reply via email to