This is an automated email from the ASF dual-hosted git repository.
HTHou pushed a change to branch codex/generic-ssl-config
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3f903d9bb65 Update Ratis snapshot and exclude OpenTelemetry
add 2cde545c9b2 Narrow OpenTelemetry exclusions
add d58313225e6 Fix compaction writer size checkpointing (#17941)
add 3b9f59fc9e8 [Pipe] Fix omitted legacy tablet compatibility follow-ups
(#17929)
add 1df19137839 Fix pipe runtime meta push blocking user operations
(#17909)
add c40805ff692 Merge remote-tracking branch 'origin/master' into
codex/generic-ssl-config
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +-
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 25 ++
.../async/AsyncAINodeHeartbeatClientPool.java | 12 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 12 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 22 +-
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 2 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 2 +-
.../rpc/FetchSchemaBlackListRPCHandler.java | 2 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 2 +-
.../CheckSchemaRegionUsingTemplateRPCHandler.java | 2 +-
.../manager/load/service/TopologyService.java | 15 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 13 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 332 +++++++++++++++++----
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 22 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 2 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 2 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 6 +-
.../AbstractOperateSubscriptionProcedure.java | 20 ++
.../runtime/CommitProgressSyncProcedure.java | 10 +-
.../runtime/ConsumerGroupMetaSyncProcedure.java | 10 +-
.../SubscriptionHandleLeaderChangeProcedure.java | 7 +-
.../topic/runtime/TopicMetaSyncProcedure.java | 9 +-
.../request/PipeTransferTabletBatchReq.java | 98 +++++-
.../request/PipeTransferTabletRawReq.java | 13 +-
.../pipe/sink/util/TabletStatementConverter.java | 87 +++++-
.../impl/DataNodeInternalRPCServiceImpl.java | 13 +-
.../GeneralRegionAttributeSecurityService.java | 67 ++---
.../utils/writer/AbstractCompactionWriter.java | 165 +++++++++-
.../writer/AbstractCrossCompactionWriter.java | 3 +-
.../writer/AbstractInnerCompactionWriter.java | 4 +-
.../utils/writer/FastInnerCompactionWriter.java | 10 +-
.../writer/ReadPointCrossCompactionWriter.java | 5 +-
.../writer/ReadPointInnerCompactionWriter.java | 5 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 4 +-
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 128 +++++++-
.../utils/writer/AbstractCompactionWriterTest.java | 167 +++++++++++
.../client/request/AsyncRequestManager.java | 19 +-
.../client/request/AsyncRequestManagerTest.java | 226 ++++++++++++++
pom.xml | 12 -
39 files changed, 1365 insertions(+), 202 deletions(-)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/AbstractCompactionWriterTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/request/AsyncRequestManagerTest.java
