This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch sync-generic-changes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4739e3531d0 [Test] Mark multi-table insert rows as pipe batch in
SchemaValidatorTest
add 02b8c6c0437 Bump ratis to 3.3.1 (#18605)
add f00b24c66eb Fix table-model pipe batch leader redirects (#18690)
add be8606615e5 Fix SinkChannel failure propagation test race (#18675)
add 56b09f28dec Fix schema cache pollution from LAST queries on virtual
regions (#18694)
add 6377522ce2c Fix pipe leader cache updates for multi-device redirects
(#18689)
add af6f8f52e5a [Test] Avoid metadata lease fencing in DataNode unit tests
(#18284)
add a3330994747 Fix scan termination for finished fragment instances
(#18701)
add e7ec99f5d17 Datanode: validate that a query id belongs to the calling
session (#18643)
add c2ea4a40704 Add ImportWAL tool with WAL replay controls (#18516)
add 02ae00db9bc Wait for region leader election before region migration
(#18699)
add fbd5fd22a6c Fix flaky SHOW RECEIVERS lifecycle test (#18700)
add c32431faa5d Use TypeService for ImportWAL snapshot replay (#18711)
add 0594afc33a8 fix the table function that has scalar argument of null
value (#18714)
add ee17d1a8d25 [Subscription] Recover realtime admission after queue
backpressure (#18715)
add ab15c0a19b0 Recover WAL metadata from readable entries and quarantine
unrecoverable files (#18693)
add 6fa33f21ba0 Fix duplicate subscription auto commits (#18710)
add c8bf0bcfbf3 Validate region operation requests before submitting
procedures (#18696)
add 473672dfc32 Fix fenced owner heartbeat lease refresh (#18717)
add a22746a57af Fix thread pool lifecycle leaks (#18703)
add 5750e9d4014 [Subscription] Fix consumer close deadlock (#18704)
add d6b602e4463 [Subscription] Bound heartbeat provider failures (#18712)
add 7984abcabb6 [Pipe] Fix AirGap receiver retry request body reuse
(#18721)
add 90959ab504c Fix UPDATE attribute column validation (#18705)
add 81caad0395f [Query] Allow concurrent local fragment execution for
last-query collection (#18727)
add 881ed81484b Fix deletion matching during compaction (#18732)
add a51258bbb97 [Performance] Reduce aligned flush duplicate timestamp
overhead
add f24b24dcf7c Add proactive RegionGroup allocation and policy hot reload
(#18692)
add d587d8d295c Remove JDBC OSGi support (#18719)
add 79631e3ec62 Register IoTDBDriver as a JDBC 4 service provider (#18744)
add ba287a9cb41 Fix SHOW DEVICES limit offset test ordering (#18745)
add a6cfe257b1d Avoid size estimation for fixed-length compaction points
(#18707)
add dacf7c681f8 Expand some codes for use in the future (#18752)
add f58a52fe90c Fix WAL replay stalls on oversized entries (#18728)
add ce6c1f5f477 Fix pipe sink metrics lifecycle race (#18722)
add b2cc8b52126 Fix metrics lost after metric service restart and
conflicting metric series (#18748)
add 9e40726175d Reuse tablet device ranges during writes (#18734)
add d74b2744ed1 Fix schema region snapshot memory accounting (#18750)
add bd3109ef1ba Fix tag index query for pre-deleted timeseries (#18751)
add afb90593d1c Fix subscription TsFile deduplication and poll concurrency
(#18758)
add 864321f86a7 Fix async subscription commits after close (#18757)
add 3227bc1a219 [Subscription] Increase consensus catch-up batch size
(#18739)
add 3154bffd068 [Subscription] Prevent unsubscribe from blocking on
prefetch cleanup (#18742)
add 4092a780097 Fix pipe TsFile transfer when mod file is missing (#18756)
add 61e405bbfdb Revert "Show pre-deleted table schemas and improve write
errors (#18626)" (#18762)
add f510a924968 Fix ordering propagation around table and window functions
(#18749)
add 50d86cf4161 Fix flaky heartbeat executor bound test (#18773)
add 825bf9e6b8b Stop data region write retry promptly (#18730)
add 94694d92f25 Avoid redundant TsFile table schema registration (#18731)
add daf9dd8d771 Reject duplicate schema region IDs during recovery (#18754)
add 166883a1b2e Fix semantic error for unsupported table INSERT time
expressions (#18759)
add f8bfcffc9ba Fix subscription stalls after consumer disconnect (#18760)
add ef9bb521ccf Fix subscription cache memory configuration (#18761)
add abd499334f0 [Subscription] Bound pending WAL gap replay per round
(#18766)
add 8f1bed8246c [Subscription] Consolidate poll queue fixes (#18771)
add 5d389dd6e86 Fix subscription WAL retention at replay cursor (#18769)
add 5a9c6b9f293 Fix SHOW TTL wildcard path scope (#18763)
add ec72c599ce6 Show pre-delete tables in SHOW TABLES and reject
modifications on them (#18770)
add 0c9a5ee0916 Optimize tag index timeseries lookup (#18753)
add 2f9f9cab1b7 Fix TTL expired data ratio in settle compaction (#18777)
add b777d3c3f3d [Subscription] Reuse uncovered committed WAL retention
boundary (#18778)
add e163f3bc802 Stabilize subscription heartbeat executor test (#18782)
add df27bbc5001 Fix table delete routing to region leaders (#18779)
add acb801e163e [Subscription] Prevent consumers from idling on dry
regions (#18738)
add 0c9fb83974f [Fix] Prevent silent subscription data loss on WAL replay
gaps (#18741)
add ce14b310e1d [Subscription] Flush lingering batch before WAL gap retry
(#18785)
add bbe63644769 Revert "[Fix] Prevent silent subscription data loss on WAL
replay gaps (#18741)" (#18786)
add 5756dc831ae Build: upgrade Develocity Maven extension (#18790)
add 40e7ce62936 Reject truncated Thrift containers before allocation
(#18631)
add a67e6322f72 Merge branch 'iotdb_master' into sync-generic-changes
add 65ec512d89e [Query] Mark uniform insert targets at the write path
add a8c7bc917ad [ConfigNode] Reject user/role profiles written by a newer
version
No new revisions were added by this update.
Summary of changes:
.mvn/extensions.xml | 2 +-
LICENSE-binary | 3 -
dependencies.json | 3 -
.../IoTDBProactiveRegionGroupDistributionIT.java | 1471 ++++++++++++++
.../IoTDBProactiveRegionGroupExtensionIT.java | 368 ++++
.../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 9 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 123 +-
.../it/IoTDBRecreatedTimeseriesCompactionIT.java | 125 ++
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 24 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 68 +
.../db/it/last/IoTDBLastQueryVirtualRegionIT.java | 137 ++
.../auto/basic/IoTDBShowReceiversLifecycleIT.java | 2 +
.../it/db/it/IoTDBDeletionTableClusterIT.java | 152 ++
.../relational/it/db/it/IoTDBInsertTableIT.java | 117 ++
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 10 +-
.../it/db/it/IoTDBOrderingPropertyIT.java | 486 +++++
.../it/db/it/IoTDBWindowFunction3IT.java | 6 +-
.../relational/it/db/it/IoTDBWindowFunctionIT.java | 40 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 86 +
.../query/view/recent/IoTDBTableViewQueryIT.java | 9 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 46 +-
.../java/org/apache/iotdb/cli/AbstractCliTest.java | 44 +
iotdb-client/jdbc/README.md | 23 -
iotdb-client/jdbc/osgi.bnd | 31 -
iotdb-client/jdbc/pom.xml | 81 -
iotdb-client/jdbc/src/main/feature/feature.xml | 36 -
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 3 -
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 3 -
.../main/java/org/apache/iotdb/jdbc/Activator.java | 42 -
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 79 -
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 2 -
.../resources/META-INF/services/java.sql.Driver | 2 +
.../resources/services/META-INF/java.sql.Driver | 19 -
.../iotdb/jdbc/DriverServiceRegistrationTest.java | 28 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 39 +
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 3 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 3 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 42 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
.../iotdb/rpc/TElasticFramedTransportReadTest.java | 266 +++
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../rpc/subscription/config/ConsumerConstant.java | 2 +-
.../base/AbstractSubscriptionConsumer.java | 22 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 2 +-
.../base/AbstractSubscriptionProvider.java | 2 +-
.../base/AbstractSubscriptionProviders.java | 72 +-
.../base/AbstractSubscriptionPullConsumer.java | 19 +
.../base/SubscriptionExecutorServiceManager.java | 68 +
.../tree/SubscriptionTreePullConsumer.java | 2 +-
.../tree/SubscriptionTreePushConsumer.java | 2 +-
...SubscriptionConsumerHeartbeatIsolationTest.java | 341 ++++
.../base/SubscriptionConsumerLifecycleTest.java | 170 +-
.../operator/RowReferenceTsBlockManager.java | 12 +-
.../process/AbstractLinearFillOperator.java | 15 +-
.../process/TableLinearFillWithGroupOperator.java | 18 +-
.../process/TableNextFillWithGroupOperator.java | 5 +
.../operator/process/TableStreamSortOperator.java | 4 +-
.../process/window/TopKRankingOperator.java | 12 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 23 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 23 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 70 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 -
.../consensus/request/ConfigPhysicalPlanType.java | 9 +-
.../table/RollbackPreAlterColumnDataTypePlan.java | 61 -
.../partition/GetRegionGroupsByTimeResp.java | 25 +
.../confignode/manager/ClusterQuotaManager.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 33 +-
.../iotdb/confignode/manager/ProcedureManager.java | 482 ++---
.../partition/DataPartitionPolicyTable.java | 18 +-
.../manager/partition/PartitionManager.java | 106 +-
.../partition/RegionGroupExtensionPolicy.java | 4 +-
.../PipeConfigNodeRemainingTimeMetrics.java | 20 +-
.../PipeTemporaryMetaInCoordinatorMetrics.java | 18 +-
.../metric/sink/PipeConfigRegionSinkMetrics.java | 17 +-
.../source/PipeConfigRegionSourceMetrics.java | 17 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 7 +
.../manager/schema/ClusterSchemaManager.java | 48 +-
.../persistence/executor/ConfigPlanExecutor.java | 4 -
.../partition/DatabasePartitionTable.java | 16 +
.../persistence/partition/PartitionInfo.java | 12 +
.../schema/CNPhysicalPlanGenerator.java | 15 +
.../persistence/schema/ClusterSchemaInfo.java | 97 -
.../confignode/persistence/schema/ConfigMTree.java | 205 +-
.../procedure/env/RegionMaintainHandler.java | 22 +-
.../table/AlterTableColumnDataTypeProcedure.java | 78 +-
.../impl/schema/table/CreateTableProcedure.java | 16 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 2 +-
.../conf/RegionGroupExtensionPolicyConfigTest.java | 106 +
.../request/ConfigPhysicalPlanSerDeTest.java | 15 -
.../manager/ClusterSchemaManagerTest.java | 89 +
.../ConfigManagerRegionGroupPolicyReloadTest.java | 150 ++
.../ProcedureManagerReconstructRegionTest.java | 190 --
.../ProcedureManagerRegionOperationTest.java | 401 ++++
.../DataPartitionPolicyTableProactiveTest.java | 190 ++
.../PartitionManagerProactiveExtensionTest.java | 811 ++++++++
.../metric/PipeConfigNodeMetricsRestartTest.java | 184 ++
.../persistence/CNPhysicalPlanGeneratorTest.java | 20 +
.../persistence/schema/ClusterSchemaInfoTest.java | 119 ++
.../persistence/schema/ConfigMTreeTest.java | 64 +-
.../persistence/schema/TablePreDeleteTest.java | 368 ----
.../procedure/env/RegionMaintainHandlerTest.java | 235 +++
.../AlterTableColumnDataTypeProcedureTest.java | 171 --
.../schema/table/CreateTableProcedureTest.java | 39 -
iotdb-core/consensus/pom.xml | 5 +
.../consensus/iot/IoTConsensusServerImpl.java | 7 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 104 +-
.../subscription/SubscriptionQueueRegistry.java | 21 +-
.../SubscriptionWalRetentionCalculator.java | 10 +-
.../consensus/pipe/IoTConsensusV2ServerImpl.java | 5 +
.../pipe/metric/IoTConsensusV2ServerMetrics.java | 3 -
.../consensus/ratis/metrics/CounterProxy.java | 8 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 34 +-
.../ratis/metrics/MetricRegistryManager.java | 14 +
.../consensus/ratis/metrics/RatisMetricSet.java | 8 +-
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 7 +-
.../LogDispatcherThreadMetricsTest.java | 146 ++
.../metric/IoTConsensusV2ServerMetricsTest.java | 107 +
.../ratis/metrics/RatisMetricSetTest.java | 134 ++
iotdb-core/datanode/pom.xml | 2 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 42 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 7 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 3 +
.../apache/iotdb/db/i18n/ImportWALMessages.java | 155 ++
.../iotdb/db/i18n/StorageEngineMessages.java | 5 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 40 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 7 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 3 +
.../apache/iotdb/db/i18n/ImportWALMessages.java | 154 ++
.../iotdb/db/i18n/StorageEngineMessages.java | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 +
.../dataregion/DataRegionStateMachine.java | 8 +-
.../db/partition/DataPartitionTableGenerator.java | 8 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 20 +-
.../overview/PipeTsFileToTabletsMetrics.java | 16 +-
.../metric/processor/PipeProcessorMetrics.java | 19 +-
.../schema/PipeSchemaRegionListenerMetrics.java | 16 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 16 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 16 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 19 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 13 +-
.../metric/source/PipeDataRegionSourceMetrics.java | 20 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 11 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 36 +-
.../request/PipeTransferTabletBatchReqV2.java | 7 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 3 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 109 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 13 +-
.../PipeTransferTabletInsertionEventHandler.java | 6 +-
.../async/handler/PipeTransferTsFileHandler.java | 100 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 7 +-
.../db/pipe/sink/util/cacher/LeaderCacheUtils.java | 42 +-
.../iotdb/db/protocol/session/ClientSession.java | 23 +
.../iotdb/db/protocol/session/IClientSession.java | 3 +
.../db/protocol/session/InternalClientSession.java | 5 +
.../db/protocol/session/MqttClientSession.java | 5 +
.../db/protocol/session/RestClientSession.java | 5 +
.../handler/RPCServiceThriftHandlerMetrics.java | 37 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 97 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 50 +-
.../db/queryengine/execution/driver/Driver.java | 6 +
...java => FragmentInstanceFinishedException.java} | 16 +-
.../process/last/LastQueryCollectOperator.java | 12 +-
.../execution/operator/source/SeriesScanUtil.java | 4 +
.../analyze/cache/partition/PartitionCache.java | 2 +-
.../plan/analyze/schema/SchemaValidator.java | 16 +-
.../config/executor/ClusterConfigTaskExecutor.java | 24 +-
.../plan/planner/OperatorTreeGenerator.java | 12 +-
.../relational/analyzer/StatementAnalyzer.java | 162 +-
.../fetcher/TableHeaderSchemaValidator.java | 41 +-
.../distribute/TableDistributedPlanGenerator.java | 594 +++++-
.../planner/optimizations/SortElimination.java | 65 +-
.../optimizations/TableFunctionOrdering.java | 79 +
.../TransformAggregationToStreamable.java | 5 +-
.../optimizations/TransformSortToStreamSort.java | 45 +-
.../plan/relational/sql/parser/AstBuilder.java | 16 +-
.../plan/statement/crud/InsertRowsStatement.java | 20 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 23 +-
.../schemaengine/metric/SchemaEngineMemMetric.java | 7 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 7 +-
.../rescon/MemSchemaEngineStatistics.java | 4 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 91 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 32 +-
.../schemaengine/schemaregion/tag/TagManager.java | 55 +-
.../db/schemaengine/table/DataNodeTableCache.java | 90 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 2 +
.../iotdb/db/service/metrics/CacheMetrics.java | 17 +
.../db/service/metrics/DataNodeMetricsHelper.java | 1 +
.../metrics/IoTDBInternalLocalReporter.java | 1 +
.../iotdb/db/service/metrics/WritingMetrics.java | 80 +-
.../db/service/metrics/file/TsFileMetrics.java | 22 +
.../iotdb/db/storageengine/StorageEngine.java | 4 +
.../db/storageengine/dataregion/DataRegion.java | 13 +-
.../dataregion/DataRegionMetrics.java | 49 +-
.../execute/utils/CompactionPathUtils.java | 2 +-
.../utils/writer/AbstractCompactionWriter.java | 10 +-
.../selector/impl/SettleSelectorImpl.java | 5 +-
.../dataregion/memtable/AbstractMemTable.java | 32 +-
.../memtable/AlignedWritableMemChunk.java | 119 +-
.../dataregion/memtable/IMemTable.java | 10 +
.../dataregion/memtable/TsFileProcessor.java | 98 +-
.../memtable/TsFileProcessorInfoMetrics.java | 55 +-
.../dataregion/modification/TagPredicate.java | 24 +
.../dataregion/wal/buffer/WALBuffer.java | 30 +-
.../dataregion/wal/io/WALByteBufReader.java | 24 +-
.../dataregion/wal/io/WALFileVersion.java | 19 +
.../dataregion/wal/io/WALInputStream.java | 82 +-
.../dataregion/wal/io/WALMetaData.java | 98 +-
.../storageengine/dataregion/wal/io/WALReader.java | 21 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 17 +-
.../storageengine/dataregion/wal/node/WALNode.java | 12 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 54 +-
.../dataregion/wal/recover/WALRepairWriter.java | 125 +-
.../load/memory/LoadTsFileMemoryBlock.java | 20 +-
.../load/metrics/ActiveLoadingFilesMetricsSet.java | 6 +
.../ActiveLoadingFilesNumberMetricsSet.java | 16 +-
.../load/metrics/LoadTsFileMemMetricSet.java | 19 +-
.../agent/SubscriptionBrokerAgent.java | 8 +
.../agent/SubscriptionConsumerAgent.java | 147 +-
.../agent/SubscriptionReceiverAgent.java | 12 +
.../broker/ConsensusSubscriptionBroker.java | 53 +-
.../subscription/broker/ISubscriptionBroker.java | 3 +
.../db/subscription/broker/SubscriptionBroker.java | 14 +-
.../broker/SubscriptionPrefetchingQueue.java | 107 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 28 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 11 +-
.../consensus/ConsensusLogToTabletConverter.java | 4 +
.../consensus/ConsensusPrefetchingQueue.java | 216 +-
.../broker/consensus/ProgressWALIterator.java | 61 +-
.../event/cache/SubscriptionPollResponseCache.java | 24 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 12 +-
.../SubscriptionPrefetchingQueueMetrics.java | 55 +-
.../receiver/SubscriptionReceiver.java | 5 +
.../receiver/SubscriptionReceiverV1.java | 66 +-
.../java/org/apache/iotdb/db/tools/ImportWAL.java | 1728 ++++++++++++++++
.../iotdb/db/tools/TableWALDeleteConverter.java | 226 +++
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 7 +
.../org/apache/iotdb/db/utils/TypeServices.java | 81 +
.../dataregion/DataRegionStateMachineTest.java | 53 +-
.../schemaRegion/SchemaRegionManagementTest.java | 38 +-
.../SchemaRegionSimpleRecoverTest.java | 76 +
.../db/pipe/metric/PipeMetricsRestartTest.java | 426 ++++
.../PipeSchemaRegionListenerMetricsTest.java | 116 ++
.../metric/sink/PipeDataRegionSinkMetricsTest.java | 98 +
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 63 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 70 +
.../thrift/async/IoTDBDataRegionAsyncSinkTest.java | 49 +
...peTransferTabletInsertNodeEventHandlerTest.java | 105 +
.../PipeTransferTsFileHandlerCleanupTest.java | 56 +
.../sink/util/cacher/LeaderCacheUtilsTest.java | 89 +
.../db/protocol/session/QueryOwnershipTest.java | 343 ++++
.../queryengine/execution/ConfigExecutionTest.java | 27 +
.../SinkChannelFailurePropagationTest.java | 12 +-
.../operator/LastQueryCollectOperatorTest.java | 140 ++
.../process/TableStreamSortOperatorTest.java | 63 +
.../process/fill/GroupedFillOperatorTest.java | 174 ++
.../process/window/TopKRankingOperatorTest.java | 75 +-
.../source/SeriesScanUtilCancellationTest.java | 172 +-
.../schedule/DefaultDriverSchedulerTest.java | 81 +
.../plan/analyze/schema/SchemaValidatorTest.java | 2 -
.../plan/planner/LastQueryCacheTest.java | 236 +++
.../plan/relational/analyzer/AnalyzerTest.java | 138 ++
.../plan/relational/analyzer/TreeViewTest.java | 5 -
.../fetcher/TableHeaderSchemaValidatorTest.java | 251 ---
.../plan/relational/planner/PlanTester.java | 6 +-
.../planner/WindowFunctionOptimizationTest.java | 12 +-
.../OrderingPropertyPropagationTest.java | 481 +++++
.../optimizations/TableFunctionSortTest.java | 263 +++
.../iotdb/db/schemaengine/SchemaEngineTest.java | 57 +
.../metric/SchemaMemMetricTableTest.java | 133 ++
.../tag/TagManagerPerformanceTest.java | 258 +++
.../schemaregion/tag/TagManagerTest.java | 64 +
.../schemaengine/table/DataNodeTableCacheTest.java | 208 +-
.../metrics/DataNodeMetricsRestartTest.java | 290 +++
.../db/service/metrics/file/TsFileMetricsTest.java | 148 ++
.../dataregion/DatabaseMemMetricsTest.java | 144 ++
.../utils/writer/AbstractCompactionWriterTest.java | 17 +-
.../compaction/utils/CompactionUtilsTest.java | 43 +-
...gnedFlushDuplicateTimeCheckPerformanceTest.java | 238 +++
.../dataregion/memtable/MemTableFlushTaskTest.java | 83 +
.../TabletDeviceRangeReusePerformanceTest.java | 283 +++
.../dataregion/memtable/TsFileProcessorTest.java | 110 ++
...FileTableSchemaRegistrationPerformanceTest.java | 230 +++
.../dataregion/wal/buffer/WALBufferCommonTest.java | 27 +
.../dataregion/wal/io/WALFileTest.java | 274 ++-
.../wal/recover/WALRepairWriterTest.java | 140 +-
.../agent/SubscriptionConsumerAgentTest.java | 114 ++
.../agent/SubscriptionReceiverAgentTest.java | 51 +
...onsensusSubscriptionBrokerPayloadLimitTest.java | 67 +
.../SubscriptionBrokerAgentPayloadLimitTest.java | 14 +
...sFileDeduplicationBlockingPendingQueueTest.java | 68 +
.../ConsensusLogToTabletConverterTest.java | 10 +
.../consensus/ConsensusPrefetchingQueueTest.java | 759 ++++++-
.../broker/consensus/ProgressWALIteratorTest.java | 92 +
.../cache/SubscriptionPollResponseCacheTest.java | 60 +
.../metric/SubscriptionMetricsRestartTest.java | 188 ++
.../receiver/SubscriptionReceiverV1Test.java | 100 +-
.../org/apache/iotdb/db/tools/ImportWALTest.java | 2070 ++++++++++++++++++++
.../db/tools/TableWALDeleteConverterTest.java | 318 +++
.../src/test/resources/iotdb-system.properties | 3 +
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 86 +-
.../metrics/metricsets/system/SystemMetrics.java | 13 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 1 +
.../resources/conf/edge/iotdb-system.properties | 1 +
.../conf/iotdb-system.properties.template | 83 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 12 +-
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 -
.../apache/iotdb/commons/i18n/ServiceMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 12 +-
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 -
.../apache/iotdb/commons/i18n/ServiceMessages.java | 2 +
.../commons/auth/role/LocalFileRoleAccessor.java | 2 +-
.../commons/concurrent/ThreadPoolMetrics.java | 74 +-
.../WrappedScheduledExecutorService.java | 4 +-
.../WrappedSingleThreadExecutorService.java | 4 +-
.../WrappedSingleThreadScheduledExecutor.java | 4 +-
.../threadpool/WrappedThreadPoolExecutor.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 6 +-
.../iotdb/commons/conf/CommonDescriptor.java | 16 +-
.../exception/table/ColumnInAlterException.java | 40 -
.../exception/table/ColumnInDeletionException.java | 40 -
.../exception/table/TableInDeletionException.java | 4 +-
.../pipe/metric/PipeEventCommitMetrics.java | 20 +-
.../function/TableBuiltinTableFunction.java | 34 +-
.../service/metric/JvmGcMonitorMetrics.java | 38 +-
.../commons/service/metric/MetricService.java | 13 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +
.../commons/concurrent/ThreadPoolMetricsTest.java | 157 ++
.../iotdb/commons/conf/CommonConfigTest.java | 8 +
...ubscriptionCacheMemoryUsagePercentageTest.java} | 24 +-
.../pipe/metric/PipeEventCommitMetricsTest.java | 99 +
.../service/metric/JvmGcMonitorMetricsTest.java | 72 +
.../service/metric/MetricServiceRestartTest.java | 218 +++
pom.xml | 19 +-
scripts/tools/README.md | 156 ++
.../{tsfile/settle-tsfile.sh => import-wal.sh} | 40 +-
.../windows/import-wal.bat} | 34 +-
340 files changed, 24226 insertions(+), 4089 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBProactiveRegionGroupDistributionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBProactiveRegionGroupExtensionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRecreatedTimeseriesCompactionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryVirtualRegionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBOrderingPropertyIT.java
delete mode 100644 iotdb-client/jdbc/osgi.bnd
delete mode 100644 iotdb-client/jdbc/src/main/feature/feature.xml
delete mode 100644
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/Activator.java
delete mode 100644
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java
copy
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/tablemodel/.gitkeep
=> iotdb-client/jdbc/src/main/resources/META-INF/services/java.sql.Driver (95%)
delete mode 100644
iotdb-client/jdbc/src/main/resources/services/META-INF/java.sql.Driver
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/exception/CpuNotEnoughExceptionTest.java
=>
iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/DriverServiceRegistrationTest.java
(54%)
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TElasticFramedTransportReadTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerHeartbeatIsolationTest.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/RollbackPreAlterColumnDataTypePlan.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/RegionGroupExtensionPolicyConfigTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerRegionGroupPolicyReloadTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerReconstructRegionTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerRegionOperationTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/partition/DataPartitionPolicyTableProactiveTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/partition/PartitionManagerProactiveExtensionTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeMetricsRestartTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/schema/TablePreDeleteTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/RegionMaintainHandlerTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedureTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcherThreadMetricsTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetricsTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricSetTest.java
create mode 100644
iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/ImportWALMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/ImportWALMessages.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/{FragmentInstanceFailureListener.java
=> FragmentInstanceFinishedException.java} (59%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionOrdering.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/TableWALDeleteConverter.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/PipeMetricsRestartTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/schema/PipeSchemaRegionListenerMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/sink/PipeDataRegionSinkMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTabletInsertNodeEventHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/session/QueryOwnershipTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/LastQueryCollectOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/GroupedFillOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LastQueryCacheTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableHeaderSchemaValidatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/OrderingPropertyPropagationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionSortTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/SchemaEngineTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/metric/SchemaMemMetricTableTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManagerPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/DataNodeMetricsRestartTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/file/TsFileMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/DatabaseMemMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedFlushDuplicateTimeCheckPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TabletDeviceRangeReusePerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileTableSchemaRegistrationPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueueTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/cache/SubscriptionPollResponseCacheTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/metric/SubscriptionMetricsRestartTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/ImportWALTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/TableWALDeleteConverterTest.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/ColumnInAlterException.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/ColumnInDeletionException.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/concurrent/ThreadPoolMetricsTest.java
copy
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/{sync/TsFilePipeInfoTest.java
=> conf/CommonDescriptorSubscriptionCacheMemoryUsagePercentageTest.java} (56%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/metric/PipeEventCommitMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/JvmGcMonitorMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/MetricServiceRestartTest.java
create mode 100644 scripts/tools/README.md
copy scripts/tools/{tsfile/settle-tsfile.sh => import-wal.sh} (60%)
copy scripts/{sbin/windows/stop-standalone.bat =>
tools/windows/import-wal.bat} (62%)
