This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 474e74790da Pipe: Fix TSFile transfer blocking InsertNode sending
(#15666)
add 215a1b7f697 Pipe/IoTV2: Try to persist progressIndex in local for
resend event more efficently (#15599)
No new revisions were added by this update.
Summary of changes:
.../runtime/heartbeat/PipeHeartbeatParser.java | 2 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 7 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 16 ++-
.../impl/pipe/task/CreatePipeProcedureV2.java | 18 ++-
.../confignode/service/ConfigNodeShutdownHook.java | 3 +
.../request/ConfigPhysicalPlanSerDeTest.java | 12 +-
.../consensus/response/pipe/PipeTableRespTest.java | 6 +-
.../agent/PipeConfigNodeSubtaskExecutorTest.java | 3 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 4 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 9 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 3 +
.../iotdb/commons/concurrent/ThreadName.java | 5 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 55 ++++++++
.../agent/runtime/PipePeriodicalJobExecutor.java | 33 +++++
.../commons/pipe/agent/task/PipeTaskAgent.java | 3 +
.../commons/pipe/agent/task/meta/PipeMeta.java | 6 +-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 42 ++++--
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 145 ++++++++++++++++++++-
.../iotdb/commons/pipe/config/PipeConfig.java | 21 +++
.../iotdb/commons/pipe/config/PipeDescriptor.java | 18 +++
.../config/constant/PipeConnectorConstant.java | 2 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 22 +++-
23 files changed, 386 insertions(+), 53 deletions(-)
