This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-meta-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from eca401560a9 merge master
add 837e4718bc4 Pipe Meta: Adjust the stop logic of schema/config region
subtasks (#12030)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/it/utils/TestUtils.java | 27 ----
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 4 +-
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 10 +-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 20 +--
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 154 +--------------------
.../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 19 +--
.../agent/task/PipeTaskConfigNodeAgent.java | 4 +
.../config/IoTDBConfigRegionConnector.java | 6 +-
.../transfer/execution/PipeConfigNodeSubtask.java | 4 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 3 -
.../impl/pipe/task/AlterPipeProcedureV2.java | 5 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 5 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../consensus/response/pipe/PipeTableRespTest.java | 8 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 6 +-
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 80 ++++++++++-
.../protocol/airgap/IoTDBAirGapConnector.java | 4 -
.../PipeTransferTabletBatchEventHandler.java | 4 +-
.../PipeTransferTabletInsertionEventHandler.java | 4 +-
.../PipeTransferTsFileInsertionEventHandler.java | 8 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 2 +-
.../thrift/sync/IoTDBSchemaRegionConnector.java | 4 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 46 +-----
.../protocol/writeback/WriteBackConnector.java | 1 -
.../pipe/task/connection/PipeEventCollector.java | 10 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 2 +-
...Handler.java => PipeReceiverStatusHandler.java} | 36 ++---
.../builtin/connector/iotdb/IoTDBConnector.java | 12 +-
.../iotdb/commons/pipe/task/PipeTaskManager.java | 33 ++---
.../commons/pipe/task/meta/PipeRuntimeMeta.java | 15 +-
.../commons/pipe/task/stage/PipeTaskStage.java | 10 +-
.../pipe/task/subtask/PipeTransferSubtask.java | 3 +-
.../commons/pipe/task/meta/PipeMetaDeSerTest.java | 3 +-
33 files changed, 204 insertions(+), 356 deletions(-)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/{PipeExceptionHandler.java
=> PipeReceiverStatusHandler.java} (86%)
