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 275fe395aee Pipe: Delete the heartbeat event count in Remaining Count
(#16115)
add d0788a87d87 Pipe: CN adds logic to check if Pipe is out of memory
(#16119)
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 6 ++
.../env/cluster/config/MppSharedCommonConfig.java | 6 ++
.../it/env/remote/config/RemoteCommonConfig.java | 5 ++
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../manual/basic/IoTDBPipeMemoryIT.java} | 68 ++++++++++------------
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 28 +++++++++
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 9 ++-
.../impl/DataNodeInternalRPCServiceImpl.java | 23 ++++++--
.../commons/pipe/agent/task/PipeTaskAgent.java | 1 +
10 files changed, 104 insertions(+), 45 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/{treemodel/auto/basic/IoTDBPipeSinkParallelIT.java
=> tablemodel/manual/basic/IoTDBPipeMemoryIT.java} (60%)
