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 b07929c2a35 Update IoTDBThriftSyncClientManager.java
add cc4dc0a9ed0 Pipe: Reduced pipe logs and controlled how often the log
is printed below a certain frequency (#11973)
add 654d2f0458f Merge branch 'master' of https://github.com/apache/iotdb
into pipe-meta-sync
No new revisions were added by this update.
Summary of changes:
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 21 ++++++++-
.../thrift/async/IoTDBThriftAsyncConnector.java | 9 ++--
.../PipeTransferTabletBatchEventHandler.java | 9 +++-
.../PipeTransferTabletInsertionEventHandler.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 9 ++++
.../common/tablet/PipeRawTabletInsertionEvent.java | 13 +++++
.../db/pipe/resource/PipeResourceManager.java | 7 +++
.../db/pipe/resource/log/PipeLogManager.java} | 25 +++++-----
.../iotdb/db/pipe/resource/log/PipeLogStatus.java} | 45 +++++++++---------
.../db/pipe/resource/memory/PipeMemoryBlock.java | 5 ++
.../resource/tsfile/PipeTsFileResourceManager.java | 20 ++++++--
.../pipe/resource/wal/PipeWALResourceManager.java | 23 +++++++--
.../subtask/connector/PipeConnectorSubtask.java | 12 +++--
.../dataregion/wal/utils/WALEntryHandler.java | 5 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 55 ++++++++++++++++++++++
.../iotdb/commons/conf/CommonDescriptor.java | 31 ++++++++++++
.../iotdb/commons/pipe/config/PipeConfig.java | 33 +++++++++++++
.../iotdb/commons/pipe/event/EnrichedEvent.java | 34 ++++++++++---
.../commons/pipe/task/meta/PipeMetaKeeper.java | 4 ++
19 files changed, 300 insertions(+), 64 deletions(-)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskExtractorRuntimeEnvironment.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/resource/log/PipeLogManager.java}
(59%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/StoppableThread.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/resource/log/PipeLogStatus.java}
(52%)
