This is an automated email from the ASF dual-hosted git repository.

rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from b2549039bab Fixed the bug that fetchSeriesSchema returns series in 
black list when the given pattern tree is without wildcards
     add 0fcd638a308 Pipe/Subscription: Update the way SubscriptionCoordinator 
and PipeTaskCoordinator acquire locks to prevent procedure success without any 
effect (#12909)

No new revisions were added by this update.

Summary of changes:
 .../pipe/coordinator/task/PipeTaskCoordinator.java | 22 +++++++++++++++++-----
 .../coordinator/task/PipeTaskCoordinatorLock.java  |  2 +-
 .../subscription/SubscriptionCoordinator.java      | 12 ++++++++++++
 .../impl/pipe/AbstractOperatePipeProcedureV2.java  | 16 ++++++++++------
 .../impl/pipe/plugin/DropPipePluginProcedure.java  | 12 +-----------
 .../runtime/PipeHandleMetaChangeProcedure.java     | 12 ++++++++++++
 .../impl/pipe/runtime/PipeMetaSyncProcedure.java   | 12 ++++++++++++
 .../AbstractOperateSubscriptionProcedure.java      | 16 ++++++++++------
 .../runtime/ConsumerGroupMetaSyncProcedure.java    | 12 ++++++++++++
 ...bstractOperateSubscriptionAndPipeProcedure.java |  6 +-----
 .../topic/runtime/TopicMetaSyncProcedure.java      | 12 ++++++++++++
 .../execution/load/LoadTsFileRateLimiter.java      |  2 +-
 .../apache/iotdb/commons/conf/CommonConfig.java    | 11 +++++------
 .../iotdb/commons/conf/CommonDescriptor.java       |  6 +++---
 .../iotdb/commons/pipe/config/PipeConfig.java      |  7 +++----
 .../pipe/connector/limiter/GlobalRateLimiter.java  |  2 +-
 .../connector/limiter/PipeEndPointRateLimiter.java |  2 +-
 17 files changed, 114 insertions(+), 50 deletions(-)

Reply via email to