This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch strong_password
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from cab0ac53050 fix tests
add 65b18ff9e3e Pipe: prevent historical extractor from forwarding TsFiles
generated by pipe when isForwardingPipeRequests is false (#15845)
add f8e24dc71eb Feature/retry on disk failure (#15676)
add 5ef583cfe67 Disable the parameter
'ALLOW_ZERO-BYTE_CITE_SIDED_PROPERTY1 NAME' and fix null pointer exception
(#15866)
add b04cd468c5a [AINode] Fix built-in model inference & support user
parameters (#15868)
add baa9e1ac005 [AINode] IoTDBTreeModelDataset bug fix (#15869)
add d2a040003f3 Don't print exception stack for 719
add b4045de6eb2 Bump ratis to 3.2.0 (#15825)
add f2f00501a5e Pipe: Added rate limiter for tsFile sending (#15765)
add 1a035c4b8de Print measurement for putting buffer exceptions (#15873)
add ad8bedc1d50 Bump ratis to 3.2.1 (#15871)
add a184469ada3 When querying the lastest point of alias view and normal
series at the same time, points may be lost due to overwriting
add 7800de6ad0d Correct the memroy calculation of BinaryColumnBuilder
add c5009f3ad61 Fix dead lock when take snapshot for Trigger and UDF
add 4cc6085e35c Pipe: Fix the error of Client object returning to object
pool after file transfer is completed (#15883)
add acaa72d703b Try delete sort tmp after driver is closed
add 57f22e770b1 [AINode] Fix the bug that the built-in model be deleted
(#15888)
add a10e2132d80 Fixed the NPE caused by view permission check
add 0a0ec3fb176 [AINode] Fix model management bugs (#15890)
add 966cfc73348 Change ErrorCode from 305 to 701 if there is no from clause
new 5c004404ec7 Merge branch 'master' into strong_password
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
dependencies.json | 14 +--
...reamIT.java => IoTDBConfigNodeSnapshot2IT.java} | 29 ++----
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 5 +-
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 8 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 16 +++
.../java/org/apache/iotdb/session/Session.java | 17 ++--
.../apache/iotdb/session/util/SessionUtils.java | 105 +++++++++++---------
.../iotdb/session/util/SessionUtilsTest.java | 26 ++++-
iotdb-core/ainode/ainode/core/config.py | 3 +-
iotdb-core/ainode/ainode/core/constant.py | 3 +
iotdb-core/ainode/ainode/core/exception.py | 5 +
iotdb-core/ainode/ainode/core/handler.py | 5 +-
iotdb-core/ainode/ainode/core/ingress/iotdb.py | 1 +
.../ainode/core/manager/inference_manager.py | 27 +++---
.../ainode/ainode/core/manager/model_manager.py | 19 ++--
.../ainode/core/model/built_in_model_factory.py | 10 +-
.../ainode/ainode/core/model/model_storage.py | 108 +++++++++++++++------
iotdb-core/confignode/pom.xml | 2 +-
.../iotdb/confignode/manager/ModelManager.java | 7 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 5 +
.../protocol/IoTDBConfigRegionConnector.java | 5 +
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 3 +
.../iotdb/confignode/persistence/TriggerInfo.java | 3 -
.../iotdb/confignode/persistence/UDFInfo.java | 3 -
.../procedure/impl/model/DropModelProcedure.java | 57 +++++------
iotdb-core/consensus/pom.xml | 14 +--
iotdb-core/datanode/pom.xml | 2 +-
.../iotdb/db/exception/load/LoadFileException.java | 4 +
.../task/builder/PipeDataNodeTaskBuilder.java | 68 ++++++++-----
.../airgap/IoTDBDataRegionAirGapConnector.java | 31 ++++++
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 5 +
.../async/IoTDBDataRegionAsyncConnector.java | 16 ++-
.../async/handler/PipeTransferTsFileHandler.java | 6 ++
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 21 ++++
.../thrift/sync/IoTDBSchemaRegionConnector.java | 5 +
.../connector/util/builder/PipeTsFileBuilder.java | 40 +++++---
.../dataregion/IoTDBDataRegionExtractor.java | 10 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 20 +++-
.../pipe/metric/overview/PipeResourceMetrics.java | 14 +++
.../pipeconsensus/PipeConsensusReceiver.java | 75 +++++++-------
.../protocol/thrift/IoTDBDataNodeReceiver.java | 5 +
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +
.../fragment/FragmentInstanceExecution.java | 6 +-
.../relational/AbstractMergeSortJoinOperator.java | 14 +++
.../queryengine/plan/analyze/AnalyzeVisitor.java | 24 +++--
.../config/executor/ClusterConfigTaskExecutor.java | 6 +-
.../plan/planner/LogicalPlanBuilder.java | 4 +-
.../plan/relational/planner/QueryPlanner.java | 2 +-
.../metadata/view/CreateLogicalViewStatement.java | 13 ++-
.../org/apache/iotdb/db/service/MQTTService.java | 2 +-
.../metrics/IoTDBInternalLocalReporter.java | 2 +-
.../dataregion/snapshot/SnapshotLoader.java | 67 +++++++++----
.../tsfile/generator/TsFileNameGenerator.java | 63 ++++++------
.../allocation/AbstractNodeAllocationStrategy.java | 13 +--
.../db/storageengine/load/LoadTsFileManager.java | 12 ++-
.../storageengine/load/disk/ILoadDiskSelector.java | 3 +-
.../InheritSystemMultiDisksStrategySelector.java | 42 +++++---
.../db/storageengine/load/disk/MinIOSelector.java | 3 +-
.../load/limiter/LoadTsFileRateLimiter.java | 64 ++----------
.../storageengine/rescon/disk/FolderManager.java | 63 ++++++++++++
.../db/storageengine/rescon/disk/TierManager.java | 4 +
.../rescon/disk/strategy/DirectoryStrategy.java | 34 +++++++
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 3 +
.../MinFolderOccupiedSpaceFirstStrategy.java | 4 +
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +
.../rescon/disk/strategy/SequenceStrategy.java | 4 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +-
.../iotdb/db/utils/sort/FileSpillerReader.java | 4 +-
.../process/TableStreamSortOperatorTest.java | 11 +--
iotdb-core/node-commons/pom.xml | 2 +-
.../iotdb/commons/client/ainode/AINodeClient.java | 5 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 16 +++
.../iotdb/commons/pipe/config/PipeConfig.java | 6 ++
.../iotdb/commons/pipe/config/PipeDescriptor.java | 6 ++
.../config/constant/PipeConnectorConstant.java | 5 +
.../connector/limiter/GlobalRPCRateLimiter.java} | 15 ++-
.../pipe/connector/limiter/GlobalRateLimiter.java | 14 +--
.../connector/limiter/TsFileSendRateLimiter.java} | 31 +++---
.../connector/protocol/IoTDBAirGapConnector.java | 3 +
.../pipe/connector/protocol/IoTDBConnector.java | 4 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 3 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 66 +++++++------
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 56 ++++++-----
.../thrift-ainode/src/main/thrift/ainode.thrift | 6 +-
pom.xml | 20 ++--
86 files changed, 1036 insertions(+), 523 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/{regionmigration/pass/commit/stream/IoTDBRegionMigrateNormalForIoTV2StreamIT.java
=> IoTDBConfigNodeSnapshot2IT.java} (63%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DataTypeParameter.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/limiter/GlobalRPCRateLimiter.java}
(66%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeConnectorSubtaskExecutor.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/limiter/TsFileSendRateLimiter.java}
(54%)
