This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch run-ci-mod
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 546aafd71ef sia
add e48272a8ae6 Pipe: Fixed the log of disruptor queue & deleted the
useless binary buffer (#17341)
add 355a872cfae Pipe: Fixed the bug that separated historical pipe may not
include mod on deletion & The pipe without data.insert may be wrongly separated
by pipe and transfer data (#17346)
add c8455c142b7 Add extra client_ip and timeout columns for show queries
(#17350)
add 55611f1b7bb Fixed the default string charset in CI (#17354)
add 6c8e1d5dd47 Pipe: Fixed the on committed hook square bug & Trimmed the
raw tablet hook & Fixed the premature report for source event & Skipped the
parsing of time-covered tsFile (#17360)
add fd3726f384a Avoid to roll back the state imminently and resolve the
NoSuchElementException (#17363)
add 58ec38a371d Enhance approx_percentile with strict weight validation,
improved error handling and IT coverage (#17368)
add 3b02d322735 Fix underflow exception caused by serialize function of
DataPartitionTableIntegrityCheckProcedure (#17369)
add 4dbda78d74f Added database check for flush on local & Optimized the
UTF-8 param in IT (#17365)
add 8515441b6f3 Pipe: Further reduced the repeating pipe logs (#17366)
add d1ae3ce1a2e Add IT for DELETE TIMESERIES replica consistency under
IoTConsensusV2 (#17332)
add 83addf9871a Set both JAVA_HOME and PATH environment for
daemon-services (#17370)
add 5095862f75f [AINode]: Integrate toto as a builtin forecasting model
(#17322)
add bb68d508629 Fix kill query doesn't take effect bug (#17358)
add 32f1010942e Clean up tmp dirs of udf and sort while starting up
(#17377)
add cffaaee5c4a Merge branch 'master' of https://github.com/apache/iotdb
into run-ci-mod
No new revisions were added by this update.
Summary of changes:
NOTICE | 9 +
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 9 +
.../IoTDBIoTConsensusV23C3DBasicITBase.java | 210 +++++++++-
.../batch/IoTDBIoTConsensusV2Batch3C3DBasicIT.java | 6 +
.../IoTDBIoTConsensusV2Stream3C3DBasicIT.java | 6 +
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 54 ++-
.../it/query/recent/IoTDBMaintainAuthIT.java | 12 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 24 ++
.../relational/it/schema/IoTDBDatabaseIT.java | 8 +-
iotdb-core/ainode/build_binary.py | 8 +-
.../ainode/iotdb/ainode/core/model/model_info.py | 13 +
.../iotdb/ainode/core/model/toto}/__init__.py | 0
.../ainode/core/model/toto/configuration_toto.py | 78 ++++
.../iotdb/ainode/core/model/toto/data}/__init__.py | 3 +
.../ainode/core/model/toto/data/util}/__init__.py | 3 +
.../ainode/core/model/toto/data/util/dataset.py | 127 ++++++
.../ainode/core/model/toto/inference}/__init__.py | 3 +
.../ainode/core/model/toto/inference/forecaster.py | 452 +++++++++++++++++++++
.../ainode/core/model/toto/model}/__init__.py | 3 +
.../ainode/core/model/toto/model/attention.py | 276 +++++++++++++
.../iotdb/ainode/core/model/toto/model/backbone.py | 258 ++++++++++++
.../ainode/core/model/toto/model/distribution.py | 112 +++++
.../ainode/core/model/toto/model/embedding.py | 83 ++++
.../toto/model/feed_forward.py} | 28 +-
.../iotdb/ainode/core/model/toto/model/fusion.py | 58 +++
.../iotdb/ainode/core/model/toto/model/rope.py | 94 +++++
.../iotdb/ainode/core/model/toto/model/scaler.py | 328 +++++++++++++++
.../iotdb/ainode/core/model/toto/model/toto.py | 157 +++++++
.../ainode/core/model/toto/model/transformer.py | 318 +++++++++++++++
.../iotdb/ainode/core/model/toto/model/util.py | 251 ++++++++++++
.../iotdb/ainode/core/model/toto/modeling_toto.py | 167 ++++++++
.../iotdb/ainode/core/model/toto/pipeline_toto.py | 144 +++++++
iotdb-core/ainode/pyproject.toml | 1 +
.../DataPartitionTableIntegrityCheckProcedure.java | 90 +++-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +-
...aPartitionTableIntegrityCheckProcedureTest.java | 149 +++++++
.../dataregion/DataExecutionVisitor.java | 14 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 7 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 16 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 33 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 11 +
.../protocol/thrift/IoTDBDataNodeReceiver.java | 19 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 11 +-
.../request/PipeTransferTabletBatchReq.java | 55 +--
.../request/PipeTransferTabletBatchReqV2.java | 75 +---
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 19 +-
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 13 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 20 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 16 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 6 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 17 +-
.../sink/protocol/writeback/WriteBackSink.java | 14 +-
.../realtime/assigner/DisruptorQueue.java | 2 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 27 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 5 +-
.../db/queryengine/common/MPPQueryContext.java | 17 +-
.../queryengine/execution/QueryStateMachine.java | 4 +-
.../fragment/FragmentInstanceManager.java | 2 +
.../operator/source/ShowQueriesOperator.java | 4 +
.../InformationSchemaContentSupplierFactory.java | 3 +
.../ApproxPercentileWithWeightAccumulator.java | 50 +++
...oupedApproxPercentileWithWeightAccumulator.java | 49 +++
.../iotdb/db/queryengine/plan/Coordinator.java | 34 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 43 +-
.../plan/execution/IQueryExecution.java | 28 +-
.../queryengine/plan/execution/QueryExecution.java | 106 +++--
.../plan/execution/config/ConfigExecution.java | 32 +-
.../config/executor/ClusterConfigTaskExecutor.java | 55 ++-
.../planner/plan/node/source/ShowQueriesNode.java | 12 +-
.../relational/metadata/TableMetadataImpl.java | 21 +-
.../plan/relational/sql/parser/AstBuilder.java | 6 +-
.../plan/scheduler/AsyncPlanNodeSender.java | 14 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 12 +
.../db/service/TemporaryQueryDataFileService.java | 20 +-
.../iotdb/db/storageengine/StorageEngine.java | 31 +-
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 25 +-
.../operator/MergeTreeSortOperatorTest.java | 16 +-
.../planner/informationschema/ShowQueriesTest.java | 13 +-
.../commons/executable/ExecutableManager.java | 4 +-
.../task/progress/interval/PipeCommitInterval.java | 3 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 9 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 1 +
.../schema/column/ColumnHeaderConstant.java | 12 +-
.../commons/schema/table/InformationSchema.java | 7 +
scripts/tools/ops/daemon-confignode.sh | 34 +-
scripts/tools/ops/daemon-datanode.sh | 34 +-
87 files changed, 4158 insertions(+), 475 deletions(-)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/toto}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/configuration_toto.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/toto/data}/__init__.py (83%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/toto/data/util}/__init__.py (83%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/data/util/dataset.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/toto/inference}/__init__.py (83%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/inference/forecaster.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/toto/model}/__init__.py (83%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/model/attention.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/model/backbone.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/model/distribution.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/model/embedding.py
copy iotdb-core/ainode/iotdb/ainode/core/{device/backend/cpu_backend.py =>
model/toto/model/feed_forward.py} (60%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/model/fusion.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/toto/model/rope.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/model/scaler.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/toto/model/toto.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/model/transformer.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/toto/model/util.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/modeling_toto.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/toto/pipeline_toto.py
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/partition/DataPartitionTableIntegrityCheckProcedureTest.java
