This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch air-gap-udp-transport
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ef9787b8ece Merge branch 'master' of https://github.com/apache/iotdb
into air-gap-udp-transport
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 dfd3411c63c Merge master into air-gap-udp-transport
No new revisions were added by this update.
Summary of changes:
LICENSE-binary | 24 +-
.../org/apache/iotdb/rest/i18n/RestMessages.java | 43 ++
.../org/apache/iotdb/rest/i18n/RestMessages.java | 43 ++
.../exception/RequestLimitExceededException.java | 17 +-
...er.java => RequestBodyMemoryReleaseFilter.java} | 39 +-
.../protocol/filter/RequestSizeLimitFilter.java | 183 +++++
.../filter/RestRequestBodyMemoryManager.java | 116 ++++
.../rest/protocol/handler/RequestLimitChecker.java | 68 ++
.../table/v1/handler/ExceptionHandler.java | 10 +-
.../table/v1/handler/RequestValidationHandler.java | 10 +
.../protocol/table/v1/impl/RestApiServiceImpl.java | 16 +-
.../rest/protocol/v1/handler/ExceptionHandler.java | 10 +-
.../v1/handler/RequestValidationHandler.java | 29 +
.../protocol/v1/impl/GrafanaApiServiceImpl.java | 12 +-
.../rest/protocol/v1/impl/RestApiServiceImpl.java | 12 +-
.../rest/protocol/v2/handler/ExceptionHandler.java | 10 +-
.../v2/handler/RequestValidationHandler.java | 47 ++
.../protocol/v2/impl/GrafanaApiServiceImpl.java | 12 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 20 +-
.../filter/RequestSizeLimitFilterTest.java | 258 +++++++
.../handler/RequestValidationLimitTest.java | 109 +++
.../apache/iotdb/itbase/constant/TestConstant.java | 2 +-
.../IoTDBRegionMigrateNormalITForIoTV2BatchIT.java | 2 +-
.../IoTDBRemoveConfigNodeITFramework.java | 20 +-
.../db/it/IoTDBAlignedTVListLazyAllocationIT.java | 139 ++++
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 42 ++
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 2 +-
.../iotdb/db/it/auth/IoTDBTemplateAuthIT.java | 7 +-
...DBAlignedTVListPrimitiveArrayPerformanceIT.java | 584 ++++++++++++++++
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 4 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 3 +
.../it/db/it/IoTDBAuthenticationTableIT.java | 9 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 114 +++
.../recent/IoTDBQueryWithCorruptedTsFileIT.java | 355 ++++++++++
.../it/query/recent/IoTDBTableAggregationIT.java | 15 +
.../it/schema/IoTDBAlterColumnTypeIT.java | 9 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 3 +
.../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 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +-
.../main/java/org/apache/iotdb/rpc/UrlUtils.java | 8 +
.../java/org/apache/iotdb/rpc/UrlUtilsTest.java | 3 +
iotdb-core/ainode/build_binary.py | 5 +-
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 20 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 20 +
.../iotdb/calc}/execution/FutureStateChange.java | 6 +-
.../apache/iotdb/calc}/execution/StateMachine.java | 55 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 4 +-
.../aggregation/GroupedMaxAccumulatorTest.java | 124 ++++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 8 +
.../iotdb/confignode/i18n/ManagerMessages.java | 6 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 31 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 8 +
.../iotdb/confignode/i18n/ManagerMessages.java | 6 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 43 +-
.../iotdb/confignode/manager/ConfigManager.java | 13 +
.../iotdb/confignode/manager/ProcedureManager.java | 72 +-
.../iotdb/confignode/manager/node/NodeManager.java | 79 ++-
.../manager/partition/PartitionMetrics.java | 94 ++-
.../runtime/heartbeat/PipeHeartbeatParser.java | 8 +
.../manager/schema/ClusterSchemaManager.java | 9 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 58 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 87 ++-
.../confignode/persistence/schema/ConfigMTree.java | 29 +-
.../persistence/schema/ConfigSchemaStatistics.java | 109 +++
.../confignode/procedure/ProcedureExecutor.java | 25 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 66 +-
.../procedure/impl/StateMachineProcedure.java | 11 +
.../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/DeleteDatabaseProcedure.java | 2 +
.../confignode/procedure/scheduler/LockQueue.java | 6 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 2 +-
.../consensus/response/pipe/PipeTableRespTest.java | 12 +
.../confignode/manager/node/NodeManagerTest.java | 189 +++++
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 36 +
.../pipe/PipeTaskInfoAutoRestartTest.java | 41 ++
.../persistence/schema/ClusterSchemaInfoTest.java | 57 ++
.../persistence/schema/ConfigMTreeTest.java | 8 +-
.../procedure/TestProcedureExecutor.java | 28 +
.../pipe/AbstractOperatePipeProcedureV2Test.java | 31 +
.../impl/pipe/task/DropPipeProcedureV2Test.java | 154 +++++
.../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 | 5 +-
.../consensus/iot/IoTConsensusServerImpl.java | 44 +-
.../iotdb/consensus/pipe/IoTConsensusV2.java | 88 ++-
.../ratis/ApplicationStateMachineProxy.java | 32 +-
.../consensus/iot/IoTConsensusServerImplTest.java | 162 +++++
.../apache/iotdb/consensus/iot/ReplicateTest.java | 189 +++++
.../iotdb/consensus/pipe/IoTConsensusV2Test.java | 55 ++
.../assembly/resources/conf/logback-datanode.xml | 18 -
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 14 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 39 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 1 +
.../iotdb/db/i18n/StorageEngineMessages.java | 13 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 14 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 39 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 1 +
.../iotdb/db/i18n/StorageEngineMessages.java | 13 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 132 +++-
.../iotdb/db/audit/PasswordChangeAuditContext.java | 187 +++++
.../iotdb/db/audit/PasswordChangeAuditTask.java | 87 +++
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 204 ++++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 14 +
.../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 ++
.../agent/task/connection/PipeEventCollector.java | 15 +-
.../subtask/processor/PipeProcessorSubtask.java | 41 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 61 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 226 ++++--
.../scan/TsFileInsertionEventScanParser.java | 40 +-
...ileInsertionEventTableParserTabletIterator.java | 48 +-
.../processor/aggregate/AggregateProcessor.java | 39 +-
.../downsampling/DownSamplingProcessor.java | 40 +-
.../sdt/SwingingDoorTrendingFilter.java | 8 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 31 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 16 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 351 +++++++++-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 24 +-
.../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 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 2 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 12 +-
.../request/IoTConsensusV2TabletInsertNodeReq.java | 6 +
.../async/handler/PipeTransferTsFileHandler.java | 22 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 12 +-
.../sink/protocol/websocket/WebSocketSink.java | 21 +-
.../db/queryengine/common/MPPQueryContext.java | 6 +-
.../queryengine/execution/QueryStateMachine.java | 1 +
.../fragment/FragmentInstanceStateMachine.java | 4 +-
.../execution/operator/source/FileLoaderUtils.java | 65 +-
.../execution/operator/source/SeriesScanUtil.java | 43 +-
.../execution/schedule/AbstractDriverThread.java | 28 +-
.../analyze/cache/partition/PartitionCache.java | 4 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 36 +-
.../execution/config/TableConfigTaskVisitor.java | 40 +-
.../execution/config/TreeConfigTaskVisitor.java | 30 +-
.../config/metadata/CountDatabaseTask.java | 4 +-
.../planner/DataNodeTableOperatorGenerator.java | 13 +-
.../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 | 11 +
.../read_tsfile/ExternalTsFileQueryResource.java | 100 ++-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 2 +-
.../cache/TreeDeviceSchemaCacheManager.java | 4 +-
.../node/schema/TableSchemaQueryWriteVisitor.java | 31 +-
.../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 +++--
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +
.../plan/statement/crud/InsertBaseStatement.java | 46 ++
.../crud/InsertMultiTabletsStatement.java | 11 +
.../plan/statement/crud/InsertRowsStatement.java | 29 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 9 +-
.../schemaengine/lease/MetadataLeaseManager.java | 6 +-
.../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 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 15 +-
.../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/metrics/WritingMetrics.java | 23 +-
.../metrics/memory/QueryEngineMemoryMetrics.java | 26 +-
.../iotdb/db/storageengine/StorageEngine.java | 6 +-
.../db/storageengine/dataregion/DataRegion.java | 10 +-
.../dataregion/memtable/AbstractMemTable.java | 74 +-
.../memtable/AlignedWritableMemChunk.java | 4 +
.../dataregion/memtable/IMemTable.java | 9 +
.../dataregion/memtable/TsFileProcessor.java | 529 ++++++++++----
.../read/reader/chunk/DiskAlignedChunkLoader.java | 5 +
.../read/reader/chunk/DiskChunkLoader.java | 5 +
.../broker/ConsensusSubscriptionBroker.java | 21 +-
.../consensus/ConsensusPrefetchingQueue.java | 754 +++++++++++++++-----
...nsensusSubscriptionPrefetchingQueueMetrics.java | 214 +++---
.../receiver/SubscriptionReceiverV1.java | 2 +-
.../SubscriptionDataNodeResourceManager.java | 6 +
.../resource/SubscriptionMemoryManager.java | 89 +++
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +-
.../db/utils/datastructure/AlignedTVList.java | 294 +++++---
.../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 +-
.../org/apache/iotdb/db/auth/TreeAccessTest.java | 55 ++
.../iotdb/db/conf/DataNodeMemoryConfigTest.java | 104 ++-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 119 ++++
.../dataregion/DataRegionStateMachineTest.java | 143 ++++
.../schemaRegion/SchemaRegionManagementTest.java | 38 +
.../task/subtask/sink/PipeSinkSubtaskTest.java | 93 +++
.../pipe/event/PipeTsFileInsertionEventTest.java | 9 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 191 +++--
.../PipeTsFileInsertionEventAdmissionTest.java | 67 +-
.../sdt/SwingingDoorTrendingFilterTest.java | 17 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 85 ++-
.../resource/memory/PipeMemoryManagerTest.java | 384 +++++++++++
.../request/PipeTransferSerializationSizeTest.java | 530 ++++++++++++++
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 17 +-
.../PipeTransferTsFileHandlerRateLimitTest.java | 83 +++
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 75 ++
.../node/write/InsertRowsNodeSerdeTest.java | 26 +
.../plan/relational/analyzer/AuthTest.java | 51 ++
.../schema/TableSchemaQueryWriteVisitorTest.java | 89 +++
.../statement/crud/InsertBaseStatementTest.java | 88 +++
.../schemaengine/lease/MetadataLeaseTestUtils.java | 9 +-
.../table/DataNodeTableCacheLeaseTest.java | 24 +-
.../AbstractMemTablePartialInsertTest.java | 87 ++-
...ignedBitmapMemoryAccountingPerformanceTest.java | 295 ++++++++
.../dataregion/memtable/TsFileProcessorTest.java | 221 +++++-
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 346 ++++++++++
.../consensus/ConsensusPrefetchingQueueTest.java | 765 ++++++++++++++++++++-
...nsensusPrefetchingQueueWalBackpressureTest.java | 336 +++++++++
...susSubscriptionPrefetchingQueueMetricsTest.java | 164 +++++
.../resource/SubscriptionMemoryManagerTest.java | 64 ++
.../db/utils/datastructure/AlignedTVListTest.java | 167 +++++
.../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 | 15 +
.../src/test/resources/iotdb-system.properties | 15 +
.../conf/iotdb-system.properties.template | 48 +-
.../apache/iotdb/commons/i18n/PipeMessages.java | 4 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 4 +
.../iotdb/commons/concurrent/IoTThreadFactory.java | 3 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 40 ++
.../iotdb/commons/conf/CommonDescriptor.java | 4 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../exception/MetadataLeaseFencedException.java | 21 +-
.../pipe/PipeRuntimeCriticalException.java | 4 +
.../exception/pipe/PipeRuntimeException.java | 4 +
.../pipe/PipeRuntimeSinkCriticalException.java | 4 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 6 +
.../commons/pipe/agent/task/meta/PipeStatus.java | 3 +
.../task/subtask/PipeAbstractSinkSubtask.java | 10 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 14 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 10 +
.../pipe/sink/protocol/IoTDBAirGapSink.java | 2 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 2 +-
.../plan/planner/plan/node/PlanNode.java | 8 +
.../iotdb/commons/service/metric/enums/Metric.java | 5 +
.../apache/iotdb/commons/udf/utils/KDTreeUtil.java | 10 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 2 +
.../apache/iotdb/commons/utils/StatusUtils.java | 1 +
...monDescriptorDiskSpaceWarningThresholdTest.java | 2 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 13 +
.../iotdb/commons/udf/utils/KDTreeUtilTest.java} | 30 +-
.../iotdb/commons/utils/RetryStatusUtilsTest.java} | 25 +-
.../iotdb/commons/utils/RetryUtilsTest.java} | 25 +-
pom.xml | 4 +-
scripts/tools/ops/health_check.sh | 8 +-
scripts/tools/windows/ops/backup.bat | 16 +-
scripts/tools/windows/ops/health_check.bat | 41 +-
294 files changed, 14548 insertions(+), 1748 deletions(-)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/IterableSortedMap.java
=>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/exception/RequestLimitExceededException.java
(66%)
copy
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/filter/{User.java
=> RequestBodyMemoryReleaseFilter.java} (63%)
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/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/RequestValidationLimitTest.java
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/performance/IoTDBAlignedTVListPrimitiveArrayPerformanceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBQueryWithCorruptedTsFileIT.java
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/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/GroupedMaxAccumulatorTest.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/node/NodeManagerTest.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/pipe/IoTConsensusV2Test.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/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/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/thrift/async/handler/PipeTransferTsFileHandlerRateLimitTest.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/statement/crud/InsertBaseStatementTest.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/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/metric/ConsensusSubscriptionPrefetchingQueueMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/resource/SubscriptionMemoryManagerTest.java
copy
iotdb-core/{calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/process/fill/filter/FixedIntervalFillFilterTest.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/KDTreeUtilTest.java}
(55%)
copy
iotdb-core/{datanode/src/test/java/org/apache/iotdb/db/exception/mpp/FragmentInstanceDispatchExceptionTest.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/utils/RetryStatusUtilsTest.java}
(54%)
copy
iotdb-core/{datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/aggregation/slidingwindow/SlidingWindowAggregatorFactoryTest.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/utils/RetryUtilsTest.java}
(51%)
