This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/show-receivers
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 86c37d0055a Merge branch 'master' of https://github.com/apache/iotdb
into feat/show-receivers
add 47c80d4fa55 [Pipe] Preserve receiver sessions across region task
lifecycle
No new revisions were added by this update.
Summary of changes:
.../pipe/agent/task/PipeConfigNodeSubtask.java | 13 +++++
.../pipe/agent/task/PipeConfigNodeTask.java | 10 ++++
.../pipe/agent/task/PipeConfigNodeTaskStage.java | 10 ++++
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 10 ++++
.../pipe/agent/task/stage/PipeTaskSinkStage.java | 12 +++++
.../agent/task/subtask/sink/PipeSinkSubtask.java | 22 ++++++++
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 11 +++-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 24 +++++++++
.../thrift/async/IoTDBDataRegionAsyncSink.java | 14 ++++++
.../task/stage/SubscriptionTaskSinkStage.java | 10 ++++
.../subtask/sink/PipeSinkSubtaskLifeCycleTest.java | 58 ++++++++++++++++++++++
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 39 +++++++++++++++
.../iotdb/commons/pipe/agent/task/PipeTask.java | 8 +++
.../commons/pipe/agent/task/PipeTaskAgent.java | 24 ++++++++-
.../pipe/agent/task/stage/PipeTaskStage.java | 8 +++
.../commons/pipe/receiver/IoTDBFileReceiver.java | 32 +++++++++---
.../pipe/sink/client/IoTDBClientManager.java | 5 ++
.../pipe/sink/client/IoTDBSyncClientManager.java | 45 +++++++++++++++--
.../commons/pipe/sink/protocol/IoTDBSink.java | 8 +++
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 14 ++++++
20 files changed, 362 insertions(+), 15 deletions(-)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskLifeCycleTest.java
