This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch cp-feaeaa6-dev-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7af1ad793ae Merge dev/1.3 into cp-feaeaa6-dev-1.3
add 22d9de463d2 [Pipe] Improve timeout diagnostics and DROP PIPE
observability (#18297) (#18340)
add cdefafa4dfb [Fix] Reconcile actual aligned TVList memory usage
(#18330) (#18339)
add b858e01122e [Pipe] Relax flaky TsFile event test timeouts (#18332)
(#18341)
add ed87f2d0e83 [To dev/1.3] [Pipe] Preserve sink exception root causes
(#18335) (#18342)
add 6c08c62aeb2 [Pipe] Fix TsFile rate limit accounting (#18344) (#18347)
add 910e0ae9e87 [Pipe] Release tablet memory before closing TsFile scan
parser (#18350) (#18354)
add a750bfd9d8b Merge dev/1.3 into cp-feaeaa6-dev-1.3
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/manager/ProcedureManager.java | 24 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 8 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 26 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 57 +++-
.../procedure/impl/StateMachineProcedure.java | 11 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 199 +++++++++++++-
.../impl/pipe/task/DropPipeProcedureV2.java | 81 +++++-
.../confignode/procedure/scheduler/LockQueue.java | 6 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 2 +-
.../consensus/response/pipe/PipeTableRespTest.java | 37 +++
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 35 +++
.../pipe/PipeTaskInfoAutoRestartTest.java | 46 ++++
.../pipe/AbstractOperatePipeProcedureV2Test.java | 33 +++
.../impl/pipe/task/DropPipeProcedureV2Test.java | 130 +++++++++
.../agent/task/subtask/sink/PipeSinkSubtask.java | 2 +-
.../scan/TsFileInsertionScanDataContainer.java | 5 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 2 +-
.../async/handler/PipeTransferTsFileHandler.java | 22 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 135 ++++++++--
.../db/utils/datastructure/AlignedTVList.java | 86 ++++--
.../iotdb/db/utils/datastructure/TVList.java | 13 +-
.../task/subtask/sink/PipeSinkSubtaskTest.java | 92 +++++++
.../pipe/event/PipeTsFileInsertionEventTest.java | 2 +-
.../event/TsFileInsertionDataContainerTest.java | 10 +
.../PipeTsFileInsertionEventAdmissionTest.java | 2 +-
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 17 +-
.../PipeTransferTsFileHandlerRateLimitTest.java | 83 ++++++
...ignedBitmapMemoryAccountingPerformanceTest.java | 293 +++++++++++++++++++++
.../dataregion/memtable/TsFileProcessorTest.java | 116 +++++++-
.../db/utils/datastructure/AlignedTVListTest.java | 44 ++++
.../pipe/PipeRuntimeCriticalException.java | 4 +
.../exception/pipe/PipeRuntimeException.java | 4 +
.../pipe/PipeRuntimeSinkCriticalException.java | 4 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 6 +
.../commons/pipe/agent/task/meta/PipeStatus.java | 3 +
.../task/subtask/PipeAbstractSinkSubtask.java | 9 +-
.../pipe/sink/protocol/IoTDBAirGapSink.java | 2 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 2 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 13 +
40 files changed, 1585 insertions(+), 93 deletions(-)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTsFileHandlerRateLimitTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedBitmapMemoryAccountingPerformanceTest.java
