This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/InnerTimeJoin
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4b7357f05c2 Add another UT for InnerTimeJoinOperator
add 8e9ef0aa4a9 PBTree: Prevent Concurrent Read With Stale Page (#11831)
add bcbe84ec51e Pipe: fix PipeDataRegionPluginAgent initialization order &
avoid instantiating meta source and sink (#11821)
add f42debd7e92 [IOTDB-6285] Alter Procedure timeout (#11836)
add 121c60b5936 Optimize log according to real scenarios after checking
(#11835)
add 05c7ed990c1 Add disk space log in cluster heartbeat (#11833)
add d0eed0ce738 Add error logs for NotEnoughDataNodeException and
DatabaseNotExistsException (#11832)
add 491246db1fc fix insert&delete cases dead data
add 7595a1a52bd Pipe: append logs generated by org.apache.iotdb.pipe.api.*
and org.apache.iotdb.commons.pipe.* into PIPE appender (#11845)
add 9fdeb95b6f6 Optimized wal file deletion algorithm (#11682)
add 42ea2cd3733 Fix aligned timeseries query error after delete some data
in memtable
add 712f4c4671a Return when leader election waiting is interrupted (#11842)
add 2f19b1a75e0 Reduce stack message of known compaction exceptions in log
(#11716)
add f077a18567f [IOTDB-6281] Enhance Procedure metrics (#11798)
add 4953d6fd3a0 fix the error of writing metrics (#11846)
add 01a0f6325e6 fix lose data when recover data dir onto a new iotdb
(#11848)
add a7f6d755482 Optimize InsertRecords performance by reducing record
metrics (#11723)
add 755c5d55e24 PBTree: fix deed lock in ReleaseFlushMonitor and Scheduler
(#11849)
add 463e23271c2 Revert "Optimized wal file deletion algorithm (#11682)"
(#11852)
add 20bdc070098 change ExitOnOutOfMemoryError to CrashOnOutOfMemoryError
add 31c65b3706b [IOTDB-6281] Enhance Procedure metrics (#11857)
new bfb36640ab4 Merge remote-tracking branch 'origin/master' into
ty/InnerTimeJoin
new 6e15932ff6d some code format
The 2 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:
.../IoTDBAlignedSeriesQueryWithDeletionIT.java | 28 +++
.../src/assembly/resources/conf/confignode-env.sh | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +
.../iotdb/confignode/manager/ProcedureManager.java | 24 ++-
.../confignode/manager/load/cache/LoadCache.java | 1 +
.../manager/partition/PartitionManager.java | 10 +-
.../manager/pipe/agent/PipeConfigNodeAgent.java | 2 +-
.../agent/plugin/PipePluginConfigNodeAgent.java | 14 +-
.../iotdb/confignode/procedure/Procedure.java | 46 ++++-
.../confignode/procedure/ProcedureExecutor.java | 25 ++-
.../confignode/procedure/ProcedureMetrics.java | 184 ++++++++++++++++++++
.../impl/statemachine/StateMachineProcedure.java | 2 +-
.../procedure/TestProcedureExecutor.java | 2 +-
.../procedure/entity/StuckProcedure.java | 4 +-
.../src/assembly/resources/conf/datanode-env.sh | 2 +-
.../assembly/resources/conf/logback-datanode.xml | 6 +
.../dataregion/DataExecutionVisitor.java | 3 +
.../pipe/agent/plugin/PipePluginDataNodeAgent.java | 8 +-
.../dataregion/PipeDataRegionPluginAgent.java | 23 ++-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 14 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 10 +-
.../db/queryengine/common/MPPQueryContext.java | 10 ++
.../execution/executor/RegionWriteExecutor.java | 3 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 8 +-
.../analyze/cache/schema/DataNodeSchemaCache.java | 44 +++++
.../plan/analyze/schema/ClusterSchemaFetcher.java | 9 +
.../plan/planner/distribution/SourceRewriter.java | 4 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 13 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 74 +++++---
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 77 +++------
.../schemafile/pagemgr/BTreePageManager.java | 68 +++++++-
.../pbtree/schemafile/pagemgr/PageManager.java | 11 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 21 +--
.../db/storageengine/dataregion/DataRegion.java | 189 ++++++++++++++++-----
.../CompactionFileCountExceededException.java | 5 +
.../CompactionLastTimeCheckFailedException.java | 5 +
.../CompactionMemoryNotEnoughException.java | 5 +
.../CompactionValidationFailedException.java | 5 +
.../performer/impl/FastCompactionPerformer.java | 4 +
.../execute/task/AbstractCompactionTask.java | 11 +-
.../compaction/schedule/CompactionWorker.java | 2 +-
.../dataregion/flush/CompressionRatio.java | 3 -
.../dataregion/flush/MemTableFlushTask.java | 24 ---
.../memtable/AlignedWritableMemChunk.java | 2 +-
.../dataregion/memtable/TsFileProcessor.java | 28 ++-
.../dataregion/wal/recover/WALRecoverManager.java | 11 +-
.../dataregion/wal/utils/WALFileUtils.java | 14 ++
.../db/utils/datastructure/AlignedTVList.java | 6 +-
.../db/metadata/mtree/schemafile/MonitorTest.java | 13 +-
.../dataregion/memtable/TsFileProcessorTest.java | 16 +-
.../src/test/resources/datanode1conf/logback.xml | 6 +
.../src/test/resources/datanode2conf/logback.xml | 6 +
.../src/test/resources/datanode3conf/logback.xml | 6 +
.../commons/pipe/agent/plugin/PipePluginAgent.java | 18 +-
.../iotdb/commons/service/metric/enums/Metric.java | 6 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 3 -
56 files changed, 857 insertions(+), 285 deletions(-)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureMetrics.java
