This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch calc_commons
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 127e6fa7021 rename package
add cca9dbbf0b4 fix the clear logic of specified info of one operator when
print plan in explain analyze (#17454)
add 1c1cbca7760 fix (#17455)
add d245edce685 Fix NPE in table model export when -q is not specified
(#17462)
add 609d28ba645 fix the binary function: from_base64, from_base32 (#17466)
add eaa2c387cab Load balance service patch (#17463)
add 300987c7cd2 Remove password history feature in iotdb. (#17436)
add 5c036db1cc3 Update release information after 2.0.8 released (#17468)
add e4ae2537558 Subscription: add removeUserData for messages (#17460)
add 5b642dff869 Repair the problem named ClassCastException cause by CN
resend rpc request frequently after one of DNs in the cluster is down up
(#17461)
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 89c2af83e2a Cancel that submit the
DataPartitionTableIntegrityCheckProcedure when ConfigNode start up. (#17506)
add 90c540cf937 Fast schema partition fetch for single device query
(#17493)
add 2304ae75d54 Remove the error log for password validation failure.
(#17509)
add aa4b551befb Fix Integer overflow when converting 604800000000000ms to
-3942554432415203328ns (#17511)
add 07e2cfb63f4 fix(tvf): validate non-negative width and height in
pattern_match (#17515)
add a7ca099aa33 Pipe: Fixed the potential NPE of concurrent user deletion
(#17499)
add b49c2f43e60 Show pipe plugin loading errors in plugin listing (#17487)
add a3c451e6be7 Pipe: Fixed the OPC UA bug that drop pipe may not erase
the client (#17510)
add 335048c752a Banned the tree model database in table model SQLs &&
Pipe: Upgraded bouncy castle && Added logs for pipe tsFile parser (#17504)
add ce103a333d5 Fixed db parameter in data import (#17521)
add 4cd24c1856a Merge branch 'iotdb_master' into calc_commons
No new revisions were added by this update.
Summary of changes:
.claude/settings.json | 17 +
.gitignore | 8 +-
CLAUDE.md | 180 ++++++++
NOTICE | 2 +-
NOTICE-binary | 2 +-
RELEASE_NOTES.md | 28 ++
.../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 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 6 +-
.../it/partition/IoTDBPartitionGetterIT.java | 3 +-
.../confignode/it/procedure/IoTDBProcedureIT.java | 3 +-
...IoTDBRegionOperationReliabilityITFramework.java | 2 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 6 +-
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 2 +-
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 483 +++++++++++++++++++++
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 105 -----
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 2 +-
.../iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java | 2 +-
.../IoTDBExplainAnalyzePrintIT.java} | 96 ++--
.../iotdb/db/it/query/IoTDBFilteredRowsIT.java | 1 -
.../iotdb/db/it/schema/IoTDBDeleteDatabaseIT.java | 3 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 8 +-
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 2 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 4 +-
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 2 -
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 101 +++++
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 36 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 6 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 17 +
.../it/db/it/IoTDBSetConfigurationTableIT.java | 14 +
.../relational/it/db/it/IoTDBWindowTVFIT.java | 34 ++
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 8 +-
.../relational/it/query/recent/IoTDBCteIT.java | 6 +-
.../scalar/IoTDBFromBase32ColumnFunctionIT.java | 4 +
.../scalar/IoTDBFromBase64ColumnFunctionIT.java | 12 +-
.../relational/it/rest/it/IoTDBRestServiceIT.java | 18 +
.../relational/it/schema/IoTDBDatabaseIT.java | 12 +-
.../iotdb/session/it/IoTDBSessionQueryIT.java | 77 ++++
.../it/local/IoTDBSubscriptionMessageIT.java | 186 ++++++++
.../pipe-count-point-processor-example.jar | Bin 0 -> 9446 bytes
.../org/apache/iotdb/tool/common/OptionsUtil.java | 32 +-
.../org/apache/iotdb/tool/data/ExportData.java | 28 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 37 +-
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 +
.../base/AbstractSubscriptionConsumer.java | 51 ++-
.../base/AbstractSubscriptionPullConsumer.java | 29 +-
.../subscription/payload/SubscriptionMessage.java | 23 +
.../payload/SubscriptionMessageHandler.java | 5 +-
.../payload/SubscriptionRecordHandler.java | 45 +-
.../scalar/factory/CodecStrategiesFactory.java | 7 +-
.../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 +-
.../response/pipe/plugin/PipePluginTableResp.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 6 +-
.../iotdb/confignode/manager/ProcedureManager.java | 22 +-
.../iotdb/confignode/manager/UDFManager.java | 3 +
.../manager/consensus/ConsensusManager.java | 19 +
.../manager/load/service/EventService.java | 5 +
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../manager/schema/ClusterSchemaManager.java | 8 +-
.../iotdb/confignode/persistence/UDFInfo.java | 11 +-
.../persistence/auth/AuthorPlanExecutor.java | 1 -
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/pipe/PipePluginInfo.java | 138 ++++--
.../persistence/schema/ClusterSchemaInfo.java | 10 +-
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../DataPartitionTableIntegrityCheckProcedure.java | 104 ++++-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 19 +-
.../table/AlterTableColumnDataTypeProcedure.java | 11 +-
.../schema/table/RenameTableColumnProcedure.java | 4 +-
.../schema/table/SetTablePropertiesProcedure.java | 4 +-
.../AbstractOperateSubscriptionProcedure.java | 1 +
.../iotdb/confignode/service/ConfigNode.java | 55 +--
.../request/ConfigPhysicalPlanSerDeTest.java | 19 +
.../response/pipe/PipePluginTableRespTest.java | 2 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 1 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 4 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 23 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 28 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 25 ++
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 20 +-
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 5 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 57 ++-
.../tsfile/parser/TsFileInsertionEventParser.java | 17 +-
.../query/TsFileInsertionEventQueryParser.java | 4 +-
.../scan/TsFileInsertionEventScanParser.java | 4 +-
.../table/TsFileInsertionEventTableParser.java | 4 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 58 ++-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 9 -
.../visitor/PipeStatementTSStatusVisitor.java | 30 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 56 ++-
...istoricalDataRegionTsFileAndDeletionSource.java | 87 +++-
.../PipeRealtimeDataRegionHybridSource.java | 9 +-
.../realtime/PipeRealtimeDataRegionSource.java | 16 +-
.../PipeRealtimeDataRegionTsFileSource.java | 7 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 1 +
.../PipeTsFileEpochProgressIndexKeeper.java | 78 +++-
.../iotdb/db/protocol/session/IClientSession.java | 11 +
.../iotdb/db/protocol/session/SessionManager.java | 52 ---
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 101 +++--
.../impl/DataNodeInternalRPCServiceImpl.java | 14 +-
.../db/queryengine/common/MPPQueryContext.java | 2 +-
.../fragment/FragmentInstanceExecution.java | 1 -
.../InformationSchemaContentSupplierFactory.java | 8 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 28 +-
.../plan/analyze/ClusterPartitionFetcher.java | 30 +-
.../db/queryengine/plan/analyze/QueryType.java | 1 +
.../queryengine/plan/execution/QueryExecution.java | 6 +-
.../plan/execution/config/ConfigExecution.java | 6 +-
.../execution/config/TableConfigTaskVisitor.java | 111 +++--
.../execution/config/TreeConfigTaskVisitor.java | 18 +-
.../config/executor/ClusterConfigTaskExecutor.java | 7 +-
.../config/metadata/ShowPipePluginsTask.java | 10 +-
.../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 +-
.../plan/relational/planner/IrTypeAnalyzer.java | 13 +
.../relational/planner/LiteralInterpreter.java | 7 +
.../plan/relational/planner/RelationPlanner.java | 1 +
.../sql/ast/RelationalAuthorStatement.java | 53 +--
.../plan/relational/sql/parser/AstBuilder.java | 21 +-
.../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 | 53 +--
.../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 +-
.../statistics/SpecifiedInfoMergerFactory.java | 13 +
.../statistics/StatisticsMergeUtil.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 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 370 ----------------
.../pipe/event/PipeTsFileInsertionEventTest.java | 99 +++++
...ricalDataRegionTsFileAndDeletionSourceTest.java | 174 ++++++++
.../PipeTsFileEpochProgressIndexKeeperTest.java | 117 +++++
.../queryengine/execution/ConfigExecutionTest.java | 2 +-
.../statement/sys/pipe/PipeStatementTest.java | 8 +-
.../analyzer/NeedSetHighestPriorityTest.java | 56 +++
.../plan/relational/planner/PlanTester.java | 4 +
.../apache/iotdb/commons/conf/CommonConfig.java | 27 --
.../commons/partition/SeriesPartitionTable.java | 14 +-
.../plugin/constructor/PipePluginConstructor.java | 8 +
.../pipe/agent/plugin/meta/PipePluginMeta.java | 45 +-
.../function/tvf/PatternMatchTableFunction.java | 17 +
.../function/tvf/match/model/MatchState.java | 16 +-
.../function/tvf/match/model/RegexMatchState.java | 34 +-
.../relational/sql/ast/CommonQueryAstVisitor.java | 4 +
.../relational/sql/ast/TableExpressionType.java | 3 +-
...ecimalLiteral.java => TimeDurationLiteral.java} | 61 ++-
.../relational/sql/util/ExpressionFormatter.java | 6 +
.../schema/column/ColumnHeaderConstant.java | 3 +-
.../commons/schema/table/InformationSchema.java | 3 +
iotdb-doap.rdf | 8 +
.../src/main/thrift/datanode.thrift | 2 +-
pom.xml | 2 +-
243 files changed, 3560 insertions(+), 1546 deletions(-)
create mode 100644 .claude/settings.json
create mode 100644 CLAUDE.md
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBFileTimeIndexIT.java
=> query/IoTDBExplainAnalyzePrintIT.java} (52%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionMessageIT.java
create mode 100644
integration-test/src/test/resources/pipe-count-point-processor-example.jar
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{AlterColumnDataTypePlan.java
=> PreAlterColumnDataTypePlan.java} (81%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/DataNodeAuthUtils.java
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
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/relational/sql/ast/{DecimalLiteral.java
=> TimeDurationLiteral.java} (66%)
