This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/support_schema_evolution
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from dbe1661921e spotless
add 749d5f5e13c Fix delete NPE after insert failed (#17122)
add 30b3de6fcc0 Subscription: Optimized the performance (#17121)
add b6c7300aa0c Load: Fixed the bug that active load may fail for table
model (#17124)
add d703886e2c8 [Bug fix] The partition table is cleaned incorrectly when
set only device TTL for tree mode (#17123)
add 8455b8c4c1f Optimize TsTable with Copy-on-Write pattern for
thread-safe concurrent access (#17069)
add 8488a64cab4 [AINode] Integrate moirai2 as builtin forecasting model
(#17056)
add 2d07d8afc2a Security fix: Bump Jetty to 9.4.58.v20250814
(CVE-2025-5115) (#17136)
add f445132b2ee Fix blob accumulator query can't skip read blobStatistics
caused by isModified don't change to true in the metadata of chunk and
pageReader (#17127)
add 0650a6a3456 Fix value and time chunk misalignment when rewriting with
time deletion (#17142)
add 2146a080230 fix: Fix ShowTimeseries estimated offset without limit
scenario (#17116)
add e4ef4db9a69 fix the problem that cast a float point number to float
type, by adding the floatLiteral (#17143)
add c05e9cba78d Merge branch 'master' into
force_ci/support_schema_evolution
No new revisions were added by this update.
Summary of changes:
LICENSE | 12 +-
LICENSE-binary | 12 +-
.../it/env/cluster/config/MppCommonConfig.java | 5 -
.../env/cluster/config/MppSharedCommonConfig.java | 6 -
.../it/env/remote/config/RemoteCommonConfig.java | 5 -
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 -
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 4 +-
.../partition/IoTDBPartitionTableAutoCleanIT.java | 57 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 25 +
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 244 ++++
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 1399 +++++++++++++++-----
.../recent/scalar/IoTDBCastLiteralFunctionIT.java | 146 ++
.../it/schema/IoTDBAlterColumnTypeIT.java | 805 +++++++----
.../relational/it/schema/IoTDBDatabaseIT.java | 8 -
.../it/cluster/IoTDBSubscriptionRestartIT.java | 7 +-
.../it/dual/AbstractSubscriptionDualIT.java | 3 -
.../dual/tablemodel/IoTDBSubscriptionTopicIT.java | 7 +
.../IoTDBSubscriptionConsumerGroupIT.java | 57 +
.../IoTDBSubscriptionTimePrecisionIT.java | 2 +
.../dual/treemodel/IoTDBSubscriptionTopicIT.java | 14 +
.../it/local/AbstractSubscriptionLocalIT.java | 1 -
.../it/local/IoTDBSubscriptionBasicIT.java | 8 +
.../it/local/IoTDBSubscriptionDataTypeIT.java | 21 +
.../it/local/IoTDBSubscriptionIdempotentIT.java | 4 +
.../it/local/IoTDBSubscriptionTopicIT.java | 5 +
.../tablemodel/IoTDBSubscriptionIsolationIT.java | 3 +
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 5 +
.../it/triple/AbstractSubscriptionTripleIT.java | 5 -
.../treemodel/IoTDBSubscriptionSharingIT.java | 2 +
.../IoTDBDefaultPullConsumerDataSetIT.java | 2 +
.../IoTDBDefaultTsfilePushConsumerIT.java | 2 +
.../IoTDBRootDatasetPushConsumerIT.java | 2 +
.../IoTDBRootPullConsumeTsfileIT.java | 2 +
...merPullConsumerWith1TopicShareProcessMixIT.java | 2 +
.../param/IoTDBTestParamPullConsumerIT.java | 26 +
.../param/IoTDBTestParamPushConsumerIT.java | 19 +
.../param/IoTDBTestParamSubscriptionSessionIT.java | 6 +
.../regression/param/IoTDBTestParamTopicIT.java | 20 +
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 2 +
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 2 +
.../format/IoTDBDBDataSetPullConsumerIT.java | 2 +
.../format/IoTDBDBTsfilePullConsumerIT.java | 2 +
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 2 +
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 2 +
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 2 +
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 2 +
.../IoTDBDBPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 2 +
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 2 +
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 2 +
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 2 +
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBRootPatternPullConsumeTsfileIT.java | 2 +
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 +
.../IoTDBTSPatternPullConsumerDataSetIT.java | 2 +
.../time/IoTDBAllPullConsumerDataSetIT.java | 2 +
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 2 +
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 2 +
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 2 +
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 2 +
.../format/IoTDBTestPushConsumeDataSetIT.java | 2 +
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 2 +
.../format/IoTDBTestPushConsumeTsfileIT.java | 2 +
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 2 +
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 2 +
.../IoTDBLooseAllTsfilePushConsumerIT.java | 2 +
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 2 +
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +
.../IoTDBPathLooseTsfilePushConsumerIT.java | 2 +
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 2 +
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 2 +
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 2 +
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 2 +
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +
.../IoTDBDBPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBDBPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 2 +
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 2 +
.../IoTDBRootPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBTSPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 2 +
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 2 +
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 2 +
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 2 +
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 2 +
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 2 +
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 2 +
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 2 +
.../regression/topic/IoTDBTestTopicNameIT.java | 2 +
.../regression/user/IoTDBOtherUserConsumerIT.java | 8 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 3 +-
.../pool_scheduler/basic_pool_scheduler.py | 9 +
.../ainode/core/model/chronos2/chronos_bolt.py | 2 +-
.../ainode/iotdb/ainode/core/model/model_info.py | 13 +
.../ainode/iotdb/ainode/core/model/model_loader.py | 7 +-
.../iotdb/ainode/core/model/moirai2/__init__.py | 16 +-
.../ainode/core/model/moirai2/common}/__init__.py | 0
.../ainode/core/model/moirai2/common/torch_util.py | 130 ++
.../core/model/moirai2/configuration_moirai2.py | 61 +
.../ainode/core/model/moirai2/modeling_moirai2.py | 1352 +++++++++++++++++++
.../ainode/core/model/moirai2/module}/__init__.py | 0
.../ainode/core/model/moirai2/module/attention.py | 366 +++++
.../iotdb/ainode/core/model/moirai2/module/ffn.py | 159 +++
.../iotdb/ainode/core/model/moirai2/module/norm.py | 62 +
.../core/model/moirai2/module/packed_scaler.py | 125 ++
.../model/moirai2/module/position}/__init__.py | 34 +-
.../core/model/moirai2/module/position/additive.py | 81 ++
.../model/moirai2/module/position/attn_bias.py | 113 ++
.../moirai2/module/position/attn_projection.py | 215 +++
.../core/model/moirai2/module/transformer.py | 246 ++++
.../ainode/core/model/moirai2/module/ts_embed.py | 294 ++++
.../ainode/core/model/moirai2/pipeline_moirai2.py | 169 +++
.../core/model/moirai2/transform}/__init__.py | 0
.../ainode/core/model/moirai2/transform/_base.py | 71 +
.../ainode/core/model/moirai2/transform/_mixin.py | 126 ++
.../core/model/moirai2/transform/imputation.py | 133 ++
iotdb-core/ainode/pyproject.toml | 1 +
.../iotdb/confignode/manager/TTLManager.java | 14 +
.../iotdb/confignode/persistence/TTLInfo.java | 17 +
.../procedure/PartitionTableAutoCleaner.java | 18 +-
.../process/rowpattern/expression/Computation.java | 4 +
.../execution/operator/source/FileLoaderUtils.java | 8 +-
.../execution/operator/source/SeriesScanUtil.java | 8 +-
.../relational/ColumnTransformerBuilder.java | 32 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 6 +-
.../plan/planner/LogicalPlanVisitor.java | 17 +-
.../planner/plan/node/load/LoadTsFileNode.java | 2 +-
.../relational/analyzer/ExpressionAnalyzer.java | 8 +
.../predicate/ConvertPredicateToFilterVisitor.java | 29 +-
.../PredicatePushIntoMetadataChecker.java | 6 +
.../planner/CastToBlobLiteralVisitor.java | 6 +
.../planner/CastToBooleanLiteralVisitor.java | 6 +
.../planner/CastToDateLiteralVisitor.java | 6 +
.../planner/CastToDoubleLiteralVisitor.java | 6 +
.../planner/CastToFloatLiteralVisitor.java | 6 +
.../planner/CastToInt32LiteralVisitor.java | 6 +
.../planner/CastToInt64LiteralVisitor.java | 6 +
.../planner/CastToStringLiteralVisitor.java | 6 +
.../planner/CastToTimestampLiteralVisitor.java | 6 +
.../plan/relational/planner/IrTypeAnalyzer.java | 7 +
.../plan/relational/planner/LiteralEncoder.java | 7 +-
.../relational/planner/LiteralInterpreter.java | 7 +
...ithUncorrelatedScalarSubqueryReconstructor.java | 3 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../plan/relational/sql/ast/Expression.java | 3 +
.../ast/{DoubleLiteral.java => FloatLiteral.java} | 54 +-
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../relational/sql/util/ExpressionFormatter.java | 9 +
.../plan/statement/crud/LoadTsFileStatement.java | 9 +
.../impl/SchemaReaderLimitOffsetWrapper.java | 2 +-
.../db/schemaengine/table/DataNodeTableCache.java | 8 +-
.../db/storageengine/dataregion/DataRegion.java | 5 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 56 +-
.../planner/assertions/ExpressionVerifier.java | 14 +
.../compaction/CompactionDataTypeAlterTest.java | 55 +
.../apache/iotdb/commons/conf/CommonConfig.java | 8 -
.../iotdb/commons/conf/CommonDescriptor.java | 5 -
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 29 +
.../subscription/config/SubscriptionConfig.java | 4 +-
pom.xml | 4 +-
183 files changed, 6712 insertions(+), 706 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBCastLiteralFunctionIT.java
copy docker/src/main/DockerCompose/start-1c1d.sh =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/__init__.py (78%)
mode change 100755 => 100644
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/common}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/common/torch_util.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/configuration_moirai2.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/modeling_moirai2.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/attention.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/ffn.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/norm.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/packed_scaler.py
copy {iotdb-client/client-py/iotdb/dbapi =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/position}/__init__.py
(55%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/position/additive.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/position/attn_bias.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/position/attn_projection.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/transformer.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/ts_embed.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/pipeline_moirai2.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/transform}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/transform/_base.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/transform/_mixin.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/transform/imputation.py
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DoubleLiteral.java
=> FloatLiteral.java} (67%)
