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 0a32caca6a2 mbt
add 93ea4ae5f5c sink
No new revisions were added by this update.
Summary of changes:
.../pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java | 2 +-
.../manager/pipe/agent/task/PipeConfigNodeSubtask.java | 8 ++++----
.../pipe/metric/sink/PipeConfigRegionSinkMetrics.java | 4 ++--
.../pipe/sink/protocol/IoTDBConfigRegionAirGapSink.java | 2 +-
.../manager/pipe/sink/protocol/IoTDBConfigRegionSink.java | 2 +-
.../db/pipe/agent/plugin/PipeDataNodePluginAgent.java | 4 ++--
.../agent/plugin/dataregion/PipeDataRegionPluginAgent.java | 14 +++++++-------
.../db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java | 2 +-
.../agent/task/execution/PipeSubtaskExecutorManager.java | 4 ++--
.../agent/task/subtask/sink/PipeSinkSubtaskManager.java | 12 ++++++------
.../resources/conf/iotdb-system.properties.template | 2 +-
.../commons/pipe/agent/task/meta/PipeRuntimeMeta.java | 2 +-
.../iotdb/commons/pipe/agent/task/meta/PipeStaticMeta.java | 2 +-
.../commons/pipe/sink/limiter/GlobalRPCRateLimiter.java | 2 +-
.../payload/thrift/request/PipeTransferCompressedReq.java | 2 +-
.../iotdb/commons/pipe/sink/protocol/IoTDBAirGapSink.java | 2 +-
.../apache/iotdb/commons/pipe/sink/protocol/IoTDBSink.java | 4 ++--
.../iotdb/commons/pipe/sink/protocol/IoTDBSslSyncSink.java | 2 +-
18 files changed, 36 insertions(+), 36 deletions(-)