This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch mac-arm64-ci
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a9bba5dac33 test
add 4031ddf7b8d Fix NPE while right side finished
add 5e8d43f2faa Fix PBTree metric and support async flushAll (#11884)
add 782e97aa75e Fix distributed plan of GroupLevelNode
add e858069aac6 Fix scatter width metric bug (#11886)
add a565597f0b1 [RatisConsensus] Enable Leader Transfer UT (#11871)
add d1fc9b0cd79 exclude gc time from cpu usage percentage for thread pool
and modules (#11883)
add e0f24a68ac0 doc(cpp-client): update build scripts
add f53a3fab371 Remove useless writing metric item (#11889)
add 5c28958fcc3 fixed collection iotdb info unable to obtain information
(#11881)
add 020b8a52885 Extract common code and fix PBTree UT (#11890)
add 7b09a5adcae Pipe: fix NPE when parsing TabletInsertionData & add IT
for null values insertion (#11877)
add aeeb0baf3a0 Pipe: Utilize parallelStream for concurrent execution of
create, start, stop, and drop pipe tasks to enhance performance (#11892)
add 5d343711115 Pipe: Fix ConcurrentModificationException occured by ttl
check in PipeTsFileResourceManager (#11876)
add 212cebf4e21 Fix TsFileResource is deleted cause compaction validation
result is not correct (#11878)
add 0e93697e1af [IOTDB-6290] Simplify GetNodePathsPartition log (#11895)
add 4e1020632b6 finish (#11898)
add 6f650547d6b change the description of daemon-confignode/datanode
(#11880)
add 1c6f926cf48 Change the clean script to a destory script and add a stop
operation … (#11879)
add bcfeafe1838 Pipe: Fix deadlock when
PipeTaskAgent.handlePipeMetaChanges and
PipeTaskDataNodeAgent.stopAllPipesWithCriticalException are invoked
concurrently & Fix concurrent issues caused by addFailureEventToRetryQueue &
transferQueuedEventsIfNecessary (#11893)
add 9bc9685816c Load: Fix the warning of deleting a directory that already
deleted (#11902)
add d4193fbf5b3 Fix upgrade and add fysnc
add 3305467ac2f Clear useless query resource ASAP
add e11116285ba conf: make cluster_name and timestamp_precision be comment
(#11904)
add d529f678960 PBTreeSketchTool support view (#11897)
add 05b5b893df5 Optimize PBTree pst file space utilization for view
(#11896)
add f1d87533610 Fix ConcurrentModificationException when evict time
partition info (#11907)
add 16c77d73273 fix index out of bounds with all empty value chunk in one
device (#11906)
add d2a71be993f Fix wrong calculation of ExchangeNum for
consumeAllPipelineBreaker when dop = 1
add 0746d6710c2 Pipe: print more info about event and task when error
occurs in pipe subtask (#11909)
add 8fefc91f8fd Daemon script change default choice from n to y (#11910)
add 85fe36d324c This configuration file needs to be configured only when
the start-all.sh,stop-all.sh, and destroy.sh scripts are required. You also
need to modify this configuration file when the cluster nodes change (#11911)
add bc3c9f43669 remove insert cross compaction config v1 (#11912)
add 3f16839f5a3 Dicard all null row of aligned page in AlignedPageReader
(#11913)
add 96929fa9671 [IOTDB-6292] Add the internal address column in the result
of show regions (#11915)
add c147683fd67 fix insertion compaction target file progress index
(#11917)
add 6d46ceb4a05 [IOTDB-6291] Update RegionGroup configuration when update
DataNode configuration (#11914)
add 9aceb9f2295 [RatisConsensus] Bump ratis version from 3.0.0 to 3.0.1
(#11899)
add e9e01f3bdba Pipe: make PipeHistoricalDataRegionExtractor &
PipeRealtimeDataRegionExtractor log info much clear with pipe name and region
id added (#11920)
add 22f915f3159 Strictly check inner space compaction file size (#11919)
add da790779d13 Read chunk aligned series compaction executor (#11745)
add a965709cd3a fix remaining issues when upgrading to ratis 3.0.1 (#11921)
add 23928e97105 modify ExitOnOutOfMemoryError to CrashOnOutOfMemoryError
on .bat
add eae4d01d582 remove enable_insertion_cross_space_compaction from
iotdb-common.properties (#11925)
add 7e5162332e3 conf: 1. open replication_factor,2. open
dn_metric_prometheus_reporter_port (#11922)
add f40c3731138 fix ActiveMemTableCount update error (#11923)
add 7dd570d991a Load: Introduce LoadTsFileManager.CleanupTask to force
close writer manager after exception occurring (#11924)
add 4cc5b2ba48d Fix query result is empty in order by time align by device
add 771c096b478 Pipe: let non enriched event forever retry when exception
occurred to avoid subtask fake running status recorded at data node task agent
(#11929)
add dd48a57ddb2 Improve some descriptions of daemon-script
add 63605be3186 Fix the issue where ConfigNode reports
'ConsensusGroupAlreadyExist' error during startup in some scenarios (#11928)
add c3597b6ae12 Fixed the issue that IoTConsensus synchronization is stuck
when WAL file is corrupted (#11930)
add 0cb14994659 Enable SchemaRegion Leader Auto Balance (#11926)
add f94f99a4828 Change partial aggregation symbols for variance and
standard deviation aggregators
add 3464e95f495 Load: Support configure
load_clean_up_task_execution_delay_time_seconds of a load task (#11936)
add db7d115204a Skip broken wal files when iterate the PlanNodeIterator
(#11935)
add 4ec79560c60 fix remaining issues when upgrading to ratis 3.0.1 (#11940)
add f1db2923dfb Pipe: decrease the default value of
pipe_sink_selector_number to 4 for better performance (#11942)
add 85e71a43543 Fix update time index after compact aligned series (#11943)
add 8885df31144 fix PointPriorityReader calculation of aligned series null
value num (#11945)
add 9e05b262559 Add the ability for ClientManager to periodically clean up
idle objects
add 69202a94a51 reduce stack message of last time check exception for read
chunk compaction performer (#11927)
add 6f37cf83b1d [IOTDB-6293] Use nanotime in cluster heartbeat (#11916)
add 4cad6af6715 Fix compile error caused by concurrent pr (#11951)
add 3846bb7f2bc Enhance the robustness of Ratis linearizable reads for
node offline scenarios (#11954)
add 070de203710 PBTree: Decouple PageManager (#11953)
add 827735d1d77 fixed collection iotdb info unable to obtain information
(#11938)
add 15f63300fb7 Pipe: support restarting pipes on datanodes when they are
stuck (#11955)
add 14162173e73 skip insertion compaction disk space check (#11959)
add b07fafe3954 Optimized wal file deletion algorithm (#11948)
add 5c6c9727648 Enhance DataNode startup probing logic (#11957)
add 20726036498 Fix deadlock when delete timeseries after loading data.
add c52da2bdbd0 [IOTDB-6295] Adjust the timeout period in ConfigNode
registration procedure (#11962)
add 39b589381e9 Fix read chunk compaction performer null pointer exception
(#11960)
add 7f7285cf62e Load: Correctly release memory when system is in READ_ONLY
mode (#11961)
add 092fcb5860a fix npe (#11966)
add 7200e217b09 Repair unsorted file by compaction (#11887)
add 82d04599f6c Fixed issue where ConfigNode might recover incorrectly
under SimpleConsensus (#11969)
add 59fe3fee515 Add unit byte for no enough query memory
add 75ce7711162 Pipe: fixed the bug that region follower tsfiles can not
record the IoTProgressIndex from region leader (#11980)
add ebbddf38918 Multiply 3 for ScanOperator to take unsequence data into
account (#11978)
add 40fc15b23bc Pipe: fix connector subtasks can not be stopped and
restarted after exception reporting by connector subtasks (#11979)
add 6c15634b1e3 Fix estimating compaction memory without acquire read lock
(#11972)
add 7d0a735f2f3 fix.create role folder when init.
add a5445177d5d Fix template device aligned properties recover unexpectly
with SimpleConsensus (#11968)
add 769a151af97 Revert "Fixed issue where ConfigNode might recover
incorrectly under SimpleConsensus" (#11987)
add e7b0ca5793b Refactor last flush time management (#11946)
add 98310822b32 Session insert request won't fail while rolling upgrade
add 7923eb9e96e Fix concurrent bug in QueryContext
add 5619156e871 Pipe: Report load tsfile points to flush point metric
timeseries in root.__system (#11976)
add ea37a1f0f65 fix repair non aligned series (#11997)
add e331eadbeaf Fix non-latest partition last flush time cannot recover
(#11999)
add 775f169afd7 Pipe: result of show pipes statement is incorrect when it
contains back quoted pipe names (#11944)
add e2f71993826 Storage Engine: optimized DataRegion recover log (#11996)
add fcae2b48400 Pipe: support reporting progress by UserDefinedEvent
(#12000)
add ef94fbf1fcf Feat/cli with overridable streams (#11885)
add 634d0e07dd4 Fixed issue where ConfigNode might recover incorrectly
under SimpleConsensus (#12002)
add 8c87ab1d916 Fix more issue of last flush time memory calculate (#12003)
add 0ad17bf4a97 Pipe: Allow pipe times configured by raw timestamp (#12004)
add d0928eb15f6 Pipe: stop pipe using restarting strategy to unpin the
wal's reference count to avoid WAL stacking (#11971)
add ea68bc31d49 Avoid deleting wal files pinned by the iot consensus
(#12006)
add f9893075b42 Introduce aggregate function MaxBy
add 4b9b1c81e65 bump ratis to 3.1.0-snapshot (#12009)
add 614a0d8433a Optimize max_tsblock_line_num parameter and memory usage
of TopKOperator when align by device with limit value. (#11995)
add 63933967f6a Pipe: support alter pipe functionality (#11963)
add 035be504296 Fix concurrent modification exception of compaction worker
(#12011)
add 9337d450c0e Delete write mem control parameters (#12007)
add c8419ec7fc9 Pipe: Ensure at-least-once semantic by forcibly starting
PipeHistoricalDataRegionTsFileExtractor after pipe restart (#12010)
add 2f1dac5900f separate the synchronized block of
AbstractCompactionEstimator file info cache (#12019)
add 4230ad16afd Pipe: using clusterId to judge whether the target cluster
is source cluster (#11994)
add bbdca54ed1d Storage Engine: fix wal delete thread exception because
multi thread safety question (#12020)
add f1d718666f1 PBTree: Fix Dead Lock and Refactor write/update inteface
(#11985)
add 8c90117ebc5 Remove sql `merge` (#12021)
add 6943524b000 Load: Trigger last flush time map & tsfile resource
degrading after successful load (#12024)
add 1a10621dabf feat(jdbc):getDouble add type check
add 142f3c81268 Remove infinite retry logic for replica inconsistency to
avoid potential problems (#12028)
add e4ed1964fd6 Pipe: Support "sink.host" and "connector.host" key in
receiver IP specification (#12017)
add 6e5605ba11a Fixed Ratis query not retrying when DataNode restarts
(#12029)
add fd4337eb0af Pipe: support replace and modify mode for alter pipe sql
(#12018)
new 999393be58d Merge branch 'master' of github.com:apache/iotdb into
mac-arm64-ci
new 6681dbe8662 update
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:
.github/workflows/client-cpp.yml | 2 +-
.github/workflows/greetings.yml | 2 +-
NOTICE | 2 +-
NOTICE-binary | 2 +-
example/client-cpp-example/README.md | 2 +-
.../constant/BuiltinAggregationFunctionEnum.java | 2 +-
.../it/cluster/IoTDBClusterRestartIT.java | 70 ++
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 9 +
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 51 +-
...ushQueryMergeIT.java => IoTDBFlushQueryIT.java} | 3 +-
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 1 -
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 1 -
.../org/apache/iotdb/db/it/IoTDBRepairDataIT.java | 132 ++
.../db/it/aggregation/IoTDBAggregationIT.java | 52 +
.../db/it/aggregation/maxby/IoTDBMaxBy2IT.java | 29 +-
.../db/it/aggregation/maxby/IoTDBMaxBy3IT.java | 38 +-
.../maxby/IoTDBMaxByAlignedSeriesIT.java | 71 ++
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 487 ++++++++
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 1 +
.../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 52 +-
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 2 -
.../org/apache/iotdb/pipe/it/IoTDBPipeAlterIT.java | 355 ++++++
.../apache/iotdb/pipe/it/IoTDBPipeDataSinkIT.java | 46 -
.../apache/iotdb/pipe/it/IoTDBPipeExtractorIT.java | 37 +-
.../apache/iotdb/pipe/it/IoTDBPipeNullValueIT.java | 320 +++++
.../apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java | 3 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 2 -
.../java/org/apache/iotdb/pipe/api/PipeSink.java | 49 +-
.../java/org/apache/iotdb/pipe/api/PipeSource.java | 42 +-
.../api/customizer/parameter/PipeParameters.java | 23 +
.../iotdb/pipe/api/event/UserDefinedEvent.java | 58 +
.../src/assembly/resources/tools/collect-info.bat | 267 ++++
.../tools/{collection-info.sh => collect-info.sh} | 212 ++--
.../assembly/resources/tools/collection-info.bat | 275 -----
.../java/org/apache/iotdb/cli/AbstractCli.java | 246 ++--
.../src/main/java/org/apache/iotdb/cli/Cli.java | 124 +-
.../apache/iotdb/cli/IoTDBSyntaxHighlighter.java | 5 +-
.../java/org/apache/iotdb/cli/type/ExitType.java | 14 +-
.../org/apache/iotdb/cli/utils/CliContext.java | 84 ++
.../org/apache/iotdb/cli/utils/IoTPrinter.java | 36 +-
.../org/apache/iotdb/cli/utils/JlineUtils.java | 12 +-
.../org/apache/iotdb/tool/AbstractCsvTool.java | 10 +-
.../org/apache/iotdb/tool/AbstractTsFileTool.java | 6 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 33 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 38 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 48 +-
.../java/org/apache/iotdb/cli/AbstractCliIT.java | 37 +-
.../iotdb/tool/integration/ExportCsvTestIT.java | 3 +
.../iotdb/tool/integration/ImportCsvTestIT.java | 3 +
iotdb-client/client-cpp/README.md | 20 +-
.../org/apache/iotdb/isession/SessionConfig.java | 4 +
iotdb-client/jdbc/pom.xml | 4 +
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 37 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 9 +
.../java/org/apache/iotdb/session/Session.java | 27 +-
.../apache/iotdb/session/SessionConnection.java | 660 ++++++++--
.../org/apache/iotdb/session/pool/SessionPool.java | 1295 +++++++++-----------
.../iotdb/session/SessionConnectionTest.java | 9 +-
.../sql/factory/IoTDBDynamicTableFactory.java | 1 +
iotdb-core/antlr/pom.xml | 11 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 39 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../src/assembly/resources/conf/confignode-env.bat | 2 +-
.../resources/conf/iotdb-confignode.properties | 5 -
...register-confignode.sh => daemon-confignode.sh} | 24 +-
.../confignode/client/DataNodeRequestType.java | 1 +
.../client/async/AsyncDataNodeClientPool.java | 5 +
.../client/async/handlers/AsyncClientHandler.java | 1 +
.../heartbeat/DataNodeHeartbeatHandler.java | 2 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 17 +-
.../confignode/conf/ConfigNodeDescriptor.java | 8 -
.../confignode/conf/SystemPropertiesUtils.java | 11 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/write/pipe/task/AlterPipePlanV2.java | 66 +
.../statemachine/ConfigRegionStateMachine.java | 31 +
.../iotdb/confignode/manager/ConfigManager.java | 104 +-
.../apache/iotdb/confignode/manager/IManager.java | 12 +
.../iotdb/confignode/manager/ProcedureManager.java | 19 +
.../manager/consensus/ConsensusManager.java | 2 -
.../confignode/manager/load/cache/LoadCache.java | 2 +-
.../manager/load/cache/node/BaseNodeCache.java | 2 +-
.../load/cache/node/ConfigNodeHeartbeatCache.java | 2 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 2 +-
.../load/cache/node/NodeHeartbeatSample.java | 6 +-
.../manager/load/cache/node/NodeStatistics.java | 2 +-
.../manager/load/cache/region/RegionCache.java | 5 +-
.../load/cache/region/RegionHeartbeatSample.java | 2 +-
.../manager/load/service/HeartbeatService.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 9 +
.../pipe/coordinator/runtime/PipeMetaSyncer.java | 3 +
.../pipe/coordinator/task/PipeTaskCoordinator.java | 10 +
.../iotdb/confignode/persistence/AuthorInfo.java | 5 -
.../persistence/executor/ConfigPlanExecutor.java | 12 +-
.../partition/DatabasePartitionTable.java | 11 +
.../persistence/partition/PartitionInfo.java | 22 +-
.../persistence/partition/RegionGroup.java | 15 +
.../persistence/pipe/PipePluginInfo.java | 22 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 96 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 21 +-
.../procedure/impl/pipe/PipeTaskOperation.java | 1 +
.../impl/pipe/task/AlterPipeProcedureV2.java | 354 ++++++
.../impl/pipe/task/CreatePipeProcedureV2.java | 25 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 3 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 1 +
.../iotdb/confignode/service/ConfigNode.java | 14 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 13 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 29 +-
.../router/priority/GreedyPriorityTest.java | 6 +-
.../priority/LeaderPriorityBalancerTest.java | 6 +-
.../manager/load/cache/LoadCacheTest.java | 2 +-
.../manager/load/cache/NodeCacheTest.java | 6 +-
.../manager/load/cache/RegionGroupCacheTest.java | 6 +-
.../manager/load/cache/RegionRouteCacheTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
.../impl/pipe/task/AlterPipeProcedureV2Test.java | 65 +
.../iotdb/consensus/config/IoTConsensusConfig.java | 16 -
.../apache/iotdb/consensus/config/RatisConfig.java | 30 -
.../exception/RatisReadUnavailableException.java | 13 +-
.../iot/client/IoTConsensusClientPool.java | 2 -
.../consensus/iot/logdispatcher/LogDispatcher.java | 24 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 20 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 6 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 50 +-
.../iotdb/consensus/ratis/RecoverReadTest.java | 6 +-
.../src/assembly/resources/conf/datanode-env.bat | 2 +-
.../resources/conf/iotdb-datanode.properties | 7 +-
.../{register-datanode.sh => daemon-datanode.sh} | 24 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 1 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 101 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 84 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 7 +-
.../db/consensus/DataRegionConsensusImpl.java | 296 ++---
.../db/consensus/SchemaRegionConsensusImpl.java | 240 ++--
.../dataregion/DataRegionStateMachine.java | 10 +-
.../IoTConsensusDataRegionStateMachine.java | 2 +-
.../schemaregion/SchemaExecutionVisitor.java | 1 -
.../pipe/agent/plugin/PipePluginDataNodeAgent.java | 13 +
.../agent/runtime/PipePeriodicalJobExecutor.java | 5 +
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 36 +-
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 118 +-
.../common/PipeTransferHandshakeConstant.java} | 15 +-
...akeReq.java => PipeTransferHandshakeV1Req.java} | 18 +-
...akeReq.java => PipeTransferHandshakeV2Req.java} | 63 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 28 +-
.../async/IoTDBThriftAsyncClientManager.java | 61 +-
.../thrift/async/IoTDBThriftAsyncConnector.java | 38 +-
.../thrift/sync/IoTDBThriftSyncClientManager.java | 55 +-
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 45 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 86 ++
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 13 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 11 +
.../tablet/TabletInsertionDataContainer.java | 152 ++-
.../common/tsfile/PipeTsFileInsertionEvent.java | 19 +-
.../pipe/extractor/IoTDBDataRegionExtractor.java | 27 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 95 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 9 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 9 +-
.../iotdb/db/pipe/metric/PipeExtractorMetrics.java | 7 +-
.../receiver/thrift/IoTDBThriftReceiverV1.java | 66 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 33 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 41 +-
.../iotdb/db/pipe/task/PipeDataNodeTask.java | 30 +
.../pipe/task/builder/PipeDataNodeTaskBuilder.java | 31 +-
.../db/pipe/task/subtask/PipeDataNodeSubtask.java | 105 +-
.../subtask/connector/PipeConnectorSubtask.java | 181 +--
.../connector/PipeConnectorSubtaskLifeCycle.java | 42 +-
.../subtask/processor/PipeProcessorSubtask.java | 26 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 13 +
.../protocol/client/ConfigNodeClientManager.java | 9 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 6 +-
.../protocol/client/DataNodeClientPoolFactory.java | 2 -
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 3 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 26 +-
.../db/queryengine/common/MPPQueryContext.java | 10 +-
.../common/header/ColumnHeaderConstant.java | 1 +
.../execution/aggregation/AccumulatorFactory.java | 43 +-
.../execution/aggregation/Aggregator.java | 18 +-
.../execution/aggregation/MaxByAccumulator.java | 424 +++++++
.../SlidingWindowAggregatorFactory.java | 35 +-
.../queryengine/execution/driver/DataDriver.java | 1 +
.../execution/driver/DataDriverContext.java | 16 +-
.../execution/executor/RegionExecutionResult.java | 9 +
.../execution/executor/RegionReadExecutor.java | 23 +-
.../fragment/FragmentInstanceContext.java | 4 +
.../execution/fragment/QueryContext.java | 26 +-
.../execution/load/LoadTsFileManager.java | 183 ++-
.../execution/operator/AggregationUtil.java | 6 +
.../execution/operator/process/TopKOperator.java | 44 +-
.../process/join/LeftOuterTimeJoinOperator.java | 11 +-
.../AbstractSeriesAggregationScanOperator.java | 2 +-
.../operator/source/AlignedSeriesScanOperator.java | 23 +-
.../operator/source/SeriesScanOperator.java | 3 +-
.../execution/schedule/DriverScheduler.java | 2 +-
.../queryengine/load/LoadTsFileMemoryManager.java | 5 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 16 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 30 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 39 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 9 +-
.../db/queryengine/plan/analyze/TemplatedInfo.java | 1 +
.../db/queryengine/plan/analyze/TypeProvider.java | 4 +
.../plan/analyze/schema/ClusterSchemaFetcher.java | 6 +-
.../queryengine/plan/execution/QueryExecution.java | 3 +
.../plan/execution/config/ConfigTaskVisitor.java | 16 +
.../config/executor/ClusterConfigTaskExecutor.java | 106 +-
.../config/executor/IConfigTaskExecutor.java | 5 +
.../execution/config/metadata/ShowRegionTask.java | 7 +-
.../plan/execution/config/sys/RepairDataTask.java | 42 +
.../execution/config/sys/pipe/AlterPipeTask.java | 42 +
.../ReplaceRawPathWithGroupedPathVisitor.java | 7 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 7 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 6 +-
...catDeviceAndBindSchemaForExpressionVisitor.java | 7 +-
.../ConcatExpressionWithSuffixPathsVisitor.java | 23 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 122 +-
.../plan/planner/LocalExecutionPlanner.java | 11 +-
.../plan/planner/LogicalPlanBuilder.java | 63 +-
.../plan/planner/OperatorTreeGenerator.java | 63 +-
.../plan/planner/TemplatedLogicalPlan.java | 1 -
.../distribution/DistributionPlanContext.java | 7 +-
.../plan/planner/distribution/SourceRewriter.java | 62 +-
.../plan/planner/plan/LogicalQueryPlan.java | 6 +-
.../plan/planner/plan/PlanFragment.java | 5 +
.../plan/parameter/AggregationDescriptor.java | 50 +-
.../CrossSeriesAggregationDescriptor.java | 146 ++-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 4 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 66 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 156 +--
.../queryengine/plan/statement/StatementType.java | 2 +
.../plan/statement/StatementVisitor.java | 10 +
.../metadata/pipe/AlterPipeStatement.java | 113 ++
.../plan/statement/sys/RepairDataStatement.java | 62 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 1 +
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 1 +
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 2 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 2 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 192 ++-
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 5 +-
.../impl/pbtree/schemafile/AliasIndexPage.java | 3 +-
.../mtree/impl/pbtree/schemafile/ISegment.java | 7 +-
.../impl/pbtree/schemafile/ISegmentedPage.java | 11 +-
.../mtree/impl/pbtree/schemafile/InternalPage.java | 3 +-
.../mtree/impl/pbtree/schemafile/RecordUtils.java | 55 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 7 +-
.../impl/pbtree/schemafile/SegmentedPage.java | 43 +-
.../impl/pbtree/schemafile/WrappedSegment.java | 23 +-
.../schemafile/pagemgr/BTreePageManager.java | 18 +-
.../pbtree/schemafile/pagemgr/IPageManager.java | 3 +
.../pbtree/schemafile/pagemgr/PageIOChannel.java | 184 +++
.../schemafile/pagemgr/PageIndexSortBuckets.java | 129 ++
.../pbtree/schemafile/pagemgr/PageManager.java | 521 +-------
.../impl/pbtree/schemafile/pagemgr/PagePool.java | 152 +++
.../schemafile/pagemgr/SchemaPageContext.java | 109 ++
.../java/org/apache/iotdb/db/service/DataNode.java | 36 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 5 +
.../db/service/metrics/DataNodeMetricsHelper.java | 2 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 16 +-
.../iotdb/db/storageengine/StorageEngine.java | 64 +-
.../db/storageengine/dataregion/DataRegion.java | 292 ++---
.../dataregion/DeviceLastFlushTime.java} | 39 +-
.../dataregion/HashLastFlushTimeMap.java | 92 +-
.../storageengine/dataregion/ILastFlushTime.java} | 18 +-
.../dataregion/ILastFlushTimeMap.java | 12 +-
.../dataregion/PartitionLastFlushTime.java} | 33 +-
.../impl/ReadChunkCompactionPerformer.java | 20 +-
.../impl/ReadPointCompactionPerformer.java | 14 +-
.../RepairUnsortedFileCompactionPerformer.java | 86 ++
.../execute/task/AbstractCompactionTask.java | 9 +-
.../execute/task/CompactionTaskPriorityType.java | 14 +-
.../execute/task/CompactionTaskSummary.java | 44 +-
.../execute/task/CrossSpaceCompactionTask.java | 5 +-
.../execute/task/InnerSpaceCompactionTask.java | 48 +-
.../task/InsertionCrossSpaceCompactionTask.java | 27 +-
.../task/RepairUnsortedFileCompactionTask.java | 239 ++++
.../execute/utils/MultiTsFileDeviceIterator.java | 4 +
.../executor/ModifiedStatus.java} | 16 +-
.../fast/AlignedSeriesCompactionExecutor.java | 1 +
.../fast/NonAlignedSeriesCompactionExecutor.java | 1 +
.../executor/fast/SeriesCompactionExecutor.java | 6 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 465 +++++++
.../readchunk/SingleSeriesCompactionExecutor.java | 4 +-
.../executor/readchunk/loader/ChunkLoader.java | 104 ++
.../readchunk/loader/InstantChunkLoader.java | 105 ++
.../readchunk/loader/InstantPageLoader.java | 103 ++
.../executor/readchunk/loader/PageLoader.java | 107 ++
.../execute/utils/reader/PointPriorityReader.java | 2 +-
.../utils/writer/AbstractCompactionWriter.java | 6 +-
.../writer/AbstractCrossCompactionWriter.java | 15 +-
.../writer/AbstractInnerCompactionWriter.java | 14 +-
.../utils/writer/FastCrossCompactionWriter.java | 6 +-
.../utils/writer/FastInnerCompactionWriter.java | 6 +-
.../writer/ReadPointCrossCompactionWriter.java | 7 +-
.../writer/ReadPointInnerCompactionWriter.java | 7 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 111 ++
.../compaction/io/CompactionTsFileReader.java | 18 +
.../compaction/io/CompactionTsFileWriter.java | 5 +-
.../dataregion/compaction/repair/RepairLogger.java | 136 ++
.../repair/RepairTaskRecoverLogParser.java | 115 ++
.../compaction/repair/RepairTimePartition.java | 136 ++
.../repair/UnsortedFileRepairTaskScheduler.java | 350 ++++++
.../compaction/schedule/CompactionScheduler.java | 24 +-
.../compaction/schedule/CompactionTaskManager.java | 4 +-
.../compaction/schedule/CompactionWorker.java | 19 +-
.../DefaultCompactionTaskComparatorImpl.java | 10 +-
.../estimator/AbstractCompactionEstimator.java | 28 +-
.../estimator/AbstractCrossSpaceEstimator.java | 6 +-
.../estimator/AbstractInnerSpaceEstimator.java | 19 +-
.../RepairUnsortedFileCompactionEstimator.java | 72 ++
.../impl/SizeTieredCompactionSelector.java | 81 +-
.../InsertionCrossCompactionTaskResource.java | 25 +
.../selector/utils/TsFileResourceCandidate.java | 5 +-
.../compaction/settle/SettleRequestHandler.java | 4 +-
.../dataregion/flush/MemTableFlushTask.java | 37 +-
.../dataregion/memtable/AbstractMemTable.java | 32 +-
.../memtable/AlignedWritableMemChunk.java | 6 +-
.../dataregion/memtable/IMemTable.java | 2 +
.../dataregion/memtable/PrimitiveMemTable.java | 5 -
.../dataregion/memtable/TsFileProcessor.java | 162 +--
.../dataregion/memtable/WritableMemChunk.java | 2 +-
.../dataregion/tsfile/TsFileManager.java | 75 +-
.../TsFileRepairStatus.java} | 14 +-
.../dataregion/tsfile/TsFileResource.java | 42 +-
.../tsfile/generator/TsFileNameGenerator.java | 53 +-
.../dataregion/utils/TsFileResourceUtils.java | 75 +-
.../dataregion/wal/buffer/WALBuffer.java | 59 +-
.../wal/checkpoint/CheckpointManager.java | 50 +-
.../dataregion/wal/checkpoint/MemTableInfo.java | 22 +-
.../dataregion/wal/io/WALByteBufReader.java | 26 +-
.../dataregion/wal/io/WALMetaData.java | 76 +-
.../storageengine/dataregion/wal/node/WALNode.java | 230 ++--
.../dataregion/wal/recover/WALNodeRecoverTask.java | 41 +-
.../wal/recover/file/TsFilePlanRedoer.java | 2 +
.../rescon/memory/MemTableManager.java | 60 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 28 +-
.../rescon/memory/TimePartitionInfo.java | 10 +-
.../rescon/memory/TimePartitionManager.java | 31 +-
.../db/tools/schema/PBTreeFileSketchTool.java | 2 +-
.../TsFileOverlapValidationAndRepairTool.java | 6 -
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 8 +
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 32 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 68 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 31 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 3 +
.../iotdb/db/utils/constant/SqlConstant.java | 1 +
.../iotdb/db/utils/constant/TestConstant.java | 4 +
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 2 +-
.../iotdb/db/utils/datastructure/TVList.java | 8 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 2 +-
.../SchemaRegionSimpleRecoverTest.java | 98 ++
.../connector/PipeDataNodeThriftRequestTest.java | 68 +-
.../iotdb/db/pipe/connector/PipeReceiverTest.java | 4 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 93 +-
.../execution/aggregation/AccumulatorTest.java | 81 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 22 +-
.../operator/AlignedSeriesScanOperatorTest.java | 15 +-
.../execution/operator/OperatorMemoryTest.java | 30 +-
.../SlidingWindowAggregationOperatorTest.java | 2 +-
.../join/LeftOuterTimeJoinOperatorTest.java | 290 ++++-
.../plan/analyze/AggregationDescriptorTest.java | 8 +-
.../plan/planner/LogicalPlannerTest.java | 2 +-
.../plan/planner/PipelineBuilderTest.java | 55 +
.../plan/planner/QueryLogicalPlanUtil.java | 27 +-
.../distribution/AggregationDistributionTest.java | 64 +-
.../AlignByTimeOrderByLimitOffsetTest.java | 5 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 3 +-
.../node/process/GroupByTagNodeSerdeTest.java | 22 +-
.../storageengine/dataregion/DataRegionTest.java | 10 +-
.../dataregion/LastFlushTimeMapTest.java | 121 +-
.../compaction/CompactionSchedulerTest.java | 1 -
.../compaction/CompactionValidationTest.java | 103 ++
.../FastInnerCompactionPerformerTest.java | 108 ++
.../compaction/ReadChunkInnerCompactionTest.java | 144 +++
...eCompactionWithFastPerformerValidationTest.java | 4 +-
...actionWithReadPointPerformerValidationTest.java | 2 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 4 +-
.../cross/InsertionCrossSpaceCompactionTest.java | 6 +-
.../compaction/inner/InnerCompactionTest.java | 1 +
...nkCompactionPerformerWithAlignedSeriesTest.java | 768 ++++++++++++
.../compaction/repair/RepairLoggerTest.java | 118 ++
.../repair/RepairUnsortedFileCompactionTest.java | 1005 +++++++++++++++
.../compaction/utils/CompactionCheckerUtils.java | 8 +-
.../compaction/utils/CompactionConfigRestorer.java | 4 -
.../compaction/utils/CompactionTestFileWriter.java | 8 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 12 +-
.../dataregion/wal/node/WALEntryHandlerTest.java | 13 +-
.../wal/node/WalDeleteOutdatedNewTest.java | 585 +++++++++
.../wal/recover/WALRecoverWriterTest.java | 9 +-
.../rescon/memory/TimePartitionManagerTest.java | 41 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 -
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 87 +-
.../resources/conf/iotdb-cluster.properties | 5 +-
.../resources/conf/iotdb-common.properties | 64 +-
.../sbin/{clean-all.bat => destroy-all.bat} | 22 +-
.../sbin/{clean-all.sh => destroy-all.sh} | 59 +-
...clean-confignode.bat => destroy-confignode.bat} | 34 +-
.../{clean-confignode.sh => destroy-confignode.sh} | 7 +-
.../{clean-datanode.bat => destroy-datanode.bat} | 14 +-
.../{clean-datanode.sh => destroy-datanode.sh} | 7 +-
.../src/assembly/resources/sbin/start-all.sh | 9 +-
.../src/assembly/resources/sbin/stop-all.sh | 15 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 1 -
.../iotdb/commons/auth/role/BasicRoleManager.java | 7 +
.../commons/auth/role/LocalFileRoleAccessor.java | 12 +-
.../commons/auth/role/LocalFileRoleManager.java | 6 +
.../iotdb/commons/auth/user/BasicUserManager.java | 1 +
.../commons/auth/user/LocalFileUserAccessor.java | 23 +-
.../commons/auth/user/LocalFileUserManager.java | 5 +
.../iotdb/commons/client/ClientPoolFactory.java | 29 +-
.../client/property/ClientPoolProperty.java | 35 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 52 +-
.../iotdb/commons/conf/CommonDescriptor.java | 33 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 11 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 120 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 20 +-
.../config/constant/PipeConnectorConstant.java | 2 +
.../pipe/config/constant/SystemConstant.java} | 15 +-
.../connector/payload/request/PipeRequestType.java | 4 +-
.../builtin/connector/iotdb/IoTDBConnector.java | 34 +-
.../commons/pipe/task/meta/PipeMetaKeeper.java | 4 +
.../commons/pipe/task/subtask/PipeSubtask.java | 15 +-
.../schema/view/viewExpression/ViewExpression.java | 18 +
.../iotdb/commons/service/ThriftService.java | 2 +-
.../service/metric/JvmGcMonitorMetrics.java | 10 +-
.../service/metric}/cpu/CpuUsageMetrics.java | 23 +-
.../udf/builtin/BuiltinAggregationFunction.java | 5 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 8 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 52 +
.../iotdb/commons/client/ClientManagerTest.java | 47 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 1 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 3 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 17 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 7 +-
.../write/writer/RestorableTsFileIOWriter.java | 1 -
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 52 +-
.../writer/TsFileIOWriterMemoryControlTest.java | 34 +-
.../thrift-commons/src/main/thrift/common.thrift | 4 +-
.../src/main/thrift/confignode.thrift | 17 +-
.../src/main/thrift/datanode.thrift | 3 +
pom.xml | 6 +-
443 files changed, 16770 insertions(+), 5633 deletions(-)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBFlushQueryMergeIT.java
=> IoTDBFlushQueryIT.java} (98%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRepairDataIT.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/PipeTaskOperation.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/maxby/IoTDBMaxBy2IT.java
(57%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/InsertionCrossCompactionTaskResource.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/maxby/IoTDBMaxBy3IT.java
(50%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/maxby/IoTDBMaxByAlignedSeriesIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/maxby/IoTDBMaxByIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeAlterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeNullValueIT.java
create mode 100644
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/UserDefinedEvent.java
create mode 100644
iotdb-client/cli/src/assembly/resources/tools/collect-info.bat
rename iotdb-client/cli/src/assembly/resources/tools/{collection-info.sh =>
collect-info.sh} (59%)
delete mode 100644
iotdb-client/cli/src/assembly/resources/tools/collection-info.bat
copy
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/RatisReadUnavailableException.java
=> iotdb-client/cli/src/main/java/org/apache/iotdb/cli/type/ExitType.java (66%)
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/cli/utils/CliContext.java
rename
iotdb-core/confignode/src/assembly/resources/sbin/{register-confignode.sh =>
daemon-confignode.sh} (75%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/AlterPipePlanV2.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AlterPipeProcedureV2Test.java
rename iotdb-core/datanode/src/assembly/resources/sbin/{register-datanode.sh
=> daemon-datanode.sh} (75%)
copy
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/exception/RatisReadUnavailableException.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/common/PipeTransferHandshakeConstant.java}
(67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferHandshakeReq.java
=> PipeTransferHandshakeV1Req.java} (83%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferHandshakeReq.java
=> PipeTransferHandshakeV2Req.java} (56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/UserDefinedEnrichedEvent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/MaxByAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/RepairDataTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/AlterPipeTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/AlterPipeStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/RepairDataStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/pagemgr/PageIOChannel.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/pagemgr/PageIndexSortBuckets.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/pagemgr/PagePool.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/pagemgr/SchemaPageContext.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/auth/role/LocalFileRoleManager.java
=>
datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DeviceLastFlushTime.java}
(50%)
copy
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/exception/RatisReadUnavailableException.java
=>
datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/ILastFlushTime.java}
(62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/planner/plan/LogicalQueryPlan.java
=> storageengine/dataregion/PartitionLastFlushTime.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/performer/impl/RepairUnsortedFileCompactionPerformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/RepairUnsortedFileCompactionTask.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/{task/CompactionTaskPriorityType.java
=> utils/executor/ModifiedStatus.java} (71%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/ReadChunkAlignedSeriesCompactionExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/loader/ChunkLoader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/loader/InstantChunkLoader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/loader/InstantPageLoader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/loader/PageLoader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/RepairUnsortedFileCompactionWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/repair/RepairLogger.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/repair/RepairTaskRecoverLogParser.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/repair/RepairTimePartition.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/repair/UnsortedFileRepairTaskScheduler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/RepairUnsortedFileCompactionEstimator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/{compaction/execute/task/CompactionTaskPriorityType.java
=> tsfile/TsFileRepairStatus.java} (67%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionSimpleRecoverTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/NewReadChunkCompactionPerformerWithAlignedSeriesTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/repair/RepairLoggerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/repair/RepairUnsortedFileCompactionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WalDeleteOutdatedNewTest.java
rename iotdb-core/node-commons/src/assembly/resources/sbin/{clean-all.bat =>
destroy-all.bat} (68%)
rename iotdb-core/node-commons/src/assembly/resources/sbin/{clean-all.sh =>
destroy-all.sh} (63%)
rename
iotdb-core/node-commons/src/assembly/resources/sbin/{clean-confignode.bat =>
destroy-confignode.bat} (81%)
rename
iotdb-core/node-commons/src/assembly/resources/sbin/{clean-confignode.sh =>
destroy-confignode.sh} (89%)
rename iotdb-core/node-commons/src/assembly/resources/sbin/{clean-datanode.bat
=> destroy-datanode.bat} (95%)
rename iotdb-core/node-commons/src/assembly/resources/sbin/{clean-datanode.sh
=> destroy-datanode.sh} (93%)
copy
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/exception/RatisReadUnavailableException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/SystemConstant.java}
(67%)
rename
iotdb-core/{metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets
=>
node-commons/src/main/java/org/apache/iotdb/commons/service/metric}/cpu/CpuUsageMetrics.java
(94%)
