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 7d94bba6ad6 PipePlugin: Enhance PipePlugin Jar Directory Compatibility
and Update Format During CN and DN Upgrade (#13006)
add b540636c58a Subscription: fix concurrent issues related to seal batch
& use hybrid realtime extractor for tsfile format topic (#12996)
No new revisions were added by this update.
Summary of changes:
.../it/triple/AbstractSubscriptionTripleIT.java | 78 +++
.../it/triple/IoTDBSubscriptionSharingIT.java | 560 +++++++++++++++++++++
.../iotdb/rpc/subscription/config/TopicConfig.java | 5 +-
.../batch/PipeTabletEventTsFileBatch.java | 6 +-
.../broker/SubscriptionPrefetchingQueue.java | 16 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 58 +--
.../broker/SubscriptionPrefetchingTsFileQueue.java | 68 +--
.../batch/SubscriptionPipeTabletEventBatch.java | 87 +++-
.../batch/SubscriptionPipeTsFileEventBatch.java | 68 ++-
9 files changed, 810 insertions(+), 136 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/AbstractSubscriptionTripleIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/IoTDBSubscriptionSharingIT.java
