This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch debug-data-allot-table
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 5fce2d2a854 Bug Fix
omit ea7289c8bcc Resolve conversation
omit 78c8d5e5880 Update DataPartitionPolicyTable.java
omit 539142f218e Bug Fixed
add d614139f71f Optimize client cpp package (#10923)
add 51e6d17b821 [IOTDB-6120] Push down limit/offset in query with group by
time
add 23340404c99 [IOTDB-6080] Pipe: Introduce batch mode for tablet
transferring (#10912)
add 1dce787c39e [Metric] Fix flush point statistics (#10915)
add 6357533a25c [IOTDB-6125] Fix DataPartition allocation bug when insert
big batch data (#10924)
add e891a5d1f31 [IOTDB-6121] Consensus layer interface and exception
handling refactoring (#10896)
add 8358667c60e Bug Fix
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5fce2d2a854)
\
N -- N -- N refs/heads/debug-data-allot-table (8358667c60e)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
distribution/pom.xml | 16 +-
distribution/src/assembly/client-cpp.xml | 2 +-
.../apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java | 1 +
.../confignode/manager/ClusterQuotaManager.java | 52 ++--
.../iotdb/confignode/manager/ConfigManager.java | 18 +-
.../iotdb/confignode/manager/ModelManager.java | 75 +++---
.../confignode/manager/PermissionManager.java | 39 ++-
.../iotdb/confignode/manager/TriggerManager.java | 56 ++--
.../iotdb/confignode/manager/UDFManager.java | 28 +-
.../manager/consensus/ConsensusManager.java | 84 +++---
.../iotdb/confignode/manager/cq/CQManager.java | 42 ++-
.../confignode/manager/cq/CQScheduleTask.java | 26 +-
.../iotdb/confignode/manager/node/NodeManager.java | 73 +++--
.../manager/partition/PartitionManager.java | 187 +++++++++----
.../manager/pipe/plugin/PipePluginCoordinator.java | 23 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 14 +-
.../manager/schema/ClusterSchemaManager.java | 276 ++++++++++++++++---
.../procedure/env/ConfigNodeProcedureEnv.java | 18 +-
.../procedure/env/DataNodeRemoveHandler.java | 7 +-
.../procedure/impl/cq/CreateCQProcedure.java | 113 ++++----
.../procedure/impl/model/CreateModelProcedure.java | 18 +-
.../procedure/impl/model/DropModelProcedure.java | 7 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 27 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 13 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 19 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 23 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 42 ++-
.../impl/pipe/task/DropPipeProcedureV2.java | 18 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 42 ++-
.../impl/pipe/task/StopPipeProcedureV2.java | 42 ++-
.../impl/schema/DeleteDatabaseProcedure.java | 3 +-
.../impl/schema/SetTemplateProcedure.java | 77 ++++--
.../statemachine/CreateRegionGroupsProcedure.java | 7 +-
.../impl/trigger/CreateTriggerProcedure.java | 22 +-
.../procedure/store/ConfigProcedureStore.java | 13 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 8 +-
iotdb-core/consensus/pom.xml | 2 +-
.../org/apache/iotdb/consensus/IConsensus.java | 166 +++++++-----
.../iotdb/consensus/common/ConsensusGroup.java | 1 -
.../org/apache/iotdb/consensus/common/Peer.java | 1 -
.../org/apache/iotdb/consensus/common/Utils.java | 13 +-
.../common/request/ByteBufferConsensusRequest.java | 12 +-
.../common/response/ConsensusGenericResponse.java | 64 -----
.../common/response/ConsensusReadResponse.java | 69 -----
.../common/response/ConsensusResponse.java | 39 ---
.../common/response/ConsensusWriteResponse.java | 82 ------
.../iotdb/consensus/config/ConsensusConfig.java | 18 +-
.../consensus/exception/NodeReadOnlyException.java | 31 ---
.../PeerNotInConsensusGroupException.java | 6 +-
.../exception/RatisUnderRecoveryException.java | 3 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 222 +++++++--------
.../iotdb/consensus/ratis/RatisConsensus.java | 248 +++++++----------
.../iotdb/consensus/simple/SimpleConsensus.java | 142 +++++-----
...verImpl.java => SimpleConsensusServerImpl.java} | 4 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 18 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 106 ++++++--
.../iotdb/consensus/ratis/RatisConsensusTest.java | 130 +++++----
.../iotdb/consensus/ratis/RecoverReadTest.java | 49 ++--
.../apache/iotdb/consensus/ratis/TestUtils.java | 18 +-
.../iotdb/consensus/simple/RecoveryTest.java | 22 +-
.../consensus/simple/SimpleConsensusTest.java | 228 ++++++++--------
.../db/consensus/DataRegionConsensusImpl.java | 299 ++++++++++-----------
.../db/consensus/SchemaRegionConsensusImpl.java | 216 ++++++++-------
.../config/constant/PipeConnectorConstant.java | 11 +
.../payload/evolvable/PipeRequestType.java | 2 +
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 98 +++++++
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 89 ++++++
.../builder/PipeTransferBatchReqBuilder.java | 64 +++++
.../evolvable/request/PipeTransferBatchReq.java | 172 ++++++++++++
.../request/PipeTransferFilePieceReq.java | 7 +-
.../evolvable/request/PipeTransferFileSealReq.java | 4 +-
.../request/PipeTransferHandshakeReq.java | 2 +-
.../request/PipeTransferInsertNodeReq.java | 2 +-
.../evolvable/request/PipeTransferTabletReq.java | 37 ++-
.../db/pipe/connector/protocol/IoTDBConnector.java | 11 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 8 +
.../thrift/async/IoTDBThriftAsyncConnector.java | 117 ++++++--
...eTransferTabletBatchInsertionEventHandler.java} | 63 ++---
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 56 +++-
.../receiver/thrift/IoTDBThriftReceiverV1.java | 93 +++++--
.../iotdb/db/protocol/client/ConfigNodeClient.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 124 +++++----
.../thrift/impl/DataNodeRegionManager.java | 47 ++--
.../execution/executor/RegionReadExecutor.java | 18 +-
.../execution/executor/RegionWriteExecutor.java | 104 +++----
.../db/queryengine/plan/analyze/Analysis.java | 11 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 76 ++++--
.../plan/optimization/LimitOffsetPushDown.java | 117 ++++++++
.../db/queryengine/plan/parser/ASTVisitor.java | 15 +-
.../plan/planner/LogicalPlanVisitor.java | 12 +-
.../planner/plan/node/write/InsertRowsNode.java | 9 +-
.../plan/statement/component/OrderByComponent.java | 8 +-
.../plan/statement/crud/QueryStatement.java | 20 ++
.../template/ClusterTemplateManager.java | 3 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 12 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 25 +-
.../iotdb/db/service/RegionMigrateService.java | 101 +++----
.../dataregion/flush/MemTableFlushTask.java | 58 ++--
.../execution/executor/RegionReadExecutorTest.java | 31 +--
.../executor/RegionWriteExecutorTest.java | 24 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 271 +++++++++++++++++++
.../DataNodeInternalRPCServiceImplTest.java | 8 +-
.../iotdb/metrics/AbstractMetricService.java | 45 ++--
.../metrics/reporter/iotdb/IoTDBReporter.java | 6 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 38 ++-
.../apache/iotdb/commons/utils/StatusUtils.java | 2 +-
iotdb-protocol/pom.xml | 2 +-
.../pom.xml | 4 +-
.../src/main/thrift/iotconsensus.thrift | 0
pom.xml | 2 +-
111 files changed, 3545 insertions(+), 2228 deletions(-)
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusGenericResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusReadResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusWriteResponse.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/NodeReadOnlyException.java
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/simple/{SimpleServerImpl.java
=> SimpleConsensusServerImpl.java} (94%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftAsyncPipeTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftSyncPipeTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/PipeTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferBatchReq.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/{PipeTransferTabletInsertionEventHandler.java
=> PipeTransferTabletBatchInsertionEventHandler.java} (62%)
rename iotdb-protocol/{thrift-iot-consensus => thrift-consensus}/pom.xml (95%)
rename iotdb-protocol/{thrift-iot-consensus =>
thrift-consensus}/src/main/thrift/iotconsensus.thrift (100%)
