This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch rc/1.3.5
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8c694e434f6 [To dev/1.3] Pipe: Do not use the fork join pool in
TerminateEvent #16113 (#16114)
new 902aa35e14c [To dev/1.3] Pipe: Totally banned the receiver conversion
(#16086) (#16105)
new 02e358b3134 [To dev/1.3] Pipe: Delete the heartbeat event count in
Remaining Count #16115 (#16116)
new 8d1fbbd6ff5 [To dev/1.3] Pipe: CN adds logic to check if Pipe is out
of memory #16119 (#16120)
new bf5c1922f0c [To dev/1.3] Pipe: Fix and improve async tsfile transfer
error handling and logging (avoid client connection leak) (#16008) (#16125)
new d142dac567e [TIMECHODB] Change access
new 870ab7bf39a [TIMECHODB] fix-memory
new 8618d26d74a Pipe: Avoid unnecessary close-client in async client
(Follow up fix for #16008)
new 42b110729bf Pipe: Fix the problem that a cluster crash in the
multi-cluster receiving end causes all synchronization to be suspended (#15962)
(#15991)
new c9f143a15e8 Pipe: Reduce IoTDBAirGapConnector Handshake times
(#15990)(#15993)
new c0d70886f92 [To dev/1.3] Pipe: Fixed hard-link problem (#15984)
(#15986)
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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 +
...ectorParallelIT.java => IoTDBPipeMemoryIT.java} | 63 +++++++++++-----------
.../manual/IoTDBPipeTypeConversionISessionIT.java | 5 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 28 ++++++++++
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 9 ++--
.../client/IoTDBDataNodeAsyncClientManager.java | 49 ++++++++++++++++-
.../async/IoTDBDataRegionAsyncConnector.java | 32 +++++++----
.../handler/PipeTransferTrackableHandler.java | 45 +++++++++++++---
.../async/handler/PipeTransferTsFileHandler.java | 24 +++++++--
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 5 ++
.../realtime/assigner/PipeDataRegionAssigner.java | 9 ----
.../PipeDataNodeRemainingEventAndTimeOperator.java | 17 +-----
.../overview/PipeDataNodeSinglePipeMetrics.java | 4 +-
...peStatementDataTypeConvertExecutionVisitor.java | 4 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 60 +++++++++++----------
.../impl/DataNodeInternalRPCServiceImpl.java | 21 ++++++--
.../async/AsyncPipeDataTransferServiceClient.java | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 30 +++++++++++
.../commons/pipe/agent/task/PipeTaskAgent.java | 1 +
.../iotdb/commons/pipe/config/PipeConfig.java | 12 +++++
.../iotdb/commons/pipe/config/PipeDescriptor.java | 10 ++++
.../connector/client/IoTDBSyncClientManager.java | 14 +++++
.../connector/protocol/IoTDBAirGapConnector.java | 11 ++++
27 files changed, 356 insertions(+), 119 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/{IoTDBPipeConnectorParallelIT.java
=> IoTDBPipeMemoryIT.java} (65%)
