This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d48f2c50b63 Merge branch 'object_type' of github.com:apache/iotdb into
object_type
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
new b51e5da6d28 resolve conflicts
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 +--
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 16 ++++
.../java/org/apache/iotdb/session/Session.java | 17 ++--
.../apache/iotdb/session/util/SessionUtils.java | 103 ++++++++++++---------
.../iotdb/session/util/SessionUtilsTest.java | 26 +++++-
iotdb-core/ainode/ainode/core/ingress/iotdb.py | 1 +
.../ainode/core/manager/inference_manager.py | 27 +++---
.../ainode/ainode/core/manager/model_manager.py | 10 +-
.../ainode/core/model/built_in_model_factory.py | 8 +-
.../ainode/ainode/core/model/model_storage.py | 5 +-
iotdb-core/confignode/pom.xml | 2 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 5 +
.../protocol/IoTDBConfigRegionConnector.java | 5 +
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 3 +
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 | 14 +++
.../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 +-
.../pipe/metric/overview/PipeResourceMetrics.java | 14 +++
.../pipeconsensus/PipeConsensusReceiver.java | 75 ++++++++-------
.../protocol/thrift/IoTDBDataNodeReceiver.java | 5 +
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 24 +++--
.../config/executor/ClusterConfigTaskExecutor.java | 6 +-
.../plan/planner/LogicalPlanBuilder.java | 4 +-
.../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-core/node-commons/pom.xml | 2 +-
.../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 ++++++-----
pom.xml | 18 ++--
66 files changed, 827 insertions(+), 403 deletions(-)
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%)
