This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira3385
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 11791a41d0 reduce electionTimeout
add 08006e2ae0 [IOTDB-3360] Fix precision loss bug due to float converted
to double (#6192)
add 0868dfa889 Add thread name for log (#6202)
add 4fde65e41e [IOTDB-3394] Add cache metrics (#6201)
new c9a2b9494e Merge branch 'master' of github.com:Apache/iotdb into
jira3385
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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} | 73 +++---
.../recorder/CompactionMetricsRecorder.java} | 16 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 44 ++--
30 files changed, 705 insertions(+), 622 deletions(-)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/rescon/TimeseriesStatistics.java
=> service/metrics/recorder/CacheMetricsRecorder.java} (50%)
rename
server/src/main/java/org/apache/iotdb/db/{engine/compaction/CompactionMetricsManager.java
=> service/metrics/recorder/CompactionMetricsRecorder.java} (94%)
