This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/join in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 35962d403ba9bbc5526b217475562d7f1b8658dc Merge: f7fd85e0bde 525f40ce3eb Author: Beyyes <[email protected]> AuthorDate: Wed Aug 14 12:19:58 2024 +0800 Merge branch 'master' into beyyes/join .../relational/it/db/it/IoTDBInsertTableIT.java | 12 ++ .../relational/it/schema/IoTDBDeviceQueryIT.java | 8 ++ .../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 + .../iotdb/consensus/ratis/RatisConsensus.java | 2 + .../metadata/AliasAlreadyExistException.java | 4 +- .../metadata/AlignedTimeseriesException.java | 7 +- .../metadata/DatabaseNotSetException.java | 12 +- .../metadata/IllegalParameterOfPathException.java | 7 +- .../metadata/MeasurementAlreadyExistException.java | 4 +- .../metadata/PathAlreadyExistException.java | 4 +- .../template/TemplateIncompatibleException.java | 11 +- .../pipeconsensus/PipeConsensusAsyncConnector.java | 14 +- .../impl/DataNodeInternalRPCServiceImpl.java | 1 + .../execution/executor/RegionReadExecutor.java | 7 + .../fragment/FragmentInstanceContext.java | 29 ++++- .../fragment/FragmentInstanceExecution.java | 22 +++- .../execution/fragment/FragmentInstanceInfo.java | 20 +++ .../fragment/FragmentInstanceManager.java | 55 ++++++-- .../schedule/queue/IndexedBlockingQueue.java | 5 +- .../iotdb/db/queryengine/plan/Coordinator.java | 11 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 143 +++++++++++---------- .../queryengine/plan/analyze/ExpressionUtils.java | 2 +- .../analyze/lock/DataNodeSchemaLockManager.java | 23 +++- .../analyze/schema/ClusterSchemaFetchExecutor.java | 7 +- .../plan/analyze/schema/ClusterSchemaFetcher.java | 64 ++++----- .../plan/analyze/schema/SchemaValidator.java | 2 +- .../relational/analyzer/StatementAnalyzer.java | 4 +- .../plan/relational/metadata/MetadataUtil.java | 3 +- .../fetcher/TableHeaderSchemaValidator.java | 6 +- .../relational/sql/ast/AbstractQueryDevice.java | 22 +++- .../plan/relational/sql/ast/CountDevice.java | 4 +- .../plan/relational/sql/ast/LongLiteral.java | 2 +- .../plan/relational/sql/ast/ShowDevice.java | 4 +- .../plan/relational/sql/parser/AstBuilder.java | 4 +- .../scheduler/AbstractFragInsStateTracker.java | 3 +- .../plan/scheduler/ClusterScheduler.java | 4 +- .../scheduler/FixedRateFragInsStateTracker.java | 6 + .../scheduler/FragmentInstanceDispatcherImpl.java | 8 ++ .../db/service/metrics/CompactionMetrics.java | 14 +- .../db/storageengine/dataregion/DataRegion.java | 55 ++++---- .../utils/CompactionTableSchemaCollector.java | 2 +- .../compaction/io/CompactionTsFileWriter.java | 22 +++- ...Summary.java => CompactionScheduleContext.java} | 28 +++- .../compaction/schedule/CompactionScheduler.java | 47 ++++--- .../constant/InnerSequenceCompactionSelector.java | 4 +- .../InnerUnsequenceCompactionSelector.java | 4 +- .../impl/RewriteCrossSpaceCompactionSelector.java | 43 ++++++- .../utils/CrossSpaceCompactionCandidate.java | 26 +++- .../selector/utils/TsFileResourceCandidate.java | 13 +- .../dataregion/wal/io/ILogWriter.java | 13 ++ .../storageengine/dataregion/wal/io/LogWriter.java | 11 +- .../dataregion/wal/io/WALInputStream.java | 6 +- .../storageengine/dataregion/wal/io/WALReader.java | 3 + .../storageengine/dataregion/wal/io/WALWriter.java | 13 +- .../agent/SubscriptionConsumerAgent.java | 1 - .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +- .../iotdb/db/storageengine/dataregion/TTLTest.java | 6 +- ...eCompactionWithFastPerformerValidationTest.java | 2 +- .../cross/InsertionCrossSpaceCompactionTest.java | 4 +- .../inner/InnerCompactionSchedulerTest.java | 8 +- .../repair/RepairUnsortedFileCompactionTest.java | 8 +- .../TableModelFastCompactionPerformerTest.java | 4 +- ...TableModelReadChunkCompactionPerformerTest.java | 7 +- ...TableModelReadPointCompactionPerformerTest.java | 4 +- .../wal/compression/WALCompressionTest.java | 4 + .../wal/recover/WALRepairWriterTest.java | 10 +- .../commons/exception/IllegalPathException.java | 14 +- .../exception/IllegalPrivilegeException.java | 11 +- .../iotdb/commons/exception/IoTDBException.java | 7 +- .../apache/iotdb/commons/utils/StatusUtils.java | 1 + .../src/main/thrift/datanode.thrift | 1 + 71 files changed, 653 insertions(+), 293 deletions(-)
