This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch config-bug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from bfc80d66e66 Compile fix
add 35cf94a780a Improve pipe runtime memory allocation (#18051)
add 71696f333af Add pipe receiver memory protection (#18090)
add bbd424f0013 Avoid parsing fully matched historical table TsFiles
(#18123)
add 1c20df4ea7c Persist writer meta out of lock (#18124)
add a6c654bde56 Fix RegionGroupCache activation race (#18128)
add 63b70cb9ea1 Move IoTConsensus multi-data-dir region migration ITs to
commit suite (#18081)
add 86624a137bb Improve pipe receiver session handling (#18084)
add e44cbbb0e97 Fix load configuration IT target DataNode (#18125)
add 82690873b64 Pipe: throttle TsFile parser retries under memory pressure
(#18141)
add b35390559a9 Fix config region pipe privilege trimming (#18142)
add 611b66aded0 Change
partition_table_recover_max_read_megabytes_per_second into
partition_table_recover_max_read_mb_per_sec (#18138)
add 012026f0358 Add DEVICE_METADATA_INFO_SWAP_THRESHOLD parameter to
read_tsfile table function (#18146)
add 797319b453c The new value cannot be less than the current maximum
quota. The quota uses the default value if unspecified in the ALTER DATABASE
statement (#18154)
add 7558aa7ef80 Fix metadata cache and pipe edge cases (#18147)
add e231bbe5e2a Fix pipe double-living sugar after isolation (#18119)
add f3e161218d6 Fix downgraded TsFileResource serialization (#18155)
add 4c1f833adf1 Pipe: order historical TsFiles by query priority (#18088)
add e123ada23ec Respect pre-set env vars and add cgroup memory detection
in env scripts (#17765)
add d02e6af593a A lease-based self-fencing framework to enable high
availability for table metadata operations
add 506f94519fb Extend region migration speed limit to transfers and
deletion (#18118)
add afdcf327e3e Update programming languages and release notes for version
2.0.10 (#18164)
add 449946d5268 Fix pipe event accounting and aligned tablet failure
reporting (#18150)
add 33a38b6194d Pipe: manage ConfigNode receiver temporary memory (#18144)
add c716365a30f Fix subscription consumer lifecycle state ordering (#18151)
add 5aad9323c71 Reduce pipe type conversion log frequency (#18161)
add 343edab9c00 Fix IT log directory test class names (#18131)
add 9112791a88c Fix: remove some procedure that should not be included in
lease frame (#18167)
add ec81de1f9f2 Reduce pipe load success log noise (#18106)
add 7ccdaa503e2 Pipe: use session context in legacy receiver loaders
(#18111)
add 4482e65468a Fix pipe drop stuck on blocking sink reconnect (#18145)
add e8061edf668 Optimize load logic (#18153)
add 350c6c7bcd2 Optimize pipe TsFile cleanup on drop (#18163)
add 86741a8cfeb Fix compaction test metadata lease cleanup (#18172)
add da07a8ef8a1 Subscription: support table-model column-filter for topics
(#17936)
add 9f069d5c7c5 Fix that ProgressWALIterator may read incorrect
searchIndex (#18143)
add 8235112d353 Fix no-tag table attribute deletion (#18176)
add 8735702a775 Reduce repeated failure logs (#18175)
add b05f4cadb76 Avoid readLock when serializing TimeIndex. (#18189)
add ce74949268e Fix tag index misalignment in read_tsfile when projection
pruning removes tag columns (#18191)
add 5ceb047fe83 Fix DataNode restart readiness race in IoTDBConnectionsIT
(#18192)
add 7ffb1364b84 Add mutual SSL support for pipe sinks (#18080)
add eaef430d2b9 Enforce REST query row limit as hard cap (#18149)
add 0d3304a106a Fix RPC buffer memory control activation (#18194)
add ededa9a57ba Pipe IT: disable pipe memory control in overridden setups
(#18198)
add e75d1466251 Fix retry bug in tree model query which ignore the time
filter (#18179)
add 5bb15d980f4 Pipe: optimize InsertRows schema aggregation (#18195)
add f1875ed5d06 Fix external TsFile grouping optimization (#18206)
add d8506920bf8 Improve error message when auto-creating timeseries with
null value (#18209)
add 32bff9b615a Fix procedures stuck after submission-time deserialization
failure (#18212)
add 2c77de3670c Prevent aligned LAST query from hanging with time filter
(#18213)
add 8b60437ee42 Fix write retries, Pipe resource cleanup, subscription
progress, and snapshot recovery (#18180)
add fe1777bfa6d Optimize pipe tablet memory accounting (#18211)
add dfbe8db321d Fix MQTT measurement validation (#18215)
add 0ef17ba7677 Support IPv6 endpoint URLs (#18162)
add 66e4b98ebd8 Optimize TopK query of TableModel by RuntimeFilter (#18204)
add ce9838da272 Fix duplicate TsFile metric updates (#18219)
add 9ae66742b9e Only scan tables of tree model while regenerating data
partition (#18221)
add 8a1c7aa881f Pipe: disable serialize-by-region by default (#18139)
add eb9cc93284b fix: optimize reconnect exception as
`TTransport.TTransportException` (#18200)
add 5b311f6ef9e Fix unbounded async pipe sink retries (#18222)
add 9b77b54defc Fix concurrent access during TierManager folder reset
(#18223)
add 823c47ebd11 [Pipe] Include pending historical events in remaining
count (#18216)
add 2f7505ffba3 Fix flaky WALNodeTest WAL roll assertion (#18226)
add 824e2dbef04 Fix process metric precision (#18229)
add 6889b1e3cf7 modify the read logic of metadata lease timeout (#18228)
add 55271d74a36 Enable CRC32 intrinsic for DataNode (#18239)
add 37cf3cac19c [Performance] Reduce temporary allocations on insert path
(#18240)
add 94b07e08fda [Pipe] Back off async sink for all retry statuses (#18236)
add 1b44799fa97 [Pipe] Reduce AirGap sink reconnect log noise (#18243)
add a8708a4a66a [Performance] Reduce aligned MemTable bitmap memory usage
(#18249)
add 8e5e8502d62 Fix flaky concurrent queue and WAL tests (#18246)
add e5651cbc928 [Performance] Optimize tablet RPC deserialization (#18248)
add ea0b0099227 Load: Fix active load reliability issues (#18224)
add 0f2ee2b4545 [Subscription] Reject unsupported consensus topic
attributes (#18257)
add 5405623efe8 Subscription: Fix DATE serialization for consensus dataset
(#18227)
add 91476b0df7e Compatibility changes for internal settle compaction API
(#18230)
add 1188db9b130 Fix max data region group quota calculation (#18263)
add b8ff9eeaea0 [Pipe] Prevent unexpected OPC UA endpoint redirects
(#18259)
add f2dd70181ce [Performance] Use dynamic bitmaps in AlignedTVList (#18264)
add 4300930cbc2 [Pipe] Back off TsFile parser admission retries (#18262)
add 4cf58248055 Bump com.fasterxml.jackson.core:jackson-core from 2.18.6
to 2.18.9 (#18274)
add 01d1c15aaf7 Fix pipe tablet memory self-lock during batching (#18266)
add dbdabbdbf57 Fix sonar cannot analyse because it requires JDK 21
(#18278)
add 59b019ae204 Fix consensus subscription metrics by region (#18277)
add 4bc2fd5532e Add REST write request size and batch limits (#17481)
add bb0f237271b [Pipe] Resume TsFile parsing after retryable failures
(#18261)
add c13be2c65a5 Bump netty.version from 4.1.134.Final to 4.1.136.Final
(#18279)
add 02b1ecd3775 [Performance] Allocate AlignedTVList primitive arrays
lazily (#18276)
add f7be88e0c48 Added table metric & Improved the database / view metric &
Added "count databases" for table model (#15587)
add e9687382c8a Move state machine to calc commons (#18289)
add 1000f953840 Remove deprecated-for-removal JDK API usages (#18288)
add ed8cb435b94 Fix IPv6 endpoint handling in client and ops tools (#18291)
add d9040c037bd Return one NULL row for last_by over a never-written device
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 f4b0fa42b2a Merge master into config-bug
No new revisions were added by this update.
Summary of changes:
.github/workflows/sonar-codecov.yml | 4 +-
LICENSE-binary | 24 +-
RELEASE_NOTES.md | 38 +
.../org/apache/iotdb/mqtt/MPPPublishHandler.java | 5 +-
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 1 +
.../src/main/openapi3/iotdb_rest_v1.yaml | 1 +
.../src/main/openapi3/iotdb_rest_v2.yaml | 1 +
.../org/apache/iotdb/rest/i18n/RestMessages.java | 46 +
.../org/apache/iotdb/rest/i18n/RestMessages.java | 46 +
.../exception/RequestLimitExceededException.java | 25 +
.../filter/RequestBodyMemoryReleaseFilter.java | 33 +
.../protocol/filter/RequestSizeLimitFilter.java | 183 +++
.../filter/RestRequestBodyMemoryManager.java | 116 ++
.../rest/protocol/handler/QueryRowLimitUtils.java | 71 +
.../rest/protocol/handler/RequestLimitChecker.java | 68 +
.../table/v1/handler/ExceptionHandler.java | 10 +-
.../table/v1/handler/QueryDataSetHandler.java | 44 +-
.../table/v1/handler/RequestValidationHandler.java | 10 +
.../protocol/table/v1/impl/RestApiServiceImpl.java | 25 +-
.../rest/protocol/v1/handler/ExceptionHandler.java | 10 +-
.../protocol/v1/handler/QueryDataSetHandler.java | 114 +-
.../v1/handler/RequestValidationHandler.java | 29 +
.../protocol/v1/impl/GrafanaApiServiceImpl.java | 31 +-
.../rest/protocol/v1/impl/RestApiServiceImpl.java | 20 +-
.../rest/protocol/v2/handler/ExceptionHandler.java | 10 +-
.../rest/protocol/v2/handler/FastLastHandler.java | 65 +-
.../protocol/v2/handler/QueryDataSetHandler.java | 114 +-
.../v2/handler/RequestValidationHandler.java | 47 +
.../protocol/v2/impl/GrafanaApiServiceImpl.java | 31 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 68 +-
.../filter/RequestSizeLimitFilterTest.java | 258 ++++
.../protocol/handler/QueryRowLimitUtilsTest.java | 59 +
.../handler/RequestValidationLimitTest.java | 109 ++
.../v1/handler/QueryDataSetHandlerTest.java | 222 +++
.../protocol/v2/handler/FastLastHandlerTest.java | 119 ++
.../org/apache/iotdb/it/env/MultiEnvFactory.java | 8 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 1 +
.../it/env/cluster/config/MppCommonConfig.java | 6 +
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 +
.../env/cluster/config/MppSharedCommonConfig.java | 6 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 44 +-
.../iotdb/it/env/cluster/env/MultiClusterEnv.java | 9 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 6 +-
.../it/env/remote/config/RemoteCommonConfig.java | 5 +
.../env/remote/config/RemoteConfigNodeConfig.java | 5 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 23 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 +
.../it/database/IoTDBDatabaseRegionControlIT.java | 111 ++
.../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 66 +
...TDBRegionMigrateWithDeletionMultiDataDirIT.java | 14 +-
...gionMigrateWithDeletionMultiDataDirTableIT.java | 14 +-
.../RegionMigrateFileAssertions.java | 2 +-
.../IoTDBRegionMigrateNormalITForIoTV2BatchIT.java | 34 +
.../IoTDBRemoveConfigNodeITFramework.java | 20 +-
.../db/it/IoTDBAlignedTVListLazyAllocationIT.java | 139 ++
.../org/apache/iotdb/db/it/IoTDBIPv6ClusterIT.java | 124 ++
.../iotdb/db/it/IoTDBIPv6ExternalServiceIT.java | 220 +++
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 11 +
.../apache/iotdb/db/it/IoTDBLoadTsFileAuthIT.java | 285 ++++
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 59 +
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 66 +
.../IoTDBAlignedLastQueryWithTimeFilterIT.java | 88 ++
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 2 +-
.../iotdb/db/it/auth/IoTDBTemplateAuthIT.java | 7 +-
.../IoTDBIoTConsensusV23C3DBasicITBase.java | 19 +-
.../iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java | 41 +
.../IoTDBAlignedTVListBitMapPerformanceIT.java | 163 +++
...DBAlignedTVListPrimitiveArrayPerformanceIT.java | 584 ++++++++
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 2 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 4 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 8 +
.../framework/IoTDBTestRunnerWithParameters.java | 15 +-
.../org/apache/iotdb/it/utils/IPv6TestUtils.java | 60 +
.../manual/enhanced/IoTDBPipeClusterIT.java | 2 +-
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 10 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 3 +
.../dual/treemodel/auto/basic/IoTDBPipeIPv6IT.java | 166 +++
.../treemodel/auto/basic/IoTDBPipeMutualSSLIT.java | 176 +++
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 16 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 2 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 6 +-
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 109 +-
.../it/db/it/IoTDBAuthenticationTableIT.java | 9 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 132 ++
.../it/db/it/IoTDBLoadConfigurationTableIT.java | 30 +-
.../recent/IoTDBQueryWithCorruptedTsFileIT.java | 355 +++++
.../recent/IoTDBReadTsFileTableFunctionIT.java | 50 +
.../it/query/recent/IoTDBTableAggregationIT.java | 15 +
.../recent/IoTDBTopKRuntimeFilterScanPathIT.java | 353 +++++
.../it/schema/IoTDBAlterColumnTypeIT.java | 9 +-
.../IoTDBDatabaseAutoDataRegionGroupQuotaIT.java | 91 ++
.../relational/it/schema/IoTDBDatabaseIT.java | 3 +
.../schema/IoTDBDatabaseMaxRegionGroupNumIT.java | 73 +
.../relational/it/schema/IoTDBTableDDLHAIT.java | 342 +++++
.../it/schema/IoTDBTableMetaLeaseIT.java | 83 ++
.../iotdb/session/it/IoTDBConnectionsIT.java | 30 +-
.../apache/iotdb/session/it/IoTDBIPv6ClientIT.java | 142 ++
.../ConsensusSubscriptionTableITSupport.java | 336 ++++-
...ConsensusSubscriptionColumnFilterClusterIT.java | 232 +++
.../IoTDBConsensusSubscriptionDataTableIT.java | 114 ++
.../IoTDBConsensusSubscriptionFilterTableIT.java | 188 ++-
.../IoTDBSubscriptionColumnFilterIT.java | 1513 ++++++++++++++++++++
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 76 +
.../api/customizer/parameter/PipeParameters.java | 1 +
.../customizer/parameter/PipeParametersTest.java | 12 +
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 6 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 6 +
.../src/main/java/org/apache/iotdb/cli/Cli.java | 19 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 3 +-
.../org/apache/iotdb/tool/data/ImportData.java | 3 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 8 +-
.../iotdb/tool/schema/ExportSchemaTable.java | 3 +-
.../iotdb/tool/schema/ImportSchemaTable.java | 3 +-
iotdb-client/client-cpp/src/rpc/NodesSupplier.cpp | 5 +-
iotdb-client/client-cpp/src/rpc/RpcCommon.cpp | 23 +
iotdb-client/client-cpp/src/rpc/RpcCommon.h | 2 +
iotdb-client/client-cpp/src/session/Session.cpp | 4 +-
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 15 +
iotdb-client/client-cpp/test/main.cpp | 5 +-
iotdb-client/client-py/iotdb/Session.py | 92 +-
.../tests/unit/test_session_connection.py | 116 ++
.../client-py/tests/unit/test_session_node_url.py | 85 ++
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 77 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 46 +
.../org/apache/iotdb/rpc/AutoResizingBuffer.java | 24 +-
.../iotdb/rpc/AutoResizingBufferMemoryManager.java | 25 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
.../main/java/org/apache/iotdb/rpc/UrlUtils.java | 93 +-
.../apache/iotdb/rpc/AutoResizingBufferTest.java | 37 +
.../java/org/apache/iotdb/rpc/UrlUtilsTest.java | 83 ++
.../apache/iotdb/session/i18n/SessionMessages.java | 2 +
.../apache/iotdb/session/i18n/SessionMessages.java | 2 +
.../org/apache/iotdb/session/NodesSupplier.java | 5 +-
.../java/org/apache/iotdb/session/Session.java | 5 +-
.../apache/iotdb/session/SessionConnection.java | 11 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 7 +-
.../apache/iotdb/session/util/SessionUtils.java | 8 +-
.../src/test/resources/iotdb-common.properties | 3 +-
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 31 +
.../rpc/subscription/config/TopicConstant.java | 4 +-
.../payload/poll/SubscriptionPollResponse.java | 111 +-
.../base/AbstractSubscriptionConsumer.java | 26 +-
.../base/AbstractSubscriptionProviders.java | 6 +
.../base/AbstractSubscriptionPullConsumer.java | 10 +-
.../base/AbstractSubscriptionPushConsumer.java | 10 +-
.../subscription/payload/SubscriptionMessage.java | 39 +-
.../payload/SubscriptionRecordHandler.java | 161 ++-
.../rpc/subscription/config/TopicConfigTest.java | 59 +
.../payload/poll/SubscriptionPollResponseTest.java | 138 ++
.../base/SubscriptionConsumerLifecycleTest.java | 267 ++++
.../payload/SubscriptionRecordHandlerTest.java | 176 +++
iotdb-core/ainode/build_binary.py | 5 +-
iotdb-core/ainode/iotdb/ainode/core/config.py | 17 +-
.../ainode/iotdb/ainode/core/ingress/iotdb.py | 11 +-
.../ainode/resources/conf/iotdb-ainode.properties | 3 +-
iotdb-core/ainode/tests/test_config.py | 71 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 22 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 22 +
.../iotdb/calc}/execution/FutureStateChange.java | 6 +-
.../apache/iotdb/calc}/execution/StateMachine.java | 55 +-
.../calc/execution/filter/TopKRuntimeFilter.java | 67 +
.../operator/process/TableTopKOperator.java | 40 +-
.../execution/operator/process/TopKOperator.java | 36 +
.../aggregation/grouped/GroupedMaxAccumulator.java | 4 +-
.../calc/plan/planner/TableOperatorGenerator.java | 25 +
.../execution/filter/TopKRuntimeFilterTest.java | 73 +
.../aggregation/GroupedMaxAccumulatorTest.java | 124 ++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 12 +
.../iotdb/confignode/i18n/ManagerMessages.java | 26 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 370 +++--
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 419 +++---
.../iotdb/confignode/i18n/ManagerMessages.java | 26 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 958 ++++++++-----
.../CnToCnInternalServiceAsyncRequestManager.java | 4 +-
.../client/async/CnToDnAsyncRequestType.java | 3 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 13 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 3 +-
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 17 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 15 +
.../confignode/conf/ConfigNodeDescriptor.java | 9 +-
.../confignode/conf/ConfigNodeMemoryConfig.java | 4 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/read/table/FetchTablePlan.java | 10 +-
.../write/table/RollbackPreDeleteTablePlan.java | 19 +-
.../statemachine/ConfigRegionStateMachine.java | 10 +
.../iotdb/confignode/manager/ClusterManager.java | 3 +-
.../iotdb/confignode/manager/ConfigManager.java | 154 +-
.../apache/iotdb/confignode/manager/IManager.java | 4 +-
.../iotdb/confignode/manager/ProcedureManager.java | 159 +-
.../externalservice/ExternalServiceInfo.java | 2 +-
.../manager/lease/ClusterCachePropagator.java | 159 ++
.../manager/lease/DataNodeContactTracker.java | 129 ++
.../manager/lease/MetadataBroadcastVerdict.java | 66 +
.../load/cache/region/RegionGroupCache.java | 8 +-
.../manager/load/service/HeartbeatService.java | 7 +
.../iotdb/confignode/manager/node/NodeManager.java | 83 +-
.../manager/partition/PartitionManager.java | 34 +-
.../manager/partition/PartitionMetrics.java | 94 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 29 +-
.../agent/runtime/PipeConfigRegionListener.java | 19 +
.../runtime/heartbeat/PipeHeartbeatParser.java | 8 +
.../pipe/coordinator/task/PipeTaskCoordinator.java | 30 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 103 +-
.../resource/PipeConfigNodeResourceManager.java | 17 +-
.../memory/PipeConfigNodeMemoryManager.java | 115 ++
.../client/IoTDBConfigNodeSyncClientManager.java | 4 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 4 +
.../pipe/source/IoTDBConfigRegionSource.java | 21 +-
.../manager/schema/ClusterSchemaManager.java | 114 +-
.../persistence/executor/ConfigPlanExecutor.java | 19 +-
.../confignode/persistence/pipe/PipeInfo.java | 5 -
.../confignode/persistence/pipe/PipeTaskInfo.java | 58 +-
.../confignode/persistence/quota/QuotaInfo.java | 1 +
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 112 +-
.../confignode/persistence/schema/ConfigMTree.java | 77 +-
.../persistence/schema/ConfigSchemaStatistics.java | 109 ++
.../persistence/schema/TemplatePreSetTable.java | 2 +
.../persistence/schema/TemplateTable.java | 12 +-
.../persistence/subscription/SubscriptionInfo.java | 153 +-
.../confignode/procedure/ProcedureExecutor.java | 53 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 163 ++-
.../procedure/env/RemoveDataNodeHandler.java | 3 +
.../procedure/impl/StateMachineProcedure.java | 11 +
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../DataPartitionTableIntegrityCheckProcedure.java | 9 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 211 ++-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +
.../impl/pipe/task/AlterPipeProcedureV2.java | 2 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 48 +-
.../impl/schema/AlterLogicalViewProcedure.java | 33 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 32 +-
.../impl/schema/DeactivateTemplateProcedure.java | 2 +-
.../impl/schema/DeleteDatabaseProcedure.java | 2 +
.../impl/schema/DeleteLogicalViewProcedure.java | 32 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 35 +-
.../procedure/impl/schema/SchemaUtils.java | 110 +-
.../impl/schema/SetTemplateProcedure.java | 2 +-
.../table/AbstractAlterOrDropTableProcedure.java | 36 +-
.../impl/schema/table/CreateTableProcedure.java | 36 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 51 +-
.../schema/table/DropTableColumnProcedure.java | 66 +-
.../impl/schema/table/DropTableProcedure.java | 90 +-
.../runtime/CommitProgressSyncProcedure.java | 47 +-
.../subscription/CreateSubscriptionProcedure.java | 28 +
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../confignode/procedure/scheduler/LockQueue.java | 6 +-
.../procedure/state/schema/DropTableState.java | 3 +-
.../iotdb/confignode/service/ConfigNode.java | 2 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 14 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 2 +-
.../consensus/response/pipe/PipeTableRespTest.java | 12 +
.../manager/ConfigManagerCommitProgressTest.java | 241 ++++
.../confignode/manager/ProcedureManagerTest.java | 38 +
.../manager/lease/ClusterCachePropagatorTest.java | 189 +++
.../manager/lease/DataNodeContactTrackerTest.java | 73 +
.../lease/MetadataBroadcastVerdictTest.java | 77 +
...rTest.java => NodeManagerRegistrationTest.java} | 2 +-
.../confignode/manager/node/NodeManagerTest.java | 254 ++--
.../PipeConfigRegionListenerSnapshotTest.java | 59 +
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 36 +
.../pipe/sink/IoTDBConfigRegionSinkTest.java | 46 +
.../PipeConfigTreePrivilegeParseVisitorTest.java | 43 +
.../persistence/ExternalServiceInfoTest.java | 21 +
.../confignode/persistence/QuotaInfoTest.java | 14 +
.../pipe/PipeTaskInfoAutoRestartTest.java | 41 +
.../persistence/schema/ClusterSchemaInfoTest.java | 57 +
.../persistence/schema/ConfigMTreeTest.java | 8 +-
.../schema/TemplatePreSetTableTest.java | 19 +-
.../persistence/schema/TemplateTableTest.java | 10 +-
.../subscription/SubscriptionInfoTest.java | 40 +
.../SubscriptionInfoTopicValidationTest.java | 125 +-
.../procedure/TestProcedureExecutor.java | 155 ++
.../pipe/AbstractOperatePipeProcedureV2Test.java | 31 +
.../impl/pipe/task/DropPipeProcedureV2Test.java | 154 ++
.../runtime/CommitProgressSyncProcedureTest.java | 140 ++
.../CreateSubscriptionProcedureTest.java | 37 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 6 +
.../consensus/i18n/IoTConsensusV2Messages.java | 3 -
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 6 +
.../consensus/i18n/IoTConsensusV2Messages.java | 3 -
.../apache/iotdb/consensus/iot/IoTConsensus.java | 10 +-
.../consensus/iot/IoTConsensusServerImpl.java | 57 +-
.../iot/snapshot/IoTConsensusRateLimiter.java | 22 +-
.../iotdb/consensus/pipe/IoTConsensusV2.java | 93 +-
.../ratis/ApplicationStateMachineProxy.java | 32 +-
.../consensus/ratis/RateLimitedGrpcFactory.java | 32 +-
.../ratis/RateLimitedGrpcLogAppender.java | 76 +
.../consensus/ratis/RateLimitedGrpcRpcType.java} | 23 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +
.../apache/iotdb/consensus/ratis/utils/Utils.java | 9 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 5 +-
.../consensus/iot/IoTConsensusServerImplTest.java | 162 +++
.../apache/iotdb/consensus/iot/ReplicateTest.java | 189 +++
.../iotdb/consensus/pipe/IoTConsensusV2Test.java | 55 +
.../ratis/RateLimitedGrpcLogAppenderTest.java | 66 +
.../iotdb/consensus/ratis/utils/UtilsTest.java | 54 +
.../assembly/resources/conf/logback-datanode.xml | 18 -
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 66 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 123 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 43 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 95 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 64 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 115 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 43 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 73 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 16 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 132 +-
.../iotdb/db/audit/PasswordChangeAuditContext.java | 187 +++
.../iotdb/db/audit/PasswordChangeAuditTask.java | 87 ++
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 16 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 214 ++-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 35 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 53 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 60 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 83 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 25 +-
.../dataregion/DataExecutionVisitor.java | 11 +
.../dataregion/DataRegionStateMachine.java | 14 +-
.../db/exception/CorruptedTsFileException.java | 70 +
.../exception/metadata/PathNotExistException.java | 13 +
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 10 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 477 ++----
.../task/builder/PipeDataNodeTaskBuilder.java | 36 +
.../agent/task/connection/PipeEventCollector.java | 30 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 5 +-
.../subtask/processor/PipeProcessorSubtask.java | 43 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 203 ++-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 61 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 13 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 310 +++-
.../tsfile/parser/TsFileInsertionEventParser.java | 12 +-
.../query/TsFileInsertionEventQueryParser.java | 1 +
.../scan/TsFileInsertionEventScanParser.java | 54 +-
.../table/TsFileInsertionEventTableParser.java | 22 +-
...ileInsertionEventTableParserTabletIterator.java | 48 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 12 +
.../overview/PipeDataNodeSinglePipeMetrics.java | 12 +-
.../processor/aggregate/AggregateProcessor.java | 38 +-
.../downsampling/DownSamplingProcessor.java | 39 +-
.../sdt/SwingingDoorTrendingFilter.java | 8 +-
.../receiver/TwoStageAggregateReceiver.java | 10 +
.../exchange/sender/TwoStageAggregateSender.java | 75 +-
.../twostage/plugin/TwoStageCountProcessor.java | 9 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 82 +-
.../protocol/legacy/loader/DeletionLoader.java | 25 +-
.../receiver/protocol/legacy/loader/ILoader.java | 3 +-
.../protocol/legacy/loader/TsFileLoader.java | 16 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 235 ++-
.../statement/PipeConvertedInsertRowStatement.java | 30 +-
.../PipeConvertedInsertTabletStatement.java | 14 +-
...leStatementDataTypeConvertExecutionVisitor.java | 16 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 9 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 85 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 127 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 450 +++++-
.../pipe/resource/tsfile/PipeTsFileResource.java | 8 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 39 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 19 +-
.../client/IoTDBDataNodeSyncClientManager.java | 10 +-
.../evolvable/batch/PipeTabletEventBatch.java | 83 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 65 +-
.../batch/PipeTabletEventTsFileBatch.java | 109 +-
.../request/PipeTransferTabletBatchReq.java | 27 +-
.../request/PipeTransferTabletBatchReqV2.java | 56 +-
.../request/PipeTransferTabletBinaryReq.java | 14 +-
.../request/PipeTransferTabletBinaryReqV2.java | 28 +-
.../request/PipeTransferTabletInsertNodeReq.java | 20 +-
.../request/PipeTransferTabletInsertNodeReqV2.java | 16 +-
.../request/PipeTransferTabletRawReq.java | 13 +-
.../request/PipeTransferTabletRawReqV2.java | 30 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 51 +-
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 16 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 52 +-
.../handler/IoTConsensusV2DeleteEventHandler.java | 2 +-
.../IoTConsensusV2TabletBatchEventHandler.java | 2 +-
.../IoTConsensusV2TabletInsertionEventHandler.java | 2 +-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 36 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 121 +-
.../request/IoTConsensusV2TabletInsertNodeReq.java | 6 +
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 140 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 32 +-
.../sink/protocol/opcua/client/ClientRunner.java | 89 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 14 +-
.../protocol/opcua/server/OpcUaKeyStoreLoader.java | 21 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 4 +-
.../protocol/opcua/server/OpcUaServerBuilder.java | 143 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 292 +++-
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../handler/PipeTransferTrackableHandler.java | 36 +-
.../async/handler/PipeTransferTsFileHandler.java | 95 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 4 +
.../thrift/sync/IoTDBDataRegionSyncSink.java | 167 ++-
.../sink/protocol/websocket/WebSocketSink.java | 21 +-
.../sink/protocol/writeback/WriteBackSink.java | 2 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 19 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 16 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 8 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 18 +-
.../source/dataregion/IoTDBDataRegionSource.java | 12 +
...istoricalDataRegionTsFileAndDeletionSource.java | 441 +++++-
.../realtime/PipeRealtimeDataRegionSource.java | 17 +-
.../realtime/epoch/TsFileEpochManager.java | 70 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 4 +-
.../PipePlanTablePrivilegeParseVisitor.java | 17 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 12 +-
.../DnToCnInternalServiceAsyncRequestManager.java | 4 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 53 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 17 +-
.../thrift/impl/DataNodeRegionManager.java | 8 +-
.../db/queryengine/common/MPPQueryContext.java | 14 +-
.../queryengine/execution/QueryStateMachine.java | 1 +
.../execution/fragment/DataNodeQueryContext.java | 21 +
.../fragment/FragmentInstanceStateMachine.java | 4 +-
.../execution/operator/source/FileLoaderUtils.java | 65 +-
.../execution/operator/source/SeriesScanUtil.java | 176 ++-
.../relational/AbstractTableScanOperator.java | 23 +-
.../ExternalTsFileTableScanOperator.java | 13 +-
.../execution/schedule/AbstractDriverThread.java | 28 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 106 +-
.../db/queryengine/plan/analyze/Analyzer.java | 16 +-
.../plan/analyze/ConcatPathRewriter.java | 23 +-
.../queryengine/plan/analyze/PredicateUtils.java | 177 ++-
.../plan/analyze/TemplatedAggregationAnalyze.java | 71 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 20 +-
.../plan/analyze/TreeAnalysisMutationJournal.java | 255 ++++
.../analyze/cache/partition/PartitionCache.java | 14 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 70 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 108 +-
.../queryengine/plan/execution/QueryExecution.java | 47 +-
.../execution/config/TableConfigTaskVisitor.java | 81 +-
.../execution/config/TreeConfigTaskVisitor.java | 44 +-
.../config/executor/ClusterConfigTaskExecutor.java | 32 +-
.../config/executor/IConfigTaskExecutor.java | 4 +-
.../config/metadata/CountDatabaseTask.java | 4 +-
.../execution/config/sys/TestConnectionTask.java | 3 +-
.../visitor/predicate/PredicateSimplifier.java | 83 +-
.../plan/parser/StatementGenerator.java | 38 +-
.../planner/DataNodeTableOperatorGenerator.java | 171 ++-
.../db/queryengine/plan/planner/IPlanner.java | 6 +
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 20 +-
.../plan/planner/plan/PlanFragment.java | 4 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 7 +
.../plan/planner/plan/node/PlanVisitor.java | 2 +-
.../plan/node/load/LoadSingleTsFileNode.java | 28 +-
.../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 | 96 +-
.../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 | 12 +-
.../node/write/RelationalInsertTabletNode.java | 11 +
.../planner/plan/parameter/SeriesScanOptions.java | 19 +-
.../relational/analyzer/StatementAnalyzer.java | 21 +-
.../read_tsfile/ExternalTsFileQueryResource.java | 109 +-
.../tvf/read_tsfile/ReadTsFileTableFunction.java | 60 +-
.../relational/metadata/TableMetadataImpl.java | 3 +-
.../metadata/fetcher/SchemaPredicateUtil.java | 3 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 2 +-
.../fetcher/cache/LastCacheUpdateSource.java | 23 +-
.../fetcher/cache/TableDeviceCacheEntry.java | 35 +-
.../fetcher/cache/TableDeviceLastCache.java | 124 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 42 +-
.../cache/TreeDeviceSchemaCacheManager.java | 26 +-
.../plan/relational/planner/RelationPlanner.java | 5 +-
.../distribute/TableDistributedPlanGenerator.java | 11 +-
.../distribute/TableDistributedPlanner.java | 5 +-
.../planner/node/DeviceTableScanNode.java | 49 +-
.../node/schema/TableSchemaQueryWriteVisitor.java | 31 +-
.../optimizations/LogicalOptimizeFactory.java | 1 +
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../optimizations/TopKRuntimeFilterOptimizer.java | 83 ++
.../plan/relational/security/AccessControl.java | 13 +
.../relational/security/AccessControlImpl.java | 27 +-
.../relational/security/AllowAllAccessControl.java | 7 +
.../relational/security/ITableAuthChecker.java | 13 +
.../relational/security/ITableAuthCheckerImpl.java | 41 +-
.../security/TreeAccessCheckVisitor.java | 178 ++-
.../sql/ast/AbstractQueryDeviceWithCache.java | 24 +
.../plan/relational/sql/ast/CountDevice.java | 9 +
.../plan/relational/sql/ast/InsertRows.java | 115 +-
.../plan/relational/sql/ast/ShowDevice.java | 11 +
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 75 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 42 +-
.../plan/statement/component/GroupByComponent.java | 5 +
.../plan/statement/component/OrderByComponent.java | 30 +
.../plan/statement/component/WhereCondition.java | 7 +
.../plan/statement/crud/InsertBaseStatement.java | 57 +-
.../crud/InsertMultiTabletsStatement.java | 11 +
.../plan/statement/crud/InsertRowStatement.java | 10 +-
.../plan/statement/crud/InsertRowsStatement.java | 29 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 9 +-
.../schemaengine/lease/MetadataLeaseManager.java | 318 ++++
.../schemaengine/metric/ISchemaEngineMetric.java | 7 +-
.../schemaengine/metric/ISchemaRegionMetric.java | 7 +-
.../metric/SchemaEngineCachedMetric.java | 10 +
.../schemaengine/metric/SchemaEngineMemMetric.java | 34 +-
.../schemaengine/metric/SchemaMetricManager.java | 4 +
.../metric/SchemaRegionCachedMetric.java | 10 +
.../schemaengine/metric/SchemaRegionMemMetric.java | 56 +
.../rescon/ISchemaEngineStatistics.java | 2 +
.../rescon/MemSchemaEngineStatistics.java | 43 +
.../rescon/MemSchemaRegionStatistics.java | 25 +-
.../schemaregion/SchemaRegionLoader.java | 8 +-
.../schemaregion/SchemaRegionUtils.java | 14 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 4 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 4 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 15 +-
.../db/schemaengine/table/DataNodeTableCache.java | 394 +++--
.../iotdb/db/schemaengine/table/ITableCache.java | 31 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 23 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 3 +
.../iotdb/db/service/metrics/FileMetrics.java | 8 +-
.../db/service/metrics/MetadataLeaseMetrics.java | 50 +
.../iotdb/db/service/metrics/ProcessMetrics.java | 8 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 23 +-
.../db/service/metrics/file/TsFileMetrics.java | 19 +-
.../metrics/memory/QueryEngineMemoryMetrics.java | 26 +-
.../iotdb/db/storageengine/StorageEngine.java | 15 +-
.../db/storageengine/dataregion/DataRegion.java | 326 +++--
.../dataregion/HashLastFlushTimeMap.java | 1 +
.../execute/task/CrossSpaceCompactionTask.java | 4 +-
.../execute/task/InnerSpaceCompactionTask.java | 5 +-
.../task/InsertionCrossSpaceCompactionTask.java | 12 +-
.../execute/task/SettleCompactionTask.java | 3 +-
.../compaction/execute/utils/CompactionUtils.java | 17 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 11 +-
.../selector/impl/SettleSelectorImpl.java | 43 +-
.../dataregion/memtable/AbstractMemTable.java | 74 +-
.../memtable/AlignedWritableMemChunk.java | 4 +
.../dataregion/memtable/IMemTable.java | 9 +
.../dataregion/memtable/TsFileProcessor.java | 615 +++++---
.../dataregion/read/QueryDataSource.java | 114 ++
.../read/reader/chunk/DiskAlignedChunkLoader.java | 5 +
.../read/reader/chunk/DiskChunkLoader.java | 5 +
.../metadata/DiskAlignedChunkMetadataLoader.java | 4 +-
.../dataregion/tsfile/TsFileResource.java | 59 +-
.../dataregion/wal/allocation/ElasticStrategy.java | 5 +-
.../wal/allocation/FirstCreateStrategy.java | 5 +-
.../load/active/ActiveLoadDirScanner.java | 11 +-
.../load/active/ActiveLoadPathHelper.java | 50 +-
.../load/active/ActiveLoadPendingQueue.java | 20 +-
.../load/active/ActiveLoadTsFileLoader.java | 49 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 148 +-
.../db/storageengine/rescon/disk/TierManager.java | 39 +-
.../agent/SubscriptionBrokerAgent.java | 155 +-
.../agent/SubscriptionConsumerAgent.java | 55 +-
.../subscription/agent/SubscriptionTopicAgent.java | 56 +-
.../broker/ConsensusSubscriptionBroker.java | 26 +-
.../broker/SubscriptionPrefetchingQueue.java | 15 +-
.../consensus/ConsensusLogToTabletConverter.java | 296 ++--
.../consensus/ConsensusPrefetchingQueue.java | 1051 +++++++++++---
.../ConsensusSubscriptionCommitManager.java | 524 ++++++-
.../ConsensusSubscriptionSetupHandler.java | 168 ++-
.../broker/consensus/ProgressWALIterator.java | 5 +-
.../columnfilter/BoundColumnFilter.java | 146 ++
.../columnfilter/ColumnFilterBinder.java | 169 +++
.../columnfilter/ColumnFilterEvaluator.java | 183 +++
.../columnfilter/ColumnFilterMatcher.java | 202 +++
.../columnfilter/ColumnFilterParser.java | 296 ++++
.../columnfilter/ColumnFilterValidator.java | 174 +++
.../columnfilter/TabletColumnPruner.java | 189 +++
.../columnfilter/TreeViewTabletProjector.java | 168 +++
.../db/subscription/event/SubscriptionEvent.java | 29 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 179 ++-
.../batch/SubscriptionPipeTsFileEventBatch.java | 57 +-
.../cache/CachedSubscriptionPollResponse.java | 24 +-
.../response/SubscriptionEventSingleResponse.java | 20 +
.../response/SubscriptionEventTabletResponse.java | 54 +-
.../response/SubscriptionEventTsFileResponse.java | 22 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 214 ++-
.../receiver/SubscriptionReceiverV1.java | 2 +-
.../SubscriptionDataNodeResourceManager.java | 6 +
.../resource/SubscriptionMemoryManager.java | 89 ++
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +-
.../org/apache/iotdb/db/utils/TabletDecoder.java | 36 +-
.../db/utils/datastructure/AlignedTVList.java | 385 +++--
.../iotdb/db/utils/datastructure/LazyBitMap.java | 2 +-
.../iotdb/db/utils/datastructure/TVList.java | 13 +-
.../apache/iotdb/db/audit/DNAuditLoggerTest.java | 181 +++
.../db/audit/PasswordChangeAuditContextTest.java | 327 +++++
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 25 +-
.../db/auth/ClusterAuthorityFetcherLeaseTest.java | 103 ++
.../org/apache/iotdb/db/auth/TreeAccessTest.java | 55 +
.../iotdb/db/conf/DataNodeMemoryConfigTest.java | 136 ++
.../org/apache/iotdb/db/conf/PropertiesTest.java | 149 ++
.../dataregion/DataRegionStateMachineTest.java | 143 ++
.../cache/TreeDeviceSchemaCacheManagerTest.java | 25 +-
.../schemaRegion/SchemaRegionManagementTest.java | 38 +
.../agent/plugin/PipeDataNodePluginAgentTest.java | 6 +-
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 88 --
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 8 +-
.../task/subtask/sink/PipeSinkSubtaskTest.java | 391 +++++
.../pipe/event/PipeTabletInsertionEventTest.java | 59 +
.../pipe/event/PipeTsFileInsertionEventTest.java | 9 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 229 +++
.../PipeTsFileInsertionEventAdmissionTest.java | 137 ++
...eDataNodeRemainingEventAndTimeOperatorTest.java | 46 +
.../sdt/SwingingDoorTrendingFilterTest.java | 17 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 85 +-
.../InsertNodeMemoryEstimatorPerformanceTest.java | 279 ++++
.../memory/InsertNodeMemoryEstimatorTest.java | 130 ++
.../memory/PipeMemoryManagerResizeTest.java | 116 ++
.../resource/memory/PipeMemoryManagerTest.java | 384 +++++
.../sink/IoTDBDataNodeAsyncClientManagerTest.java | 120 ++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 45 +
.../iotdb/db/pipe/sink/PipeReceiverTest.java | 70 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 193 +++
.../batch/PipeTabletEventTsFileBatchTest.java | 64 +
.../request/PipeTransferSerializationSizeTest.java | 530 +++++++
...ipeTransferTabletBatchReqV2PerformanceTest.java | 133 ++
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 17 +-
.../protocol/opcua/client/ClientRunnerTest.java | 147 ++
.../opcua/server/OpcUaServerBuilderTest.java | 164 +++
.../handler/PipeTransferTrackableHandlerTest.java | 79 +-
.../PipeTransferTsFileHandlerCleanupTest.java | 86 ++
.../PipeTransferTsFileHandlerRateLimitTest.java | 83 ++
.../sink/util/builder/PipeTsFileBuilderV2Test.java | 264 ++++
.../PipePlanTablePatternParseVisitorTest.java | 49 +
.../db/pipe/source/PipeRealtimeExtractTest.java | 73 +
...ricalDataRegionTsFileAndDeletionSourceTest.java | 491 ++++++-
.../realtime/PipeRealtimeDataRegionSourceTest.java | 113 ++
.../epoch/TsFileEpochManagerPerformanceTest.java | 212 +++
.../realtime/epoch/TsFileEpochManagerTest.java | 105 ++
...alTsFileTableScanOperatorRuntimeFilterTest.java | 127 ++
.../db/queryengine/plan/analyze/AnalyzeTest.java | 238 +++
.../plan/analyze/PredicateUtilsTest.java | 172 +++
.../plan/analyze/TemplatedAnalyzeRetryTest.java | 127 ++
.../analyze/cache/PartitionCacheLeaseTest.java | 129 ++
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 75 +
.../plan/execution/QueryExecutionRetryTest.java | 218 +++
.../plan/planner/LogicalPlanBuilderTest.java | 113 ++
.../plan/planner/node/load/LoadTsFileNodeTest.java | 46 +
.../node/write/InsertRowsNodeSerdeTest.java | 26 +
.../plan/relational/analyzer/AnalyzerTest.java | 117 ++
.../plan/relational/analyzer/AuthTest.java | 51 +
.../ExternalTsFileQueryResourceTest.java | 7 +-
.../cache/TableDeviceLastCachePerformanceTest.java | 265 ++++
.../fetcher/cache/TableDeviceLastCacheTest.java | 34 +
.../TreeDeviceSchemaCacheManagerLeaseTest.java | 119 ++
.../planner/assertions/PlanMatchPattern.java | 25 +
.../schema/TableSchemaQueryWriteVisitorTest.java | 89 ++
.../optimizations/ParallelizeGroupingTest.java | 111 ++
.../TopKRuntimeFilterDistributedPlanTest.java | 200 +++
.../TopKRuntimeFilterTreeViewPlanTest.java | 119 ++
.../scheduler/load/LoadTsFileSchedulerTest.java | 42 +
.../plan/statement/QueryStatementTest.java | 26 +
.../statement/crud/InsertBaseStatementTest.java | 88 ++
.../lease/MetadataLeaseManagerTest.java | 114 ++
.../schemaengine/lease/MetadataLeaseTestUtils.java | 86 ++
.../table/DataNodeTableCacheLeaseTest.java | 108 ++
.../schemaengine/table/DataNodeTableCacheTest.java | 28 +-
.../storageengine/dataregion/DataRegionTest.java | 190 +++
.../dataregion/LastFlushTimeMapTest.java | 33 +
.../TsFileResourceProgressIndexTest.java | 42 +
.../compaction/AbstractCompactionTest.java | 5 +
.../cross/InsertionCrossSpaceCompactionTest.java | 16 +-
.../utils/CompactionUpdateFileCountTest.java | 66 +-
.../compaction/utils/CompactionUtilsTest.java | 2 +-
.../AbstractMemTablePartialInsertTest.java | 87 +-
...ignedBitmapMemoryAccountingPerformanceTest.java | 295 ++++
.../dataregion/memtable/TsFileProcessorTest.java | 297 +++-
.../read/QueryDataSourceRuntimeFilterTest.java | 76 +
.../dataregion/tsfile/TsFileResourceTest.java | 19 +-
.../dataregion/wal/node/WALNodeTest.java | 4 +
.../wal/node/WALNodeWaitForRollFileTest.java | 141 +-
.../load/active/ActiveLoadDirScannerTest.java | 157 ++
.../load/active/ActiveLoadPathHelperTest.java | 146 ++
.../load/active/ActiveLoadTsFileLoaderTest.java | 20 +
.../db/storageengine/load/util/LoadUtilTest.java | 141 ++
.../storageengine/rescon/disk/TierManagerTest.java | 156 ++
.../agent/SubscriptionConsumerAgentTest.java | 65 +
.../agent/SubscriptionTopicAgentTest.java | 85 ++
.../ConsensusLogToTabletConverterTest.java | 106 +-
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 346 +++++
.../consensus/ConsensusPrefetchingQueueTest.java | 1513 ++++++++++++++++++++
...nsensusPrefetchingQueueWalBackpressureTest.java | 336 +++++
.../ConsensusSubscriptionCommitStateTest.java | 375 ++++-
.../ConsensusSubscriptionSetupHandlerTest.java | 141 ++
.../columnfilter/ColumnFilterBinderTest.java | 331 +++++
.../columnfilter/ColumnFilterParserTest.java | 130 ++
.../columnfilter/TabletColumnPrunerTest.java | 148 ++
...ubscriptionPipeTsFileEventBatchCleanupTest.java | 78 +
.../SubscriptionPipeTsFileEventBatchTest.java | 102 ++
...susSubscriptionPrefetchingQueueMetricsTest.java | 164 +++
.../resource/SubscriptionMemoryManagerTest.java | 64 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 3 +-
.../iotdb/db/utils/ManualPerformanceTestUtils.java | 186 +++
.../apache/iotdb/db/utils/TabletDecoderTest.java | 81 ++
.../TabletRpcDeserializationPerformanceTest.java | 617 ++++++++
.../db/utils/datastructure/AlignedTVListTest.java | 249 ++++
.../src/test/resources/datanode1conf/logback.xml | 18 -
.../src/test/resources/datanode2conf/logback.xml | 18 -
.../src/test/resources/datanode3conf/logback.xml | 18 -
.../src/test/resources/iotdb-common.properties | 18 +-
.../src/test/resources/iotdb-system.properties | 18 +-
.../conf/iotdb-system.properties.template | 102 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 4 +
.../apache/iotdb/commons/i18n/ConfigMessages.java | 4 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 32 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 4 +
.../apache/iotdb/commons/i18n/ConfigMessages.java | 4 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 30 +-
.../client/request/AsyncRequestManager.java | 12 +-
.../iotdb/commons/concurrent/IoTThreadFactory.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 119 +-
.../iotdb/commons/conf/CommonDescriptor.java | 4 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../commons/consensus/index/ProgressIndexType.java | 8 +-
.../index/impl/TimePartitionProgressIndex.java | 292 ++++
.../apache/iotdb/commons/disk/FolderManager.java | 5 +-
.../exception/MetadataLeaseFencedException.java | 46 +
.../pipe/PipeRuntimeCriticalException.java | 4 +
.../exception/pipe/PipeRuntimeException.java | 4 +
.../pipe/PipeRuntimeSinkCriticalException.java | 4 +
.../LoggerPeriodicalLogReducer.java} | 65 +-
.../apache/iotdb/commons/memory/MemoryConfig.java | 27 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 27 +-
.../connection/UnboundedBlockingPendingQueue.java | 4 +-
.../commons/pipe/agent/task/meta/PipeStatus.java | 3 +
.../task/subtask/PipeAbstractSinkSubtask.java | 120 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 2 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 28 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 40 +-
.../pipe/config/constant/PipeSinkConstant.java | 21 +-
.../pipe/config/constant/PipeSourceConstant.java | 46 +
.../env/PipeTaskProcessorRuntimeEnvironment.java | 23 +
.../queue/ConcurrentIterableLinkedQueue.java | 5 +-
.../AbstractSerializableListeningQueue.java | 2 +-
.../datastructure/visibility/VisibilityUtils.java | 43 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 129 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 4 +-
.../commons/pipe/resource/log/PipeLogger.java | 24 +-
.../commons/pipe/sink/client/IoTDBSyncClient.java | 17 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 10 +-
.../thrift/common/PipeTransferSliceReqHandler.java | 37 +
.../thrift/request/PipeTransferCompressedReq.java | 21 +
.../pipe/sink/protocol/IoTDBAirGapSink.java | 14 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 127 +-
.../iotdb/commons/pipe/source/IoTDBSource.java | 18 +-
.../plan/planner/plan/node/PlanNode.java | 8 +
.../plan/relational/planner/node/TopKNode.java | 55 +-
.../schema/table/NonCommittableTsTable.java | 5 +-
...mmittableTsTable.java => PreDeleteTsTable.java} | 15 +-
.../commons/schema/table/TableNodeStatus.java | 10 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 27 +-
.../iotdb/commons/service/metric/enums/Metric.java | 5 +
.../subscription/columnfilter/ColumnMetadata.java | 64 +
.../meta/consumer/CommitProgressKeeper.java | 188 ++-
.../commons/subscription/meta/topic/TopicMeta.java | 2 +
.../apache/iotdb/commons/udf/utils/KDTreeUtil.java | 10 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 46 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 9 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 67 +-
.../RegionMigrationFileRemoveRateLimiter.java} | 40 +-
.../commons/utils/RegionMigrationRateLimiter.java} | 28 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 2 +
.../apache/iotdb/commons/utils/StatusUtils.java | 1 +
...monDescriptorDiskSpaceWarningThresholdTest.java | 2 +-
.../LoggerPeriodicalLogReducerTest.java} | 21 +-
.../UnboundedBlockingPendingQueueTest.java | 73 +
.../ConcurrentIterableLinkedQueueTest.java | 259 ++--
.../listening/AbstractPipeListeningQueueTest.java | 91 ++
.../visibility/VisibilityUtilsTest.java | 57 +-
.../pipe/receiver/IoTDBFileReceiverTest.java | 184 ++-
.../commons/pipe/resource/PipeLoggerTest.java | 47 +-
.../common/PipeTransferSliceReqBuilderTest.java | 52 +
.../request/PipeTransferCompressedReqTest.java | 37 +
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 24 +
.../meta/consumer/CommitProgressKeeperTest.java | 248 ++++
.../commons/subscription/topic/TopicDeSerTest.java | 28 +
.../iotdb/commons/udf/utils/KDTreeUtilTest.java | 31 +-
.../apache/iotdb/commons/utils/FileUtilsTest.java | 64 +
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 7 +
.../apache/iotdb/commons/utils/PathUtilsTest.java | 78 +
.../iotdb/commons/utils/RetryStatusUtilsTest.java | 34 +-
.../apache/iotdb/commons/utils/RetryUtilsTest.java | 46 +
.../grammar/sql/SubscriptionColumnFilter.g4 | 88 ++
iotdb-doap.rdf | 14 +-
.../src/main/thrift/confignode.thrift | 13 +-
.../src/main/thrift/datanode.thrift | 1 +
pom.xml | 8 +-
scripts/conf/confignode-env.sh | 91 +-
scripts/conf/datanode-env.sh | 89 +-
scripts/conf/iotdb-common.sh | 117 +-
scripts/conf/windows/confignode-env.bat | 5 +-
scripts/conf/windows/datanode-env.bat | 5 +-
scripts/tools/ops/health_check.sh | 8 +-
scripts/tools/windows/ops/backup.bat | 16 +-
scripts/tools/windows/ops/health_check.bat | 41 +-
805 files changed, 50976 insertions(+), 6695 deletions(-)
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/exception/RequestLimitExceededException.java
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/filter/RequestBodyMemoryReleaseFilter.java
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/filter/RequestSizeLimitFilter.java
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/filter/RestRequestBodyMemoryManager.java
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/handler/QueryRowLimitUtils.java
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/handler/RequestLimitChecker.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/filter/RequestSizeLimitFilterTest.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/handler/QueryRowLimitUtilsTest.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/handler/RequestValidationLimitTest.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/v1/handler/QueryDataSetHandlerTest.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/v2/handler/FastLastHandlerTest.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{daily/iotv1
=> commit}/IoTDBRegionMigrateWithDeletionMultiDataDirIT.java (93%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{daily/iotv1
=> commit}/IoTDBRegionMigrateWithDeletionMultiDataDirTableIT.java (93%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/{daily/iotv1
=> commit}/RegionMigrateFileAssertions.java (98%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBAlignedTVListLazyAllocationIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBIPv6ClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBIPv6ExternalServiceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileAuthIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedLastQueryWithTimeFilterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/performance/IoTDBAlignedTVListBitMapPerformanceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/performance/IoTDBAlignedTVListPrimitiveArrayPerformanceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/it/utils/IPv6TestUtils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeIPv6IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeMutualSSLIT.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/query/recent/IoTDBTopKRuntimeFilterScanPathIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseAutoDataRegionGroupQuotaIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableDDLHAIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableMetaLeaseIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBIPv6ClientIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionColumnFilterClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/tablemodel/IoTDBSubscriptionColumnFilterIT.java
create mode 100644 iotdb-client/client-py/tests/unit/test_session_connection.py
create mode 100644 iotdb-client/client-py/tests/unit/test_session_node_url.py
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/config/TopicConfigTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponseTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerLifecycleTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/payload/SubscriptionRecordHandlerTest.java
create mode 100644 iotdb-core/ainode/tests/test_config.py
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine =>
calc-commons/src/main/java/org/apache/iotdb/calc}/execution/FutureStateChange.java
(92%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine =>
calc-commons/src/main/java/org/apache/iotdb/calc}/execution/StateMachine.java
(85%)
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/filter/TopKRuntimeFilter.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/filter/TopKRuntimeFilterTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/GroupedMaxAccumulatorTest.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/ConfigNodeConfig.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/RollbackPreDeleteTablePlan.java
(62%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/lease/ClusterCachePropagator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/lease/DataNodeContactTracker.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/lease/MetadataBroadcastVerdict.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/memory/PipeConfigNodeMemoryManager.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ConfigSchemaStatistics.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerCommitProgressTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/lease/ClusterCachePropagatorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/lease/DataNodeContactTrackerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/lease/MetadataBroadcastVerdictTest.java
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/node/{NodeManagerTest.java
=> NodeManagerRegistrationTest.java} (99%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigRegionListenerSnapshotTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/subscription/consumer/runtime/CommitProgressSyncProcedureTest.java
copy
integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteConfigNodeConfig.java
=>
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcFactory.java
(56%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppender.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DropTableState.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcRpcType.java}
(65%)
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/pipe/IoTConsensusV2Test.java
create 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/exception/CorruptedTsFileException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TreeAnalysisMutationJournal.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/ConfigNodeConfig.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/LastCacheUpdateSource.java
(57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TopKRuntimeFilterOptimizer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/lease/MetadataLeaseManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/MetadataLeaseMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/BoundColumnFilter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterBinder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterEvaluator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterMatcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParser.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterValidator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/TabletColumnPruner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/TreeViewTabletProjector.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/DNAuditLoggerTest.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/auth/ClusterAuthorityFetcherLeaseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/DataNodeMemoryConfigTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEventAdmissionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeRemainingEventAndTimeOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimatorPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryManagerResizeTest.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/batch/PipeTabletEventTsFileBatchTest.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/payload/evolvable/request/PipeTransferTabletBatchReqV2PerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/ClientRunnerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/server/OpcUaServerBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTsFileHandlerCleanupTest.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/sink/util/builder/PipeTsFileBuilderV2Test.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionSourceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/ExternalTsFileTableScanOperatorRuntimeFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/PredicateUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyzeRetryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/PartitionCacheLeaseTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecutionRetryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LogicalPlanBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TableDeviceLastCachePerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TreeDeviceSchemaCacheManagerLeaseTest.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/planner/optimizations/ParallelizeGroupingTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TopKRuntimeFilterDistributedPlanTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TopKRuntimeFilterTreeViewPlanTest.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/lease/MetadataLeaseManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/lease/MetadataLeaseTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCacheLeaseTest.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/read/QueryDataSourceRuntimeFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadDirScannerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadPathHelperTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/util/LoadUtilTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/disk/TierManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/agent/SubscriptionTopicAgentTest.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/ConsensusPrefetchingQueueTest.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/broker/consensus/ConsensusSubscriptionSetupHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterBinderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParserTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/columnfilter/TabletColumnPrunerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatchCleanupTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/metric/ConsensusSubscriptionPrefetchingQueueMetricsTest.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/ManualPerformanceTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TabletDecoderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TabletRpcDeserializationPerformanceTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/index/impl/TimePartitionProgressIndex.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/MetadataLeaseFencedException.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/resource/log/PipePeriodicalLogReducer.java
=> log/LoggerPeriodicalLogReducer.java} (55%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/{NonCommittableTsTable.java
=> PreDeleteTsTable.java} (71%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/subscription/columnfilter/ColumnMetadata.java
copy
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/iot/snapshot/IoTConsensusRateLimiter.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/RegionMigrationFileRemoveRateLimiter.java}
(53%)
copy
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/iot/snapshot/IoTConsensusRateLimiter.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/RegionMigrationRateLimiter.java}
(62%)
rename
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/{pipe/resource/log/PipePeriodicalLogReducerTest.java
=> log/LoggerPeriodicalLogReducerTest.java} (67%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/agent/task/connection/UnboundedBlockingPendingQueueTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/queue/listening/AbstractPipeListeningQueueTest.java
copy
iotdb-api/pipe-api/src/test/java/org/apache/iotdb/pipe/api/customizer/parameter/PipeParametersTest.java
=>
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/KDTreeUtilTest.java
(55%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/PathUtilsTest.java
copy
iotdb-api/pipe-api/src/test/java/org/apache/iotdb/pipe/api/customizer/parameter/PipeParametersTest.java
=>
iotdb-core/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
iotdb-core/relational-grammar/src/main/antlr4/org/apache/iotdb/db/relational/grammar/sql/SubscriptionColumnFilter.g4
