This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch IOTDB-5723
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b0fbdf89141 support dn task runtime error report
add cadbdb32ac5 blocking way to consume events from pending queue
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/pipe/config/PipeConfig.java | 6 +
.../core/collector/IoTDBDataRegionCollector.java | 5 +-
.../PipeRealtimeDataRegionHybridCollector.java | 6 +-
.../manager/PipeConnectorSubtaskLifeCycle.java | 8 +-
.../manager/PipeConnectorSubtaskManager.java | 8 +-
.../event/view/collector/PipeEventCollector.java | 6 +-
.../task/queue/ListenableBlockingPendingQueue.java | 153 +++++++++++++++++++-
... => ListenableBoundedBlockingPendingQueue.java} | 5 +-
.../db/pipe/task/queue/ListenablePendingQueue.java | 159 ---------------------
...> ListenableUnboundedBlockingPendingQueue.java} | 9 +-
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 8 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 4 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 10 +-
.../db/pipe/task/subtask/PipeConnectorSubtask.java | 6 +-
.../core/collector/PipeRealtimeCollectTest.java | 10 +-
.../executor/PipeConnectorSubtaskExecutorTest.java | 4 +-
16 files changed, 201 insertions(+), 206 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/pipe/task/queue/{ListenableBlockingPendingQueue.java
=> ListenableBoundedBlockingPendingQueue.java} (84%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenablePendingQueue.java
rename
server/src/main/java/org/apache/iotdb/db/pipe/task/queue/{ListenableUnblockingPendingQueue.java
=> ListenableUnboundedBlockingPendingQueue.java} (77%)
