This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch jira3385 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c9a2b9494e095a2d407e522f8daed76bded6df03 Merge: 11791a41d0 4fde65e41e Author: LebronAl <[email protected]> AuthorDate: Thu Jun 9 15:57:59 2022 +0800 Merge branch 'master' of github.com:Apache/iotdb into jira3385 docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 6 +- docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 5 +- pom.xml | 9 +- server/pom.xml | 4 + .../engine/compaction/CompactionTaskManager.java | 11 +- .../utils/AlignedSeriesCompactionExecutor.java | 8 +- .../utils/SingleSeriesCompactionExecutor.java | 10 +- .../writer/AbstractCompactionWriter.java | 4 +- .../db/metadata/cache/DataNodeSchemaCache.java | 17 ++ .../iotdb/db/mpp/common/FragmentInstanceId.java | 7 +- .../execution/datatransfer/DataBlockManager.java | 265 +++++++++++--------- .../db/mpp/execution/datatransfer/SinkHandle.java | 73 +++--- .../mpp/execution/datatransfer/SourceHandle.java | 271 +++++++++++---------- .../fragment/FragmentInstanceManager.java | 67 ++--- .../db/mpp/execution/schedule/DriverScheduler.java | 119 ++++----- .../mpp/execution/schedule/DriverTaskThread.java | 69 +++--- .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 34 +-- .../mpp/plan/analyze/ClusterPartitionFetcher.java | 41 ++-- .../db/mpp/plan/execution/IQueryExecution.java | 2 + .../db/mpp/plan/execution/QueryExecution.java | 28 ++- .../mpp/plan/execution/config/ConfigExecution.java | 5 + .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 14 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 13 +- .../scheduler/SimpleFragInstanceDispatcher.java | 94 ------- .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 14 +- .../java/org/apache/iotdb/db/service/DataNode.java | 3 +- .../iotdb/db/service/metrics/enums/Metric.java | 1 + .../metrics/recorder/CacheMetricsRecorder.java | 65 +++++ .../recorder/CompactionMetricsRecorder.java} | 16 +- .../thrift/impl/DataNodeTSIServiceImpl.java | 44 ++-- 30 files changed, 739 insertions(+), 580 deletions(-)
