This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch insert-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 404ea0c0837 insert-fix
add 226df7e8530 source/sink
No new revisions were added by this update.
Summary of changes:
.../dataregion/PipeDataRegionPluginAgent.java | 8 ++---
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 28 ++++++++---------
.../PipeTransferTabletBatchEventHandler.java | 10 +++---
.../PipeTransferTabletInsertNodeEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 7 ++---
.../handler/PipeTransferTabletRawEventHandler.java | 6 ++--
.../handler/PipeTransferTrackableHandler.java | 24 +++++++--------
.../async/handler/PipeTransferTsFileHandler.java | 27 ++++++++--------
.../realtime/assigner/DisruptorQueue.java | 4 +--
.../listener/PipeInsertionDataNodeListener.java | 36 +++++++++++-----------
.../iotdb/commons/concurrent/ThreadName.java | 4 +--
11 files changed, 75 insertions(+), 81 deletions(-)
