This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch
feature/initial-retain-progress-after-unsubscribe
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e9c9fab5475 Complete retained snapshot pipes without DataRegions
add b13f7acbea7 Persist completion for empty retained snapshots
No new revisions were added by this update.
Summary of changes:
.../runtime/heartbeat/PipeHeartbeatParser.java | 31 +++-
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 97 +++++++++----
.../CreateSubscriptionProcedureTest.java | 64 +++++++++
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 57 ++++++++
.../SubscriptionRetainedInitialReplayTest.java | 158 +++++++++++++++++++++
.../pipe/config/constant/SystemConstant.java | 3 +
6 files changed, 380 insertions(+), 30 deletions(-)
