This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch feature/memory_collect
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6e970922110 fix operators memory
add 04810e27cc8 Fix predicate pushdown when dealing with ProjectNode
(#14754)
add 8c62821f1ad [Daily IT]: Daily IT adds a single region task (#14659)
add e56b34f3535 fix mods file metrics & fix the issue of missing mods with
concurrent deletion and compaction (#14765)
add 7af1b52dbcb Implemented TableDeviceSchemaCache#getLastEntries for query
add 93e83c63fbd Pipe: incorporate batch data into
TsFileInsertionEventScanParser memory control & Subscription: close data
container in tsfile event & bind memory block for tablet response & generate
empty tablet as initial response & offer subsequent tablet response before ack
& expose prefetch and backdoor configs & best-effort disorder control (#14752)
add 5933818eec7 Delete the adjustment operation of TCP port (#14770)
add 0429a02b8ce Merge branch 'master' into feature/memory_collect
No new revisions were added by this update.
Summary of changes:
.github/workflows/daily-it.yml | 36 +++-
integration-test/pom.xml | 2 +
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 6 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 22 +++
.../subscription/payload/poll/TabletsPayload.java | 11 +-
.../scan/TsFileInsertionEventScanParser.java | 19 ++
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 48 +++++
.../fetcher/cache/TableDeviceSchemaCache.java | 19 ++
.../optimizations/LogicalOptimizeFactory.java | 2 +-
.../optimizations/PushPredicateIntoTableScan.java | 156 ++++++++++++----
.../db/storageengine/dataregion/DataRegion.java | 14 +-
.../compaction/execute/utils/CompactionUtils.java | 5 +-
.../dataregion/modification/ModificationFile.java | 69 +++++--
.../dataregion/tsfile/TsFileResource.java | 23 ++-
.../broker/SubscriptionPrefetchingQueue.java | 47 +++--
.../broker/SubscriptionPrefetchingQueueStates.java | 96 +++++++---
.../broker/SubscriptionPrefetchingTabletQueue.java | 2 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 2 +-
.../event/SubscriptionCommitContextSupplier.java | 28 ---
.../db/subscription/event/SubscriptionEvent.java | 80 +++++---
.../event/batch/SubscriptionPipeEventBatch.java | 30 ---
.../batch/SubscriptionPipeTabletEventBatch.java | 66 +++----
.../batch/SubscriptionPipeTsFileEventBatch.java | 15 --
.../cache/CachedSubscriptionPollResponse.java | 5 +
.../event/pipe/SubscriptionPipeEmptyEvent.java | 4 +-
.../pipe/SubscriptionPipeTabletBatchEvents.java | 46 ++++-
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 8 +-
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 8 +-
.../SubscriptionEventExtendableResponse.java | 1 +
.../event/response/SubscriptionEventResponse.java | 10 +-
.../response/SubscriptionEventSingleResponse.java | 1 +
.../response/SubscriptionEventTabletResponse.java | 201 ++++++++++++++++-----
.../response/SubscriptionEventTsFileResponse.java | 32 +++-
.../plan/relational/planner/SubqueryTest.java | 147 +++++++--------
.../apache/iotdb/commons/conf/CommonConfig.java | 76 ++++++--
.../iotdb/commons/conf/CommonDescriptor.java | 37 +++-
.../subscription/config/SubscriptionConfig.java | 47 ++++-
.../commons/subscription/meta/topic/TopicMeta.java | 4 +
39 files changed, 1003 insertions(+), 424 deletions(-)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionCommitContextSupplier.java
