This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch clean
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f7cc0f653ab fix
add 0a32caca6a2 mbt
No new revisions were added by this update.
Summary of changes:
.../persistence/pipe/PipePluginInfo.java | 2 +-
.../consensus/config/PipeConsensusConfig.java | 16 +++----
.../consensuspipe/ConsensusPipeDispatcher.java | 2 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 2 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 14 +++---
.../task/execution/PipeSubtaskExecutorManager.java | 2 +-
.../pipe/agent/task/stage/PipeTaskSinkStage.java | 13 +++---
.../subtask/processor/PipeProcessorSubtask.java | 12 +++---
.../agent/task/subtask/sink/PipeSinkSubtask.java | 20 ++++-----
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 2 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 12 +++---
.../airgap/IoTDBSchemaRegionAirGapSink.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncSink.java | 8 ++--
.../pipeconsensus/PipeConsensusSyncSink.java | 12 +++---
.../PipeConsensusTabletBatchEventHandler.java | 16 +++----
.../PipeConsensusTabletInsertNodeEventHandler.java | 4 +-
.../PipeConsensusTabletInsertionEventHandler.java | 12 +++---
.../PipeConsensusTsFileInsertionEventHandler.java | 19 ++++----
.../thrift/async/IoTDBDataRegionAsyncSink.java | 4 +-
.../PipeTransferTabletBatchEventHandler.java | 16 +++----
.../PipeTransferTabletInsertNodeEventHandler.java | 6 +--
.../PipeTransferTabletInsertionEventHandler.java | 11 +++--
.../handler/PipeTransferTabletRawEventHandler.java | 6 +--
.../handler/PipeTransferTrackableHandler.java | 32 +++++++-------
.../async/handler/PipeTransferTsFileHandler.java | 33 +++++++-------
.../thrift/sync/IoTDBSchemaRegionSink.java | 2 +-
.../websocket/WebSocketConnectorServer.java | 50 +++++++++++-----------
.../sink/protocol/writeback/WriteBackSink.java | 4 +-
.../config/sys/pipe/PipeFunctionSupport.java | 4 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 12 +++---
.../apache/iotdb/commons/conf/CommonConfig.java | 4 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 11 +++--
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 3 +-
33 files changed, 175 insertions(+), 193 deletions(-)
