This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 73f4e7b2494 PipeConsensus: always execute flush for historical data
extraction of consensus pipe to reduce data sync delay (#14132) (#14154)
add 2906031cd96 Pipe: Reduce the memory usage & Enable insertNode memory
control for stream mode degrade and stuck restart (#14102) (#14161)
No new revisions were added by this update.
Summary of changes:
.../pipe/runtime/PipeHandleMetaChangePlan.java | 8 +-
.../response/pipe/task/PipeTableResp.java | 5 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 4 +-
.../runtime/heartbeat/PipeHeartbeat.java | 3 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 5 +-
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 4 +-
... => PipeTemporaryMetaInCoordinatorMetrics.java} | 29 +++---
.../confignode/persistence/pipe/PipeInfo.java | 16 +--
.../confignode/persistence/pipe/PipeTaskInfo.java | 4 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 30 ++++--
.../async/IoTDBDataRegionAsyncConnector.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 30 +++++-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 12 ++-
.../impl/DataNodeInternalRPCServiceImpl.java | 17 ++--
.../config/executor/ClusterConfigTaskExecutor.java | 6 +-
.../dataregion/wal/utils/WALEntryHandler.java | 12 +--
.../TsFileResourceProgressIndexTest.java | 5 +
.../commons/consensus/index/ProgressIndex.java | 12 ++-
.../consensus/index/impl/HybridProgressIndex.java | 36 ++++---
.../consensus/index/impl/IoTProgressIndex.java | 12 +++
.../consensus/index/impl/MetaProgressIndex.java | 9 +-
.../consensus/index/impl/MinimumProgressIndex.java | 5 +
.../consensus/index/impl/RecoverProgressIndex.java | 13 +++
.../consensus/index/impl/SimpleProgressIndex.java | 9 +-
.../consensus/index/impl/StateProgressIndex.java | 20 +++-
.../index/impl/TimeWindowStateProgressIndex.java | 24 +++++
.../commons/pipe/agent/task/PipeTaskAgent.java | 49 ++++++++++
.../commons/pipe/agent/task/meta/PipeMeta.java | 17 +++-
.../pipe/agent/task/meta/PipeTemporaryMeta.java | 73 +-------------
.../agent/task/meta/PipeTemporaryMetaInAgent.java | 107 +++++++++++++++++++++
...ta.java => PipeTemporaryMetaInCoordinator.java} | 5 +-
.../pipe/agent/task/progress/CommitterKey.java | 2 +-
.../task/progress/PipeEventCommitManager.java | 12 ++-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 6 --
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 19 ++--
37 files changed, 451 insertions(+), 179 deletions(-)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{PipeTemporaryMetaMetrics.java
=> PipeTemporaryMetaInCoordinatorMetrics.java} (82%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeTemporaryMetaInAgent.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/{PipeTemporaryMeta.java
=> PipeTemporaryMetaInCoordinator.java} (94%)
