This is an automated email from the ASF dual-hosted git repository.
HTHou pushed a change to branch codex/trusted-channel-failure-hooks
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f154305b80f Address trusted channel review feedback
add 47f71715238 [Pipe] Fairly limit concurrent TsFile parsers (#18260)
add 965e8635a48 Fix inexact varargs calls (#18294)
add 939500d0990 Fix grouped max for non-positive floating-point values
(#18300)
add b4da74291db Remove obsolete DataNode audit log appender (#18292)
add 165cd4cafd2 Improve error messages for unsupported __audit database
operations (#18309)
add 1eb7c30faa2 [Pipe] Use buffered input for TsFile scan parser (#18254)
add d29dcf8247a Track null value ratio of flushed MemTables (#18287)
add 53d701c433f Fix concurrent access to IoTConsensus configuration
(#18290)
add 59f349c9844 [Pipe] Preserve parser fairness and OOM retry state
(#18305)
add 5adcc2c5f88 Reject database paths with empty nodes on ConfigNode
(#18308)
add 892dbd85bab Fix floating-point sentinel misuse in KDTree and SDT
(#18302)
add 2fd1fe3fda4 support the retry for the execution the insert path in
statemachine with DN metadata fenced and retry for coordinator (#18301)
add 39e2ad07882 [Load] Handle empty path nodes during database
auto-creation (#18307)
add cb6a309521d Fix Region recovery validation before DataNode startup
success (#18311)
add 8c68dd71f86 Optimize pipe request serialization buffer sizing (#18233)
add 11aa5069a6d Prevent pipe receiver statement exception log floods
(#18318)
add 3cf99bd9fa0 Fix IoTConsensus SyncLog retry handling (#18317)
add 913104e741e Fix flaky pipe idempotent table IT (#18316)
add fe77cf1e0ae Fix invalid WAL throttle threshold persistence (#18327)
add f3d111c78a6 Reject NaN disk space warning threshold on hot reload
(#18326)
add 98a7d511a78 Avoid stale Poetry cache when locking AINode dependencies
(#18329)
add b008bd6e03d Add CorruptedTsFileException for TsFile corruption errors
with file path (#18304)
add 44b2cf5676a [Subscription] Bound consensus prefetch memory usage
(#18298)
add 23201f223ca Fix WAL throttle threshold fallback on hot reload (#18336)
add 343acc440f7 Fix region migration IT memory proportions (#18337)
add 834418ed5ed [Pipe] Improve timeout diagnostics and DROP PIPE
observability (#18297)
add 39a20ce31b4 Fix table device recovery from schema snapshots (#18324)
add 9e909d3ce26 [Fix] Reconcile actual aligned TVList memory usage (#18330)
add 55a53f6d6fd [Pipe] Relax flaky TsFile event test timeouts (#18332)
add 8d5da83f0df Preserve Pipe sink exception root causes (#18335)
add 7e0812a9881 Fix procedure metrics before executor initialization
(#18338)
add 486102749dd Bump at.yawk.lz4:lz4-java from 1.10.1 to 1.11.1 (#18322)
add f3f7d125fe0 [Pipe] Fix TsFile rate limit accounting (#18344)
add f39d0e932cf Fix oversized audit logs for tree batch writes (#18345)
add 410ab85f2ae Fix corrupted TsFile IT file selection (#18346)
add 847cc6d1848 Fix ConfigNode leader transfer retries during removal
(#18348)
add 2882aa9fbc2 Fix retry for schema query internal writes (#18296)
add a6ac4cba687 [Pipe] Release tablet memory before closing TsFile scan
parser (#18350)
add 85711da2091 Fix table function audit operation type (#18351)
add 3fd6e26eb32 fix(consensus): preserve SyncLog retry ordering (#18323)
add a8497bef9ff Record audit log when updating user password (#18357)
add 17e4efb6922 Record audit logs when revoke failed (#18352)
add 3a06ed41d5d Disable multi-node REMOVE statements (#18360)
add 647e5363152 Remove Ratis region migration rate limiting (#18365)
add 71700468942 [Pipe] Fix historical TsFile schema recovery race (#18314)
add 6559aa52ba9 Pipe: Handle hybrid meta progress indexes (#18331)
add a321fa34d5d Subscription: preserve topic updates during owner transfer
(#18353)
add 154644107a8 Pipe: Respect history enable with source time range
(#18362)
add 75eaa40744b Fix race condition in ExternalTsFileQueryResource
reference counting (#18371)
add 09252d40064 feat(load): reject managed TsFile directories (#18271)
add d82806fa208 Subscription: Rename topic modes to initial and
incremental (#18370)
add 7ce80b15264 Merge remote-tracking branch 'origin/master' into
codex/trusted-channel-failure-hooks
add 1b478188b02 Fix trusted channel failure reporting coverage
add 157efaef283 Use provider-compatible file deletion and truncation APIs
(#18349)
add cc583ca61b0 Fix query analyze metric of TableModel
add 83d536aa17d [Fix] Keep heartbeat alive when metadata lease is fenced
(#18343)
add e23500e1a10 Support rate family aggregation functions in table model
(#18334)
add cde1601d17d [Pipe] Batch OPC UA sink writes (#18380) (#18384)
add bee70a863b4 Fix IndexOutOfBoundsException caused by concurrent sort
and delete on TVList (#18389)
add f6a844d8191 Query: Optimize schema traversal for non-leading tag IN
predicates (#18369)
add 303686e8604 Pipe: Add receiver session authentication integration
tests (#18395)
add c46c0732bb3 Record audit logs for normal and failed role grants and
revokes (#18355)
add f49370013af Fix config event race in pipe idempotent table IT (#18403)
add 346abc37df2 Fix DataNode restart during database deletion (#18407)
add a0543f5aa21 [ConfigNode] Revert procedure-based RegionGroup cleanup
and fix RegionMaintainer retries (#18404)
add 14ecc9f212a [Performance] Reduce allocations on aligned tablet writes
(#18358)
add 6a253567b08 Fix write-back sink tree target database case (#18398)
add 9fe55fce9a9 Fix table UDF result block splitting (#18333)
add 84c4bafa38d [Subscription] Reduce consensus WAL replay and ACK
contention (#18402)
add 513a093f6dc Fix silent deduplication of duplicate tag columns in COPY
TO statement (#18408)
add c6afaf54957 Fix table model set configuration audit logging (#18412)
add ec473f7fd1d [Subscription] Isolate tree and table topics (#18397)
add 0d94b765427 Optimize aligned memtable flush without deleted
measurements (#18406)
add feba0c62b8a feat(load): reject active load listening dirs under data
directory (#18405)
add 5be170d6a1f Fix pipe tablet memory resize admission limit (#18413)
add 7e2c453fbd1 fix(load): use buffered input when splitting TsFiles
(#18388)
add 81c2b05c67f Bump tsfile to 2.4.1-260806-SNAPSHOT and add
COPY_TO_WRITE_ERROR for COPY TO write failures (#18414)
add fcaa2f82267 Pipe: Reuse clusters across related integration tests
(#18400)
add c4616685b1a Fix SHOW QUERIES and KILL QUERY privilege filtering
(#18359)
add e281a308851 Reduce AirGap receiver log noise (#18424)
add d1f362d3ca3 Pipe: Handle transient resource failures locally (#18381)
add bc5b6a2d162 Fix subscription topic authorization bypass (#18418)
add 85442f00f85 [Load] Isolate reused TsFile parser memory from Pipe pool
(#18419)
add 10950e13ea9 Pipe: dynamically share idle floating memory (#18422)
add 50a2e83eb65 fix: validate internal tsfile paths for files only (#18417)
add 5d163835737 Support high availability for the authority module (#18425)
add 4b237744707 modify the deal strategy for metadata lease exception in
DataDriver and ErrorHandlingUtils (#18438)
add ab881319f22 Fix fragment failure race with concurrent cancellation
(#18439)
add 02f43e73f47 Upgrade Eclipse Milo to 1.1.6 (#18431)
add 3c0c7fef006 [Pipe] Fix processor worker starvation on pipe stop
(#18396)
add 17e3b4e9460 clone partial columns of aligned tvlist for query (#18409)
add ef0a792a3aa fix(pipe): reuse safe local progress on alter (#18423)
add 6ca8850a25b [Pipe] Support configurable TsFile parser (#18440)
add 2479dc63531 Subscription: clean up consumers after abrupt disconnect
(#18434)
add e1030c5e00e fix: reuse pre-computed ArrayList instance size in
AlignedTVList ram cost (#18452)
add e509114c515 fix: retry SyncStatus batch memory reservation (#18453)
add 0ea96b543ea Bump ratis to 3.3.0 (#18320)
add 96c905e8146 [SQL] Add STREAM and STREAMS as reserved keywords (#18458)
add 27e9920399b feat: cache sorted WAL file lists (#18456)
add ab7a911fdb2 [Subscription] Fix pending consensus request memory leak
(#18429)
add 8b0abccd89a [Subscription] Exclude audit database from subscriptions
(#18451)
add a110cc024f9 fix flush average points num may be mixed in one region
(#18460)
add 9b2784c3ad4 Fix data exchange failure propagation (#18468)
add cec4f9b111b Fix audit database filtering for consensus pipes (#18476)
add dc2e7c861b6 [Pipe] Optimize OPC UA TsFile last-value transfer (#18433)
add 5db9f416143 fix(subscription): avoid per-provider poll backoff (#18448)
add 4eff4c1654c [Pipe] Support receiver-side async takeover for TsFile
conversion (#18421)
add dc47a3baa0a Stabilize air-gap batch compression IT
add ada62cb1048 [Pipe] Fix conversion task ID collision after leader
switch (#18494)
add 5221cf49ed0 fix: make CompactionWorkerTest UT deterministic by using
CountDownLatch instead of fixed 2s sleep to wait for task drop status reset
(#18498)
add c63d0e82efc [DOC] Clarify internal RPC trust boundary in threat model
(#18504)
add c8e73f30ac3 Add the setting for JAVA_HOME in the start-cli.bat file
(#18503)
add 541b9a32d8e Fix unsolicited AirGap responses on idle timeout (#18502)
add 41c0e2d4ee8 [Subscription] Isolate tree and table consensus topics
(#18469)
add e591e66c0f5 Fix IoTConsensus batch accumulation and config reload
(#18501)
add fdce12d7972 Fix subscription event loss on poll payload overflow
(#18471)
add a4e56ce5c2f [Subscription] Fix WAL replay after leader failover
(#18474)
add 130b1bbe170 Merge remote-tracking branch 'origin/master' into
codex/trusted-channel-failure-hooks
No new revisions were added by this update.
Summary of changes:
LICENSE-binary | 2 +-
THREAT_MODEL.md | 41 +-
dependencies.json | 17 +-
example/pipe-opc-ua-sink/pom.xml | 4 +-
.../java/org/apache/iotdb/opcua/ClientExample.java | 4 +-
.../apache/iotdb/opcua/ClientExampleRunner.java | 41 +-
.../java/org/apache/iotdb/opcua/ClientTest.java | 54 +-
.../ConsensusSubscriptionWalFileAnalyzer.java | 5 +-
.../iotdb/ConsensusSubscriptionSessionExample.java | 2 +-
...sensusTableModelSubscriptionSessionExample.java | 2 +-
.../rest/TrustedChannelAuditHandshakeListener.java | 6 +-
.../rest/protocol/filter/AuthorizationFilter.java | 7 +-
.../protocol/handler/AuthorizationHandler.java | 16 +-
.../rest/protocol/v1/impl/RestApiServiceImpl.java | 3 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 3 +-
.../relational/LargeResultTableFunction.java | 136 ++
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 9 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 9 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 2 +-
.../IoTDBRegionMigrateNormalITForIoTV2BatchIT.java | 2 +-
.../IoTDBRemoveConfigNodeITFramework.java | 20 +-
.../IoTDBRemoveDataNodeNormalIT.java | 7 -
.../db/it/IoTDBAlignedTVListLazyAllocationIT.java | 5 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 22 +
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 42 +
.../org/apache/iotdb/db/it/IoTDBShowQueriesIT.java | 155 +++
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 2 +-
.../iotdb/db/it/auth/IoTDBTemplateAuthIT.java | 7 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 4 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 10 +-
.../treemodel/auto/basic/IoTDBPipeAlterIT.java | 48 +
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 60 +
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 5 +
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 4 +-
.../manual/IoTDBPipeManualConflictIT.java | 70 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 147 ++-
.../treemodel/manual/IoTDBPipeWriteBackSinkIT.java | 24 +-
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 219 ----
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 33 +-
.../iotdb/pipe/it/single/IoTDBPipeReceiverIT.java | 612 +++++++++
.../it/db/it/IoTDBAuthenticationTableIT.java | 9 +
.../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 80 ++
.../recent/IoTDBQueryWithCorruptedTsFileIT.java | 355 +++++
.../it/query/recent/IoTDBTableAggregationIT.java | 579 +++++++-
.../query/recent/copyto/IoTDBCopyToTsFileIT.java | 38 +-
.../it/schema/IoTDBAlterColumnTypeIT.java | 9 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 5 +-
.../relational/it/schema/IoTDBTableAuthHAIT.java | 670 ++++++++++
.../local/ConsensusSubscriptionITSupport.java | 2 +-
.../ConsensusSubscriptionTableITSupport.java | 2 +-
...ConsensusSubscriptionColumnFilterClusterIT.java | 2 +-
...ensusSubscriptionConsumerDisconnectTableIT.java | 298 +++++
.../IoTDBSubscriptionColumnFilterIT.java | 5 +-
.../tablemodel/IoTDBSubscriptionIsolationIT.java | 161 ++-
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 2 +-
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +-
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 4 +-
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 3 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 3 +
.../org/apache/iotdb/tool/data/ImportData.java | 3 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 5 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 8 +-
.../iotdb/rpc/TElasticFramedTransportTest.java | 68 +
.../iotdb/session/AbstractSessionBuilder.java | 4 +
.../org/apache/iotdb/session/NodesSupplier.java | 66 +-
.../java/org/apache/iotdb/session/Session.java | 23 +-
.../apache/iotdb/session/SessionConnection.java | 14 +
.../org/apache/iotdb/session/pool/SessionPool.java | 16 +-
.../iotdb/session/SessionConnectionTest.java | 55 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 23 +
.../subscription/i18n/SubscriptionMessages.java | 2 +-
.../subscription/i18n/SubscriptionMessages.java | 2 +-
.../iotdb/rpc/subscription/config/TopicConfig.java | 51 +-
.../rpc/subscription/config/TopicConstant.java | 19 +-
.../base/AbstractSubscriptionConsumer.java | 26 +-
.../base/AbstractSubscriptionProviders.java | 8 +
.../rpc/subscription/config/TopicConfigTest.java | 57 +
.../SubscriptionConsumerMultiProviderPollTest.java | 281 ++++
iotdb-core/ainode/build_binary.py | 5 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 60 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 60 +
.../process/function/TableFunctionOperator.java | 51 +-
.../process/function/partition/PartitionCache.java | 2 +-
.../relational/aggregation/AccumulatorFactory.java | 141 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 4 +-
.../rate/AbstractGroupedDeltaAccumulator.java | 138 ++
.../rate/AbstractGroupedIncreaseAccumulator.java | 147 +++
.../rate/AbstractGroupedIrateAccumulator.java | 83 ++
.../rate/AbstractGroupedRateAccumulator.java | 150 +++
.../grouped/rate/GroupedNaiveDeltaAccumulator.java | 141 ++
.../rate/GroupedNaiveIncreaseAccumulator.java | 151 +++
.../grouped/rate/GroupedNaiveIrateAccumulator.java | 120 ++
.../grouped/rate/GroupedNaiveRateAccumulator.java | 148 +++
.../rate/GroupedOrderedDeltaAccumulator.java | 159 +++
.../rate/GroupedOrderedIncreaseAccumulator.java | 167 +++
.../rate/GroupedOrderedIrateAccumulator.java | 143 ++
.../rate/GroupedOrderedRateAccumulator.java | 164 +++
.../grouped/rate/TimeValueBufferBigArray.java | 75 ++
.../rate/AbstractDeltaTableAccumulator.java | 109 ++
.../rate/AbstractIncreaseTableAccumulator.java | 118 ++
.../rate/AbstractIrateTableAccumulator.java | 78 ++
.../rate/AbstractRateTableAccumulator.java | 121 ++
.../aggregation/rate/ExtrapolationUtil.java | 139 ++
.../aggregation/rate/NaiveDeltaAccumulator.java | 155 +++
.../aggregation/rate/NaiveIncreaseAccumulator.java | 171 +++
.../aggregation/rate/NaiveIrateAccumulator.java | 143 ++
.../aggregation/rate/NaiveRateAccumulator.java | 163 +++
.../aggregation/rate/OrderedDeltaAccumulator.java | 143 ++
.../rate/OrderedIncreaseAccumulator.java | 150 +++
.../aggregation/rate/OrderedIrateAccumulator.java | 133 ++
.../aggregation/rate/OrderedRateAccumulator.java | 147 +++
.../rate/RateFunctionIntermediateStateCodec.java | 201 +++
.../aggregation/rate/RateFunctionType.java} | 43 +-
.../aggregation/rate/RateFunctionValidation.java | 119 ++
.../aggregation/rate/TimeValueBuffer.java | 228 ++++
.../calc/plan/planner/TableOperatorGenerator.java | 4 +
.../planner/memory/MemoryReservationManager.java | 6 +
.../datastructure/SerializableList.java | 28 +-
.../iotdb/calc/utils/constant/SqlConstant.java | 4 +
.../aggregation/GroupedMaxAccumulatorTest.java | 124 ++
.../rate/GroupedRateAccumulatorMemoryTest.java | 96 ++
.../aggregation/rate/ExtrapolationUtilTest.java | 65 +
.../rate/RateAccumulatorFactoryTest.java | 181 +++
.../RateFunctionIntermediateStateCodecTest.java | 157 +++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 22 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 11 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 51 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 24 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 11 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 63 +-
.../async/AsyncAINodeHeartbeatClientPool.java | 34 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 18 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 37 +-
.../CnToCnInternalServiceAsyncRequestManager.java | 13 +
.../client/async/CnToDnAsyncRequestType.java | 4 +
.../CnToDnInternalServiceAsyncRequestManager.java | 11 +
.../heartbeat/DataNodeHeartbeatHandler.java | 3 +-
.../client/sync/SyncAINodeClientPool.java | 14 +
.../client/sync/SyncConfigNodeClientPool.java | 16 +-
.../client/sync/SyncDataNodeClientPool.java | 7 +-
.../write/subscription/topic/DropTopicPlan.java | 31 +-
.../response/pipe/task/PipeTableResp.java | 1 +
.../iotdb/confignode/manager/ConfigManager.java | 16 +-
.../iotdb/confignode/manager/ProcedureManager.java | 133 +-
.../iotdb/confignode/manager/node/NodeManager.java | 79 +-
.../manager/partition/PartitionManager.java | 334 +++--
.../pipe/agent/task/PipeConfigNodeSubtask.java | 8 +
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 17 +-
.../runtime/PipeRuntimeCoordinator.java | 7 +-
.../runtime/heartbeat/PipeHeartbeat.java | 29 +
.../runtime/heartbeat/PipeHeartbeatParser.java | 9 +
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 6 +-
.../manager/schema/ClusterSchemaManager.java | 7 +-
.../subscription/SubscriptionCoordinator.java | 127 +-
.../runtime/SubscriptionRuntimeCoordinator.java | 2 +-
.../confignode/persistence/ProcedureInfo.java | 40 +-
.../confignode/persistence/node/NodeInfo.java | 3 +-
.../persistence/partition/PartitionInfo.java | 32 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 58 +-
.../persistence/schema/ClusterSchemaInfo.java | 12 +-
.../persistence/schema/TemplatePreSetTable.java | 3 +-
.../persistence/schema/TemplateTable.java | 3 +-
.../persistence/subscription/SubscriptionInfo.java | 216 ++-
.../confignode/procedure/ProcedureExecutor.java | 12 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 111 +-
.../procedure/env/RegionMaintainHandler.java | 4 +-
.../procedure/impl/StateMachineProcedure.java | 11 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 216 ++-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +
.../impl/pipe/task/AlterPipeProcedureV2.java | 98 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 48 +-
.../impl/region/CreateRegionGroupsProcedure.java | 44 +-
.../impl/region/RemoveRegionGroupProcedure.java | 389 ------
.../impl/schema/DeleteDatabaseProcedure.java | 111 +-
.../SubscriptionHandleLeaderChangeProcedure.java | 2 +-
.../subscription/CreateSubscriptionProcedure.java | 5 +-
.../subscription/DropSubscriptionProcedure.java | 5 +-
.../subscription/topic/AlterTopicProcedure.java | 70 +-
.../subscription/topic/CreateTopicProcedure.java | 6 +-
.../subscription/topic/DropTopicProcedure.java | 41 +-
.../impl/sync/AuthOperationProcedure.java | 86 +-
.../confignode/procedure/scheduler/LockQueue.java | 6 +-
.../state/schema/DeleteDatabaseState.java | 5 +-
.../procedure/store/ProcedureFactory.java | 13 +-
.../confignode/procedure/store/ProcedureType.java | 2 +-
.../confignode/procedure/store/ProcedureWAL.java | 10 +-
.../writelog/io/SingleFileLogReader.java | 8 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 10 +-
.../consensus/response/pipe/PipeTableRespTest.java | 31 +
.../manager/ClusterSchemaManagerTest.java | 37 +
.../confignode/manager/node/NodeManagerTest.java | 189 +++
.../PartitionManagerRegionMaintainTest.java | 70 +
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 88 +-
.../subscription/SubscriptionCoordinatorTest.java | 155 +++
.../confignode/persistence/PartitionInfoTest.java | 27 -
.../pipe/PipeTaskInfoAutoRestartTest.java | 41 +
.../persistence/schema/ClusterSchemaInfoTest.java | 17 +
.../subscription/SubscriptionInfoTest.java | 66 +
.../SubscriptionInfoTopicValidationTest.java | 203 ++-
.../procedure/TestProcedureExecutor.java | 15 +
.../pipe/AbstractOperatePipeProcedureV2Test.java | 31 +
.../impl/pipe/task/DropPipeProcedureV2Test.java | 154 +++
.../region/RemoveRegionGroupProcedureTest.java | 100 --
.../CreateSubscriptionProcedureTest.java | 2 +-
.../DropSubscriptionProcedureTest.java | 2 +-
.../topic/AlterTopicProcedureTest.java | 82 +-
.../subscription/topic/DropTopicProcedureTest.java | 19 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 6 +
.../consensus/i18n/IoTConsensusV2Messages.java | 3 -
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 6 +
.../consensus/i18n/IoTConsensusV2Messages.java | 3 -
.../common/request/IndexedConsensusRequest.java | 44 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 20 +-
.../consensus/iot/IoTConsensusServerImpl.java | 65 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 55 +-
.../iot/client/IoTConsensusClientPool.java | 31 +-
.../iot/client/SyncIoTConsensusServiceClient.java | 35 +-
.../iot/client/TrustedChannelFailureReporter.java | 49 +
.../logdispatcher/IoTConsensusMemoryManager.java | 76 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 42 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 20 +-
.../iot/service/IoTConsensusRPCService.java | 4 +
.../subscription/SubscriptionQueueRegistry.java | 10 +-
.../iotdb/consensus/pipe/IoTConsensusV2.java | 88 +-
.../pipe/service/IoTConsensusV2RPCService.java | 4 +
.../ratis/ApplicationStateMachineProxy.java | 44 +-
.../ratis/RateLimitedGrpcLogAppender.java | 76 --
.../iotdb/consensus/ratis/RatisConsensus.java | 2 -
.../consensus/iot/IoTConsensusServerImplTest.java | 162 +++
.../apache/iotdb/consensus/iot/ReplicateTest.java | 189 +++
.../client/TrustedChannelFailureReporterTest.java | 73 ++
.../IoTConsensusMemoryManagerTest.java | 100 ++
.../iot/logdispatcher/LogDispatcherTest.java | 224 ++++
.../iot/logdispatcher/SyncStatusTest.java | 64 +
.../SubscriptionQueueRegistryTest.java | 108 ++
.../iotdb/consensus/pipe/IoTConsensusV2Test.java | 55 +
.../ratis/RateLimitedGrpcLogAppenderTest.java | 66 -
iotdb-core/datanode/pom.xml | 14 +-
.../assembly/resources/conf/logback-datanode.xml | 18 -
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 48 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 25 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 48 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 4 +
.../iotdb/db/i18n/StorageEngineMessages.java | 23 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 45 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 25 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 45 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 4 +
.../iotdb/db/i18n/StorageEngineMessages.java | 21 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 389 +++++-
.../iotdb/db/audit/PasswordChangeAuditContext.java | 187 +++
.../iotdb/db/audit/PasswordChangeAuditTask.java | 87 ++
.../db/audit/UserRoleModificationAuditContext.java | 184 +++
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 28 +-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 9 -
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 68 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 2 -
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 137 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 96 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 15 +
.../db/consensus/SchemaRegionConsensusImpl.java | 25 +-
.../dataregion/DataExecutionVisitor.java | 11 +
.../dataregion/DataRegionStateMachine.java | 14 +-
.../db/exception/CorruptedTsFileException.java | 70 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 126 +-
.../agent/task/builder/PipeDataNodeBuilder.java | 2 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 56 +-
.../agent/task/connection/PipeEventCollector.java | 17 +-
.../subtask/processor/PipeProcessorSubtask.java | 97 +-
.../PipeProcessorSubtaskExecutionGuard.java | 110 ++
.../processor/PipeProcessorSubtaskWorker.java | 129 +-
.../PipeProcessorSubtaskWorkerManager.java | 15 +-
.../PipeProcessorSubtaskYieldException.java | 53 +
.../agent/task/subtask/sink/PipeSinkSubtask.java | 10 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 22 +-
.../consensus/deletion/recover/DeletionReader.java | 7 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 61 +-
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 1 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 285 ++--
.../tsfile/parser/TsFileInsertionEventParser.java | 44 +-
.../TsFileInsertionEventParserMemoryBlock.java} | 24 +-
.../TsFileInsertionEventParserMemoryManager.java | 75 ++
.../parser/TsFileInsertionEventParserProvider.java | 62 +
.../query/TsFileInsertionEventQueryParser.java | 69 +-
...ileInsertionEventQueryParserTabletIterator.java | 10 +-
.../scan/TsFileInsertionEventScanParser.java | 335 +++--
.../table/TsFileInsertionEventTableParser.java | 112 +-
...ileInsertionEventTableParserTabletIterator.java | 198 +--
.../processor/aggregate/AggregateProcessor.java | 16 +-
.../sdt/SwingingDoorTrendingFilter.java | 8 +-
.../twostage/plugin/TwoStageCountProcessor.java | 29 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 54 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 3 +-
.../protocol/legacy/loader/TsFileLoader.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 233 +++-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 4 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 16 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 408 +++++-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 24 +-
.../batch/PipeTabletEventTsFileBatch.java | 3 +-
.../request/PipeTransferTabletBatchReq.java | 27 +-
.../request/PipeTransferTabletBatchReqV2.java | 43 +-
.../request/PipeTransferTabletBinaryReq.java | 14 +-
.../request/PipeTransferTabletBinaryReqV2.java | 28 +-
.../request/PipeTransferTabletInsertNodeReq.java | 20 +-
.../request/PipeTransferTabletInsertNodeReqV2.java | 16 +-
.../request/PipeTransferTabletRawReq.java | 13 +-
.../request/PipeTransferTabletRawReqV2.java | 14 +-
.../request/PipeTransferTsFileSealWithModReq.java | 263 +++-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 44 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 21 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 12 +-
.../request/IoTConsensusV2TabletInsertNodeReq.java | 6 +
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 19 +
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 171 ++-
.../sink/protocol/opcua/client/ClientRunner.java | 46 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 228 +++-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 99 +-
.../protocol/opcua/server/OpcUaServerBuilder.java | 246 ++--
.../thrift/async/IoTDBDataRegionAsyncSink.java | 68 +-
.../async/handler/PipeTransferTsFileHandler.java | 73 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 53 +-
.../sink/protocol/writeback/WriteBackSink.java | 4 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 9 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 8 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 6 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 5 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 20 +-
.../dataregion/DataRegionListeningFilter.java | 18 +-
.../source/dataregion/IoTDBDataRegionSource.java | 25 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 50 +-
.../realtime/PipeRealtimeDataRegionSource.java | 9 +
.../realtime/assigner/PipeDataRegionAssigner.java | 1 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 1 +
.../iotdb/db/protocol/client/an/AINodeClient.java | 11 +-
.../DnToCnInternalServiceAsyncRequestManager.java | 8 +
.../client/dn/AsyncTSStatusRPCHandler.java | 26 +-
.../client/dn/DataNodeAsyncRequestRPCHandler.java | 13 +-
...DataNodeExternalServiceAsyncRequestManager.java | 2 +-
.../client/dn/DataNodeIntraHeartbeatManager.java | 2 +-
.../dn/DataNodeMPPServiceAsyncRequestManager.java | 2 +-
.../DnToDnInternalServiceAsyncRequestManager.java | 2 +-
.../db/protocol/session/RestClientSession.java | 6 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 12 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 75 +-
.../thrift/impl/DataNodeRegionManager.java | 18 +-
.../thrift/impl/PushMultiPipeMetaHelper.java | 36 +-
.../db/queryengine/common/MPPQueryContext.java | 6 +-
.../queryengine/execution/driver/DataDriver.java | 20 +-
.../execution/exchange/MPPDataExchangeManager.java | 54 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 121 +-
.../execution/exchange/sink/SinkChannel.java | 24 +-
.../execution/exchange/source/SourceHandle.java | 39 +-
.../fragment/FragmentInstanceContext.java | 51 +-
.../fragment/FragmentInstanceManager.java | 19 +-
.../execution/fragment/QueryContext.java | 11 +
.../process/copyto/TableCopyToOperator.java | 27 +-
.../process/copyto/tsfile/CopyToTsFileOptions.java | 13 +-
.../copyto/tsfile/TsFileFormatCopyToWriter.java | 26 +-
.../execution/operator/source/FileLoaderUtils.java | 65 +-
.../execution/operator/source/SeriesScanUtil.java | 43 +-
.../InformationSchemaContentSupplierFactory.java | 6 +
.../execution/schedule/AbstractDriverThread.java | 28 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 83 +-
.../analyze/cache/partition/PartitionCache.java | 4 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 54 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 37 +-
.../plan/analyze/schema/ISchemaFetcher.java | 19 +
.../plan/analyze/schema/SchemaValidator.java | 34 +-
.../queryengine/plan/execution/QueryExecution.java | 4 +
.../execution/config/TableConfigTaskVisitor.java | 49 +-
.../execution/config/TreeConfigTaskVisitor.java | 65 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../relational/RelationalAuthorizerTask.java | 9 +-
.../plan/execution/config/sys/AuthorizerTask.java | 11 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 9 +
.../db/queryengine/plan/parser/ASTVisitor.java | 3 +-
.../memory/FakedMemoryReservationManager.java | 3 +
.../NotThreadSafeMemoryReservationManager.java | 16 +-
.../memory/ThreadSafeMemoryReservationManager.java | 5 +
.../plan/planner/plan/PlanFragment.java | 4 +
.../plan/node/pipe/PipeEnrichedInsertNode.java | 16 +
.../plan/node/write/InsertMultiTabletsNode.java | 9 +
.../plan/planner/plan/node/write/InsertNode.java | 45 +
.../planner/plan/node/write/InsertRowNode.java | 67 +
.../planner/plan/node/write/InsertRowsNode.java | 15 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 10 +
.../planner/plan/node/write/InsertTabletNode.java | 83 ++
.../plan/node/write/RelationalInsertRowNode.java | 5 +
.../node/write/RelationalInsertTabletNode.java | 15 +
.../plan/relational/analyzer/Analyzer.java | 2 +-
.../read_tsfile/ExternalTsFileQueryResource.java | 104 +-
.../relational/metadata/TableMetadataImpl.java | 49 +
.../cache/TreeDeviceSchemaCacheManager.java | 4 +-
.../distribute/TableDistributedPlanGenerator.java | 74 +-
.../node/schema/TableSchemaQueryWriteVisitor.java | 31 +-
.../PushAggregationIntoTableScan.java | 18 +
.../plan/relational/security/AccessControl.java | 13 +
.../relational/security/AccessControlImpl.java | 49 +-
.../relational/security/AllowAllAccessControl.java | 7 +
.../relational/security/ITableAuthChecker.java | 13 +
.../relational/security/ITableAuthCheckerImpl.java | 41 +-
.../security/TreeAccessCheckVisitor.java | 196 +--
.../plan/relational/sql/ast/LoadTsFile.java | 32 +-
.../plan/relational/sql/parser/AstBuilder.java | 34 +-
.../plan/scheduler/AsyncPlanNodeSender.java | 24 +-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 8 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 5 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 9 +-
.../plan/statement/crud/InsertBaseStatement.java | 46 +
.../crud/InsertMultiTabletsStatement.java | 11 +
.../plan/statement/crud/InsertRowsStatement.java | 29 +
.../plan/statement/crud/LoadTsFileStatement.java | 93 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 33 +-
.../schemaengine/lease/MetadataLeaseManager.java | 10 +-
.../schemaregion/logfile/SchemaLogReader.java | 14 +-
.../schemaregion/logfile/SchemaLogWriter.java | 28 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 15 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 21 +-
.../pbtree/schemafile/log/SchemaFileLogReader.java | 3 +-
.../pbtree/schemafile/pagemgr/PageIOChannel.java | 12 +-
.../schemaregion/mtree/traverser/Traverser.java | 6 +
.../schemaengine/schemaregion/tag/TagManager.java | 4 +-
.../schemaregion/utils/ResourceByPathUtils.java | 339 +++--
.../db/schemaengine/table/DataNodeTableCache.java | 59 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 7 +
.../java/org/apache/iotdb/db/service/DataNode.java | 13 +-
.../iotdb/db/service/RegionMigrateService.java | 12 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 57 +-
.../metrics/memory/QueryEngineMemoryMetrics.java | 26 +-
.../iotdb/db/storageengine/StorageEngine.java | 13 +-
.../db/storageengine/dataregion/DataRegion.java | 12 +-
.../dataregion/flush/CompressionRatio.java | 5 +-
.../dataregion/memtable/AbstractMemTable.java | 74 +-
.../memtable/AbstractWritableMemChunk.java | 26 +-
.../memtable/AlignedReadOnlyMemChunk.java | 4 +-
.../memtable/AlignedWritableMemChunk.java | 182 +++
.../dataregion/memtable/IMemTable.java | 9 +
.../dataregion/memtable/ReadOnlyMemChunk.java | 4 +-
.../dataregion/memtable/TsFileProcessor.java | 394 +++---
.../modification/v1/ModificationFileV1.java | 4 +-
.../v1/io/LocalTextModificationAccessor.java | 37 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 5 +
.../read/reader/chunk/DiskChunkLoader.java | 5 +
.../dataregion/tsfile/TsFileResource.java | 2 +-
.../FileTimeIndexCacheWriter.java | 30 +-
.../dataregion/wal/buffer/WALBuffer.java | 34 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 12 +-
.../storageengine/dataregion/wal/node/WALNode.java | 110 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../load/active/ActiveLoadDirScanner.java | 33 +-
.../load/active/ActiveLoadPathHelper.java | 103 ++
.../load/active/ActiveLoadPendingQueue.java | 26 +-
.../load/active/ActiveLoadTsFileLoader.java | 86 +-
.../load/config/LoadTsFileConfigurator.java | 23 +
...leStatementDataTypeConvertExecutionVisitor.java | 168 ++-
...eeStatementDataTypeConvertExecutionVisitor.java | 245 ++--
.../converter/LoadTreeTsFileTabletIterator.java | 37 +-
.../converter/LoadTsFileDataTypeConverter.java | 2 +-
.../converter/PipeTsFileConversionTaskManager.java | 543 ++++++++
.../load/memory/LoadTsFileParserMemoryManager.java | 120 ++
.../load/splitter/TsFileSplitter.java | 4 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 131 +-
.../rescon/disk/DirectoryChecker.java | 36 +-
.../agent/SubscriptionBrokerAgent.java | 79 +-
.../agent/SubscriptionConsumerAgent.java | 22 +-
.../agent/SubscriptionReceiverAgent.java | 253 +++-
.../subscription/agent/SubscriptionTopicAgent.java | 188 ++-
.../broker/ConsensusSubscriptionBroker.java | 44 +-
.../subscription/broker/ISubscriptionBroker.java | 3 +
.../db/subscription/broker/SubscriptionBroker.java | 35 +-
.../broker/SubscriptionPrefetchingQueue.java | 42 +-
.../consensus/ConsensusLogToTabletConverter.java | 2 +-
.../consensus/ConsensusPrefetchingQueue.java | 918 ++++++++++---
.../ConsensusSubscriptionCommitManager.java | 21 +-
.../ConsensusSubscriptionSetupHandler.java | 100 +-
.../broker/consensus/ProgressWALIterator.java | 251 +++-
.../db/subscription/event/SubscriptionEvent.java | 5 +
.../batch/SubscriptionPipeTabletEventBatch.java | 9 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 8 +-
.../response/SubscriptionEventTabletResponse.java | 5 +-
.../response/SubscriptionEventTsFileResponse.java | 5 +-
.../receiver/SubscriptionReceiver.java | 23 +
.../receiver/SubscriptionReceiverV1.java | 198 ++-
.../SubscriptionDataNodeResourceManager.java | 6 +
.../resource/SubscriptionMemoryManager.java | 89 ++
.../task/subtask/SubscriptionSinkSubtask.java | 3 +-
.../subtask/SubscriptionSinkSubtaskLifeCycle.java | 7 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 7 +-
.../org/apache/iotdb/db/utils/ObjectWriter.java | 31 +-
.../db/utils/datastructure/AlignedTVList.java | 830 +++++++++---
.../db/utils/datastructure/BackAlignedTVList.java | 6 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 6 +-
.../iotdb/db/utils/datastructure/TVList.java | 22 +-
.../db/utils/datastructure/TimAlignedTVList.java | 6 +-
.../apache/iotdb/db/utils/writelog/LogWriter.java | 25 +-
.../db/audit/DNAuditLoggerRevokeFailureTest.java | 183 +++
.../apache/iotdb/db/audit/DNAuditLoggerTest.java | 181 +++
.../DNAuditLoggerUserRoleModificationTest.java | 354 +++++
.../db/audit/PasswordChangeAuditContextTest.java | 327 +++++
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 25 +-
.../db/auth/ClusterAuthorityFetcherLeaseTest.java | 24 +-
.../org/apache/iotdb/db/auth/TreeAccessTest.java | 55 +
.../db/conf/ActiveLoadListeningDirConfigTest.java | 139 ++
.../iotdb/db/conf/DataNodeMemoryConfigTest.java | 67 +
.../org/apache/iotdb/db/conf/PropertiesTest.java | 84 ++
.../dataregion/DataRegionStateMachineTest.java | 143 ++
.../schemaRegion/SchemaRegionManagementTest.java | 38 +
.../SchemaRegionTableDevicePerformanceTest.java | 335 +++++
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 182 +++
.../task/builder/PipeDataNodeTaskBuilderTest.java | 79 ++
.../PipeProcessorSubtaskExecutionGuardTest.java | 247 ++++
.../processor/PipeProcessorSubtaskWorkerTest.java | 151 +++
.../task/subtask/sink/PipeSinkSubtaskTest.java | 142 ++
.../pipe/event/PipeTsFileInsertionEventTest.java | 9 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 265 +++-
.../PipeTsFileInsertionEventAdmissionTest.java | 67 +-
.../sdt/SwingingDoorTrendingFilterTest.java | 17 +
.../plugin/TwoStageCountProcessorTest.java | 55 +
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 69 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 179 ++-
.../memory/PipeMemoryManagerResizeTest.java | 61 +-
.../resource/memory/PipeMemoryManagerTest.java | 384 ++++++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 67 +
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 2 +-
.../request/PipeTransferSerializationSizeTest.java | 530 ++++++++
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 17 +-
.../opcua/OpcUaSinkTsFileMetadataTest.java | 167 +++
.../opcua/OpcUaSinkTsFilePerformanceTest.java | 415 ++++++
.../protocol/opcua/client/ClientRunnerTest.java | 2 +-
.../opcua/client/IoTDBOpcUaClientTest.java | 215 +++
.../opcua/server/OpcUaNameSpaceMetadataTest.java | 167 +++
.../opcua/server/OpcUaServerBuilderTest.java | 104 +-
.../server/OpcUaTcpNoneCompatibilityTest.java | 132 ++
.../PipeTransferTsFileHandlerRateLimitTest.java | 83 ++
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 31 +
.../dataregion/DataRegionListeningFilterTest.java | 65 +
...ricalDataRegionTsFileAndDeletionSourceTest.java | 36 +
...nternalRPCServiceImplPushMultiPipeMetaTest.java | 72 +
.../exchange/MPPDataExchangeManagerTest.java | 80 ++
.../execution/exchange/ShuffleSinkHandleTest.java | 96 ++
.../SinkChannelFailurePropagationTest.java | 364 +++++
.../fragment/FragmentInstanceExecutionTest.java | 212 ++-
.../fragment/FragmentInstanceManagerTest.java | 131 ++
.../fragment/QueryModificationLoaderTest.java | 5 +
.../process/tvf/TableFunctionOperatorTest.java | 331 +++++
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 146 +++
.../config/sys/pipe/ShowPipeTaskTest.java | 13 +-
...est.java => RemoveNodeSingleNodeParseTest.java} | 27 +-
.../LocalExecutionPlannerOperatorsMemoryTest.java | 46 +
.../node/write/InsertRowsNodeSerdeTest.java | 26 +
.../plan/relational/analyzer/AuthTest.java | 51 +
.../metadata/fetcher/SchemaPredicateUtilTest.java | 125 ++
.../planner/AggregationNodeRateSerdeTest.java | 92 ++
.../TableDistributedPlanGeneratorRateTest.java | 124 ++
.../schema/TableSchemaQueryWriteVisitorTest.java | 89 ++
.../relational/security/AccessControlImplTest.java | 119 ++
...java => RemoveNodeSingleNodeStatementTest.java} | 25 +-
.../relational/sql/parser/StreamKeywordTest.java | 127 ++
.../plan/scheduler/AsyncPlanNodeSenderTest.java | 99 ++
.../statement/crud/InsertBaseStatementTest.java | 88 ++
.../statement/crud/LoadTsFileStatementTest.java | 72 +
.../schemaengine/lease/MetadataLeaseTestUtils.java | 9 +-
.../utils/ResourceByPathUtilsTest.java | 113 ++
.../table/DataNodeTableCacheLeaseTest.java | 24 +-
.../DataNodeInternalRPCServiceImplTest.java | 99 ++
.../db/service/metrics/WritingMetricsTest.java | 87 ++
.../TsFileResourceProgressIndexTest.java | 9 +
.../compaction/CompactionWorkerTest.java | 58 +-
.../AbstractMemTablePartialInsertTest.java | 87 +-
...ignedBitmapMemoryAccountingPerformanceTest.java | 493 +++++++
.../dataregion/memtable/MemTableFlushTaskTest.java | 64 +
.../dataregion/memtable/TsFileProcessorTest.java | 179 ++-
.../wal/node/ConsensusReqReaderTest.java | 51 +
.../wal/node/WALFileListCachePerformanceTest.java | 338 +++++
.../wal/node/WalDeleteOutdatedNewTest.java | 12 +
.../db/storageengine/load/TsFileSplitterTest.java | 91 ++
.../load/active/ActiveLoadDirScannerTest.java | 42 +-
.../load/active/ActiveLoadPathHelperTest.java | 60 +-
.../load/active/ActiveLoadTsFileLoaderTest.java | 14 +
...atementDataTypeConvertExecutionVisitorTest.java | 25 +
.../LoadTsFileParserPipeMemoryIsolationTest.java | 66 +
.../PipeTsFileConversionTaskManagerTest.java | 381 ++++++
.../load/memory/LoadTsFileMemoryManagerTest.java | 20 +
.../db/storageengine/load/util/LoadUtilTest.java | 100 +-
.../agent/SubscriptionReceiverAgentTest.java | 273 ++++
...onsensusSubscriptionBrokerPayloadLimitTest.java | 93 ++
.../SubscriptionBrokerAgentPayloadLimitTest.java | 104 ++
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 346 +++++
.../consensus/ConsensusPrefetchingQueueTest.java | 1385 +++++++++++++++++++-
...nsensusPrefetchingQueueWalBackpressureTest.java | 336 +++++
.../ConsensusSubscriptionSetupHandlerTest.java | 60 +
.../broker/consensus/ProgressWALIteratorTest.java | 296 ++++-
.../receiver/SubscriptionReceiverV1Test.java | 94 +-
.../resource/SubscriptionMemoryManagerTest.java | 64 +
.../AlignedBitmapRangeCheckPerformanceTest.java | 201 +++
.../AlignedSparseWritePerformanceTest.java | 314 +++++
.../db/utils/datastructure/AlignedTVListTest.java | 318 ++++-
.../src/test/resources/datanode1conf/logback.xml | 18 -
.../src/test/resources/datanode2conf/logback.xml | 18 -
.../src/test/resources/datanode3conf/logback.xml | 18 -
.../conf/iotdb-system.properties.template | 30 +-
.../apache/iotdb/commons/i18n/PipeMessages.java | 7 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 2 +-
.../apache/iotdb/commons/i18n/PipeMessages.java | 7 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../iotdb/commons/audit/AbstractAuditLogger.java | 2 +-
.../apache/iotdb/commons/audit/AuditEventType.java | 1 +
.../audit/TrustedChannelFailureHandler.java | 5 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 5 +-
.../commons/auth/user/LocalFileUserAccessor.java | 3 +-
.../iotdb/commons/client/ClientPoolFactory.java | 91 +-
.../AsyncConfigNodeInternalServiceClient.java | 65 +-
.../async/AsyncDataNodeInternalServiceClient.java | 65 +-
.../client/request/AsyncRequestManager.java | 14 +-
...nfigNodeInternalServiceAsyncRequestManager.java | 2 +-
.../DataNodeInternalServiceRequestManager.java | 2 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 52 +-
.../sync/SyncDataNodeInternalServiceClient.java | 52 +-
.../sync/SyncThriftClientWithErrorHandler.java | 42 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 43 +
.../iotdb/commons/conf/CommonDescriptor.java | 4 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../commons/consensus/index/ProgressIndex.java | 10 +
.../consensus/index/impl/HybridProgressIndex.java | 25 +
.../consensus/index/impl/IoTProgressIndex.java | 9 +
.../consensus/index/impl/MetaProgressIndex.java | 9 +
.../consensus/index/impl/MinimumProgressIndex.java | 9 +
.../consensus/index/impl/RecoverProgressIndex.java | 9 +
.../consensus/index/impl/SimpleProgressIndex.java | 9 +
.../consensus/index/impl/StateProgressIndex.java | 9 +
.../index/impl/TimePartitionProgressIndex.java | 9 +
.../index/impl/TimeWindowStateProgressIndex.java | 11 +-
.../container/IoTV2GlobalComponentContainer.java | 44 +-
.../exception/MetadataLeaseFencedException.java | 21 +-
.../pipe/PipeRuntimeCriticalException.java | 4 +
.../exception/pipe/PipeRuntimeException.java | 4 +
.../pipe/PipeRuntimeSinkCriticalException.java | 4 +
.../pipe/PipeRuntimeSinkResourceException.java | 51 +
...RuntimeSinkRetryTimesConfigurableException.java | 6 +
.../commons/executable/ExecutableManager.java | 14 +-
.../commons/file/SystemPropertiesHandler.java | 8 +-
.../iotdb/commons/path/ExtendedPartialPath.java | 34 +-
.../apache/iotdb/commons/path/fa/IPatternFA.java | 8 +
.../iotdb/commons/path/fa/nfa/SimpleNFA.java | 102 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 16 +
.../commons/pipe/agent/task/meta/PipeStatus.java | 3 +
.../agent/task/meta/PipeTemporaryMetaInAgent.java | 19 +-
.../task/meta/PipeTemporaryMetaInCoordinator.java | 81 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 33 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 15 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 15 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 10 +
.../pipe/config/constant/PipeSinkConstant.java | 7 +
.../pipe/config/constant/PipeSourceConstant.java | 5 +
.../pipe/config/constant/SystemConstant.java | 3 +
.../options/PipeInclusionOptions.java | 15 +
.../queue/serializer/PlainQueueSerializer.java | 32 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 23 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 19 +-
.../pipe/resource/PipeRecentFailureCounter.java | 93 ++
.../pipe/resource/PipeResourceFailureType.java} | 18 +-
.../commons/pipe/resource/PipeStopStrategy.java | 76 ++
.../pipe/sink/protocol/IoTDBAirGapSink.java | 2 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 31 +
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 2 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 45 +-
.../plan/planner/plan/node/PlanNode.java | 8 +
.../relational/planner/node/AggregationNode.java | 33 +-
.../schema/column/ColumnHeaderConstant.java | 7 +-
.../schema/filter/impl/DeviceFilterUtil.java | 261 +++-
.../apache/iotdb/commons/schema/table/Audit.java | 13 +
.../commons/schema/table/InformationSchema.java | 3 +
.../commons/schema/tree/AbstractTreeVisitor.java | 79 +-
.../TrustedChannelAuditServerEventHandler.java | 34 +-
.../meta/consumer/ConsumerGroupMeta.java | 28 +
.../meta/consumer/ConsumerGroupMetaKeeper.java | 20 +
.../subscription/meta/consumer/ConsumerMeta.java | 4 +
.../subscription/meta/topic/TopicMetaKeeper.java | 42 +-
.../TableBuiltinAggregationFunction.java | 11 +-
.../apache/iotdb/commons/udf/utils/KDTreeUtil.java | 10 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 17 +-
.../org/apache/iotdb/commons/utils/IOUtils.java | 2 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 2 +
.../apache/iotdb/commons/utils/StatusUtils.java | 4 +
.../commons/audit/AbstractAuditLoggerTest.java | 11 +-
.../iotdb/commons/client/ClientManagerTest.java | 313 +++++
.../client/request/AsyncRequestManagerTest.java | 4 +-
...monDescriptorDiskSpaceWarningThresholdTest.java | 2 +-
.../commons/consensus/index/ProgressIndexTest.java | 82 ++
.../agent/task/meta/PipeTemporaryMetaTest.java | 32 +
.../resource/PipeRecentFailureCounterTest.java | 48 +
.../pipe/resource/PipeStopStrategyTest.java | 84 ++
.../pipe/source/IoTDBNonDataRegionSourceTest.java | 172 +++
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 13 +
.../schema/filter/impl/DeviceFilterUtilTest.java | 385 ++++++
.../iotdb/commons/schema/table/AuditTest.java} | 31 +-
.../TrustedChannelAuditServerEventHandlerTest.java | 48 +
.../consumer/ConsumerGroupDeSerTest.java | 25 +
.../subscription/topic/TopicMetaKeeperTest.java | 120 ++
.../iotdb/commons/udf/utils/KDTreeUtilTest.java} | 29 +-
.../apache/iotdb/commons/utils/FileUtilsTest.java | 10 +
.../iotdb/commons/utils/RetryStatusUtilsTest.java} | 32 +-
.../apache/iotdb/commons/utils/RetryUtilsTest.java | 46 +
.../db/relational/grammar/sql/RelationalSql.g4 | 6 +-
.../thrift-commons/src/main/thrift/common.thrift | 7 +-
.../src/main/thrift/confignode.thrift | 1 +
.../src/main/thrift/datanode.thrift | 3 +
pom.xml | 81 +-
scripts/sbin/windows/start-cli.bat | 1 +
src/main/forbidden-apis/secure-erase | 23 +
728 files changed, 43760 insertions(+), 5397 deletions(-)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/LargeResultTableFunction.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBShowQueriesIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBLegacyPipeReceiverSecurityIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeReceiverIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBQueryWithCorruptedTsFileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableAuthHAIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionConsumerDisconnectTableIT.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerMultiProviderPollTest.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/TimeValueBufferBigArray.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractDeltaTableAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractIncreaseTableAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractIrateTableAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractRateTableAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/ExtrapolationUtil.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedDeltaAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedIncreaseAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedIrateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedRateAccumulator.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionIntermediateStateCodec.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeStatus.java
=>
calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionType.java}
(54%)
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionValidation.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/TimeValueBuffer.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/GroupedMaxAccumulatorTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedRateAccumulatorMemoryTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/ExtrapolationUtilTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateAccumulatorFactoryTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionIntermediateStateCodecTest.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionGroupProcedure.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeManagerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/partition/PartitionManagerRegionMaintainTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionCoordinatorTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionGroupProcedureTest.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/TrustedChannelFailureReporter.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppender.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImplTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/client/TrustedChannelFailureReporterTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcherTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRegistryTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/pipe/IoTConsensusV2Test.java
delete mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppenderTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/PasswordChangeAuditContext.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/PasswordChangeAuditTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/UserRoleModificationAuditContext.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/CorruptedTsFileException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskExecutionGuard.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskYieldException.java
rename
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcRpcType.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/TsFileInsertionEventParserMemoryBlock.java}
(62%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/TsFileInsertionEventParserMemoryManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/PipeTsFileConversionTaskManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileParserMemoryManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/resource/SubscriptionMemoryManager.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/audit/DNAuditLoggerRevokeFailureTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/audit/DNAuditLoggerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/audit/DNAuditLoggerUserRoleModificationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/audit/PasswordChangeAuditContextTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/ActiveLoadListeningDirConfigTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionTableDevicePerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskExecutionGuardTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskWorkerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/request/PipeTransferSerializationSizeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSinkTsFileMetadataTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSinkTsFilePerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/IoTDBOpcUaClientTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/server/OpcUaNameSpaceMetadataTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/server/OpcUaTcpNoneCompatibilityTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTsFileHandlerRateLimitTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/DataRegionListeningFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/SinkChannelFailurePropagationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceManagerTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/parser/{RemoveDataNodeMultiNodeParseTest.java
=> RemoveNodeSingleNodeParseTest.java} (66%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/SchemaPredicateUtilTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/AggregationNodeRateSerdeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGeneratorRateTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableSchemaQueryWriteVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/security/AccessControlImplTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/{RemoveDataNodeMultiNodeStatementTest.java
=> RemoveNodeSingleNodeStatementTest.java} (70%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/StreamKeywordTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/AsyncPlanNodeSenderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertBaseStatementTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/utils/ResourceByPathUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/WritingMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedBitmapMemoryAccountingPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALFileListCachePerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileParserPipeMemoryIsolationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/PipeTsFileConversionTaskManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/agent/SubscriptionReceiverAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBrokerPayloadLimitTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/SubscriptionBrokerAgentPayloadLimitTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueDataNodeMemoryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueWalBackpressureTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/resource/SubscriptionMemoryManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/datastructure/AlignedBitmapRangeCheckPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/datastructure/AlignedSparseWritePerformanceTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkResourceException.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/PipeRecentFailureCounter.java
rename
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/RemoveRegionGroupState.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/PipeResourceFailureType.java}
(66%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/PipeStopStrategy.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/consensus/index/ProgressIndexTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/resource/PipeRecentFailureCounterTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/resource/PipeStopStrategyTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/source/IoTDBNonDataRegionSourceTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/schema/filter/impl/DeviceFilterUtilTest.java
rename
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcFactory.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/schema/table/AuditTest.java}
(53%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/subscription/topic/TopicMetaKeeperTest.java
copy
iotdb-core/{confignode/src/test/java/org/apache/iotdb/confignode/manager/ClusterSchemaManagerTest.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/KDTreeUtilTest.java}
(54%)
copy
iotdb-core/{datanode/src/test/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/utils/RetryStatusUtilsTest.java}
(50%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/RetryUtilsTest.java
create mode 100644 src/main/forbidden-apis/secure-erase
