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 a151fe45f5b To avoid deadlock, we use a new thread to stop all pipes
in PipeRuntimeConfigNodeAgent.java
add 7d39716b6d4 rename
No new revisions were added by this update.
Summary of changes:
.../statemachine/ConfigRegionStateMachine.java | 12 ++--
.../runtime/PipeRuntimeCoordinator.java | 4 +-
.../agent/task/PipeTaskConfigNodeAgent.java | 5 +-
.../extractor/IoTDBConfigRegionExtractor.java | 4 +-
...ter.java => PipeConfigPlanListeningFilter.java} | 74 ++++++++++++----------
...ueue.java => PipeConfigPlanListeningQueue.java} | 22 +++----
.../persistence/executor/ConfigPlanExecutor.java | 4 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 16 ++---
....java => PipeConfigPlanListeningQueueTest.java} | 24 +++----
9 files changed, 85 insertions(+), 80 deletions(-)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/extractor/{PipeConfigPlanFilter.java
=> PipeConfigPlanListeningFilter.java} (83%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/extractor/{ConfigPlanListeningQueue.java
=> PipeConfigPlanListeningQueue.java} (87%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/{ConfigPlanListeningQueueTest.java
=> PipeConfigPlanListeningQueueTest.java} (81%)
