This is an automated email from the ASF dual-hosted git repository.
weihao pushed a change to branch lwh/SQ-mp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fbc3e532318 add UT
add 8ebe2764805 Change UDF creation error code and avoid logging thread
stack in warn log (#17467)
add 4559929126e Fix: send set configuration only to target nodes and
harden compaction schedule interruption handling (#17469)
add 86000d52098 Due to the removal of the password history featureļ¼remove
associated the useless logic. (#17477)
add d06de8afc51 fix memory issue during testConcurrentCteQueries test
(#17473)
add e6c47750087 Add Claude Code project config and refine .gitignore
(#17458)
add 48388f3bd1c fix: pattern_match TVF crashes and parameter validation
(#17471)
add d44046c791c Increase time out to wait for
DataPartitionTableIntegrityCheckProcedure complete (#17476)
add 09017af9c5b Pipe: Fixed the NPE of progress report event (#17474)
add b8756a891a4 Change delay_analyzer_window_size log to INFO (#17478)
add da250b8113c Skip broken pipe plugins on startup and snapshot load
(#17470)
add a6006f3282a Update process memory metrics to report OS resident memory
(#17482)
add 1aba8731e85 enhance cppclient tsblock deserialize validation (#17464)
add 2d20fc81d9b Split "other" operations from "write" in QueryType (#17485)
add bb0f13b78bb Enhance the last query permission && Fixed the rollback
version of alter view / table plans && Deleted the unnecessary mods in Tree
view deletion (#17465)
add 3adba331316 Fixed alter column type's consensus write (#17483)
add b4ce8dab040 Fix can not use currentGeneratorFuture and
currentGenerator to get current progress if DN is restarted before the data
partition generation complete (#17491)
add a12c209645d fix region migrate daily IT (#17496)
add 6a461f09448 Pipe: Downgraded and reduced the log of
PipePushMetaRPCHandler (#17492)
add 608fa6c4fb1 delay monthly interval check to analyzer phase
add 7a462720ea8 Fix typos: 'occured' in log, 'seperated' in comments
(#17488)
add bfb4856ef98 Do some operations when some config params are invalid
(#17498)
add b5f54b9ff86 Fix IoTConsensusV2 receiver writer borrow race (#17495)
add 9c6b90a9812 [Pipe] Deduplicate historical tsfile events in
IoTConsensusV2 pipes (#17472)
add 519dec01c8d Add TimeZone header support to REST API (#17344) (#17387)
add 14c27bba99e Fix highestPriority of SHOW QUERIES are not set correctly
(#17505)
add 9fa5308aacd Merge branch 'master' of github.com:apache/iotdb into
lwh/SQ-mp
add ea17b7fa417 fix IT and UTs
No new revisions were added by this update.
Summary of changes:
.claude/settings.json | 17 +
.gitignore | 8 +-
CLAUDE.md | 180 ++++++++
.../main/java/org/apache/iotdb/HttpExample.java | 27 ++
.../main/java/org/apache/iotdb/HttpsExample.java | 27 ++
.../java/org/apache/iotdb/TableHttpExample.java | 30 ++
.../java/org/apache/iotdb/TableHttpsExample.java | 30 ++
.../rest/protocol/filter/AuthorizationFilter.java | 40 +-
.../protocol/table/v1/impl/RestApiServiceImpl.java | 4 +-
.../protocol/v1/impl/GrafanaApiServiceImpl.java | 14 +-
.../rest/protocol/v1/impl/RestApiServiceImpl.java | 9 +-
.../protocol/v2/impl/GrafanaApiServiceImpl.java | 14 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 37 +-
...IoTDBRegionOperationReliabilityITFramework.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 483 +++++++++++++++++++++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 8 +-
.../it/db/it/IoTDBSetConfigurationTableIT.java | 14 +
.../relational/it/db/it/IoTDBWindowTVFIT.java | 22 +
.../relational/it/query/recent/IoTDBCteIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionQueryIT.java | 77 ++++
iotdb-client/client-cpp/src/main/ColumnDecoder.cpp | 3 +
iotdb-client/client-cpp/src/main/Common.cpp | 20 +-
iotdb-client/client-cpp/src/main/TsBlock.cpp | 12 +
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 7 +
.../tests/integration/test_treemodel_insert.py | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../async/handlers/rpc/PipePushMetaRPCHandler.java | 6 +-
.../client/sync/SyncDataNodeClientPool.java | 3 +-
.../confignode/conf/ConfigNodeDescriptor.java | 15 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../write/table/AlterColumnDataTypePlan.java | 4 -
...pePlan.java => PreAlterColumnDataTypePlan.java} | 15 +-
.../iotdb/confignode/manager/ConfigManager.java | 6 +-
.../iotdb/confignode/manager/ProcedureManager.java | 22 +-
.../iotdb/confignode/manager/UDFManager.java | 3 +
.../manager/consensus/ConsensusManager.java | 19 +
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../manager/schema/ClusterSchemaManager.java | 8 +-
.../iotdb/confignode/persistence/UDFInfo.java | 11 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/pipe/PipePluginInfo.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 10 +-
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../DataPartitionTableIntegrityCheckProcedure.java | 4 +-
.../table/AlterTableColumnDataTypeProcedure.java | 11 +-
.../schema/table/RenameTableColumnProcedure.java | 4 +-
.../schema/table/SetTablePropertiesProcedure.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 66 +--
.../request/ConfigPhysicalPlanSerDeTest.java | 19 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 28 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 5 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 57 ++-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 58 ++-
...istoricalDataRegionTsFileAndDeletionSource.java | 87 +++-
.../PipeRealtimeDataRegionHybridSource.java | 9 +-
.../realtime/PipeRealtimeDataRegionSource.java | 16 +-
.../PipeRealtimeDataRegionTsFileSource.java | 7 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 1 +
.../PipeTsFileEpochProgressIndexKeeper.java | 78 +++-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 101 +++--
.../impl/DataNodeInternalRPCServiceImpl.java | 14 +-
.../db/queryengine/common/MPPQueryContext.java | 2 +-
.../execution/exchange/sink/SinkChannel.java | 2 +-
.../queryengine/execution/memory/MemoryPool.java | 21 -
.../db/queryengine/plan/analyze/Analysis.java | 2 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 28 +-
.../db/queryengine/plan/analyze/QueryType.java | 1 +
.../queryengine/plan/execution/QueryExecution.java | 6 +-
.../plan/execution/config/ConfigExecution.java | 6 +-
.../execution/config/TableConfigTaskVisitor.java | 104 ++---
.../config/executor/ClusterConfigTaskExecutor.java | 7 +-
.../relational/RelationalAuthorizerTask.java | 3 +-
.../plan/execution/config/sys/AuthorizerTask.java | 3 +-
.../plan/parser/StatementGenerator.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 4 +-
.../plan/relational/analyzer/Analysis.java | 13 +-
.../relational/analyzer/StatementAnalyzer.java | 11 +-
.../function/tvf/PatternMatchTableFunction.java | 9 +
.../function/tvf/match/model/MatchState.java | 16 +-
.../function/tvf/match/model/RegexMatchState.java | 34 +-
.../plan/relational/planner/IrTypeAnalyzer.java | 13 +
.../relational/planner/LiteralInterpreter.java | 7 +
.../plan/relational/planner/RelationPlanner.java | 1 +
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/RelationalAuthorStatement.java | 2 +-
.../relational/sql/ast/TableExpressionType.java | 3 +-
...ecimalLiteral.java => TimeDurationLiteral.java} | 61 ++-
.../plan/relational/sql/parser/AstBuilder.java | 13 +-
.../relational/sql/util/ExpressionFormatter.java | 6 +
.../plan/scheduler/ClusterScheduler.java | 6 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 4 +-
.../metadata/AlterEncodingCompressorStatement.java | 2 +-
.../metadata/AlterTimeSeriesDataTypeStatement.java | 2 +-
.../metadata/CreateContinuousQueryStatement.java | 2 +-
.../metadata/CreateFunctionStatement.java | 2 +-
.../statement/metadata/CreateTriggerStatement.java | 2 +-
.../metadata/DatabaseSchemaStatement.java | 2 +-
.../metadata/DeleteDatabaseStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 2 +-
.../metadata/DropContinuousQueryStatement.java | 2 +-
.../statement/metadata/DropFunctionStatement.java | 2 +-
.../statement/metadata/DropTriggerStatement.java | 2 +-
.../statement/metadata/RemoveAINodeStatement.java | 2 +-
.../metadata/RemoveConfigNodeStatement.java | 2 +-
.../metadata/RemoveDataNodeStatement.java | 2 +-
.../plan/statement/metadata/SetTTLStatement.java | 2 +-
.../CreateExternalServiceStatement.java | 2 +-
.../DropExternalServiceStatement.java | 2 +-
.../StartExternalServiceStatement.java | 2 +-
.../StopExternalServiceStatement.java | 2 +-
.../metadata/model/CreateModelStatement.java | 2 +-
.../metadata/model/CreateTrainingStatement.java | 2 +-
.../metadata/model/DropModelStatement.java | 2 +-
.../metadata/model/LoadModelStatement.java | 2 +-
.../metadata/model/UnloadModelStatement.java | 2 +-
.../metadata/pipe/AlterPipeStatement.java | 2 +-
.../metadata/pipe/CreatePipePluginStatement.java | 2 +-
.../metadata/pipe/CreatePipeStatement.java | 2 +-
.../metadata/pipe/DropPipePluginStatement.java | 2 +-
.../statement/metadata/pipe/DropPipeStatement.java | 2 +-
.../metadata/pipe/StartPipeStatement.java | 2 +-
.../statement/metadata/pipe/StopPipeStatement.java | 2 +-
.../metadata/region/ExtendRegionStatement.java | 2 +-
.../metadata/region/MigrateRegionStatement.java | 2 +-
.../region/ReconstructRegionStatement.java | 2 +-
.../metadata/region/RemoveRegionStatement.java | 2 +-
.../subscription/CreateTopicStatement.java | 2 +-
.../subscription/DropSubscriptionStatement.java | 2 +-
.../metadata/subscription/DropTopicStatement.java | 2 +-
.../template/AlterSchemaTemplateStatement.java | 2 +-
.../template/CreateSchemaTemplateStatement.java | 2 +-
.../template/DeactivateTemplateStatement.java | 2 +-
.../template/DropSchemaTemplateStatement.java | 2 +-
.../template/SetSchemaTemplateStatement.java | 2 +-
.../template/UnsetSchemaTemplateStatement.java | 2 +-
.../metadata/view/AlterLogicalViewStatement.java | 2 +-
.../metadata/view/DeleteLogicalViewStatement.java | 2 +-
.../metadata/view/RenameLogicalViewStatement.java | 2 +-
.../plan/statement/sys/AuthorStatement.java | 2 +-
.../plan/statement/sys/ClearCacheStatement.java | 2 +-
.../plan/statement/sys/FlushStatement.java | 2 +-
.../plan/statement/sys/KillQueryStatement.java | 2 +-
.../statement/sys/LoadConfigurationStatement.java | 2 +-
.../plan/statement/sys/MergeStatement.java | 2 +-
.../statement/sys/SetConfigurationStatement.java | 2 +-
.../plan/statement/sys/SetSqlDialectStatement.java | 2 +-
.../statement/sys/SetSystemStatusStatement.java | 2 +-
.../statement/sys/StartRepairDataStatement.java | 2 +-
.../statement/sys/StopRepairDataStatement.java | 2 +-
.../sys/quota/SetSpaceQuotaStatement.java | 2 +-
.../sys/quota/SetThrottleQuotaStatement.java | 2 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 3 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 5 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 5 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 6 +-
.../iotdb/db/service/metrics/ProcessMetrics.java | 113 ++++-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../compaction/execute/utils/CompactionUtils.java | 24 +-
.../schedule/CompactionScheduleTaskManager.java | 9 +
.../schedule/CompactionScheduleTaskWorker.java | 21 +-
.../compaction/schedule/TTLScheduleTask.java | 17 +-
.../pipe/event/PipeTsFileInsertionEventTest.java | 99 +++++
...ricalDataRegionTsFileAndDeletionSourceTest.java | 174 ++++++++
.../PipeTsFileEpochProgressIndexKeeperTest.java | 117 +++++
.../queryengine/execution/ConfigExecutionTest.java | 2 +-
.../execution/exchange/LocalSinkChannelTest.java | 10 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 11 +-
.../execution/exchange/ShuffleSinkHandleTest.java | 5 +-
.../execution/exchange/SourceHandleTest.java | 5 +-
.../db/queryengine/execution/exchange/Utils.java | 26 +-
.../execution/memory/MemoryPoolTest.java | 51 ++-
.../statement/sys/pipe/PipeStatementTest.java | 8 +-
.../analyzer/NeedSetHighestPriorityTest.java | 56 +++
.../plan/relational/planner/PlanTester.java | 4 +
.../src/main/thrift/datanode.thrift | 2 +-
178 files changed, 2534 insertions(+), 565 deletions(-)
create mode 100644 .claude/settings.json
create mode 100644 CLAUDE.md
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{AlterColumnDataTypePlan.java
=> PreAlterColumnDataTypePlan.java} (81%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DecimalLiteral.java
=> TimeDurationLiteral.java} (67%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSourceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeTsFileEpochProgressIndexKeeperTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/NeedSetHighestPriorityTest.java
