This is an automated email from the ASF dual-hosted git repository.
JackieTien97 pushed a change to branch ty/fix-prometheus-scrape-race
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e7230eabe10 [Test] Accept Prometheus infinity sample spellings
add 4fceb75dfd8 Fix nullable AND results in tree-model CASE (#18875)
add 20cab121be9 [Fix] Prevent stale schema queue closes after leader
transfer (#18948)
add 6ca9cd9d1ff [Test] Fix the metadata lease override in DataNode unit
tests (#18953)
add e08a738d78b Fix table-model schema series metrics (#18951)
add 8a20619f0dc Refactor write memory accounting into named memory blocks
(#18848)
add 7f0ef94f0c0 [Feature] Support TAG value filtering for table
subscriptions (#18639)
add 36e1a13e558 [Docs] Consolidate repository agent instructions in
AGENTS.md (#18952)
add 10749a27f35 Release subscription WAL buffers between prefetch rounds
(#18956)
add 858df2843c5 [Test] Preserve quorum during session seed fallback
recovery (#18958)
add 2fc87bd8d83 Merge master into ty/fix-prometheus-scrape-race
No new revisions were added by this update.
Summary of changes:
AGENTS.md | 180 ++++++++-
CLAUDE.md | 178 ---------
CONTRIBUTING.md | 21 +
THREAT_MODEL.md | 4 +-
.../iotdb/db/it/IoTDBWriteMemoryLifecycleIT.java | 382 +++++++++++++++++++
.../iotdb/db/it/query/IoTDBCaseWhenThenIT.java | 26 ++
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 39 ++
.../session/it/SessionSeedNodeFallbackIT.java | 83 +++-
.../ConsensusSubscriptionTableITSupport.java | 28 ++
.../IoTDBConsensusSubscriptionFilterTableIT.java | 74 ++++
.../IoTDBSubscriptionColumnFilterIT.java | 111 ++++++
.../iotdb/rpc/subscription/config/TopicConfig.java | 55 +++
.../rpc/subscription/config/TopicConstant.java | 2 +
.../rpc/subscription/config/TopicProperty.java | 90 +++++
.../subscription/AbstractSubscriptionSession.java | 2 +-
.../base/AbstractSubscriptionConsumer.java | 7 +-
.../rpc/subscription/config/TopicConfigTest.java | 82 ++++
.../SubscriptionConsumerMultiProviderPollTest.java | 74 +++-
.../column/binary/LogicAndColumnTransformer.java | 2 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 9 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 9 +
.../persistence/subscription/SubscriptionInfo.java | 51 ++-
.../subscription/topic/AlterTopicProcedure.java | 1 +
.../SubscriptionInfoTopicValidationTest.java | 78 ++++
.../topic/AlterTopicProcedureTest.java | 34 ++
.../iotdb/consensus/ratis/RatisConsensus.java | 6 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 40 ++
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 88 +++++
.../iotdb/db/i18n/DataNodeQueryMessages.java | 6 +
.../iotdb/db/i18n/StorageEngineMessages.java | 9 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 90 +++++
.../iotdb/db/i18n/DataNodeQueryMessages.java | 6 +
.../iotdb/db/i18n/StorageEngineMessages.java | 9 +
.../db/pipe/event/common/PipeInsertionEvent.java | 3 +
.../batch/PipeTabletEventTsFileBatch.java | 162 +++++---
.../common/header/DatasetHeaderFactory.java | 4 +
.../execution/config/TableConfigTaskVisitor.java | 54 ++-
.../execution/config/TreeConfigTaskVisitor.java | 15 +-
.../config/executor/ClusterConfigTaskExecutor.java | 1 +
.../config/sys/subscription/ShowTopicsTask.java | 56 ++-
.../plan/node/pipe/PipeOperateSchemaQueueNode.java | 7 +
.../relational/sql/util/DataNodeSqlFormatter.java | 20 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 17 +-
.../db/storageengine/dataregion/DataRegion.java | 12 +-
.../storageengine/dataregion/DataRegionInfo.java | 27 +-
.../dataregion/flush/MemTableFlushTask.java | 164 ++++++--
.../dataregion/memtable/AbstractMemTable.java | 75 +++-
.../dataregion/memtable/IMemTable.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 300 +++++++++------
.../dataregion/memtable/TsFileProcessorInfo.java | 31 +-
.../dataregion/wal/io/ProgressWALReader.java | 4 +
.../dataregion/wal/io/WALByteBufReader.java | 4 +
.../dataregion/wal/io/WALInputStream.java | 45 ++-
.../wal/utils/MemoryControlledWALEntryQueue.java | 39 +-
.../rescon/memory/PrimitiveArrayManager.java | 58 ++-
.../db/storageengine/rescon/memory/SystemInfo.java | 55 ++-
.../rescon/memory/WriteMemoryBlock.java | 218 +++++++++++
.../rescon/memory/WriteMemoryManager.java | 76 ++++
.../agent/SubscriptionBrokerAgent.java | 159 ++++++++
.../subscription/agent/SubscriptionTopicAgent.java | 54 ++-
.../broker/SubscriptionPrefetchingQueue.java | 9 +-
.../consensus/ConsensusLogToTabletConverter.java | 61 ++-
.../consensus/ConsensusPrefetchingQueue.java | 10 +
.../ConsensusSubscriptionSetupHandler.java | 1 +
.../broker/consensus/ProgressWALIterator.java | 9 +
.../columnfilter/ColumnFilterParser.java | 5 +-
.../event/batch/SubscriptionFilterSnapshot.java | 125 ++++++
.../event/batch/SubscriptionPipeEventBatch.java | 6 +-
.../event/batch/SubscriptionPipeEventBatches.java | 54 ++-
.../batch/SubscriptionPipeTabletEventBatch.java | 155 +++-----
.../batch/SubscriptionPipeTsFileEventBatch.java | 122 +++++-
.../event/batch/SubscriptionTreeViewProjector.java | 126 ++++++
.../response/SubscriptionEventTabletResponse.java | 7 +-
.../db/subscription/tagfilter/TabletTagFilter.java | 251 ++++++++++++
.../tagfilter/TagFilterEvaluationException.java} | 30 +-
.../subscription/tagfilter/TagFilterEvaluator.java | 228 +++++++++++
.../subscription/tagfilter/TagFilterMatcher.java | 423 +++++++++++++++++++++
.../db/subscription/tagfilter/TagFilterParser.java | 94 +++++
.../TagFilterValidator.java} | 136 +++++--
.../db/utils/datastructure/AlignedTVList.java | 12 +-
.../batch/PipeTabletEventTsFileBatchTest.java | 38 ++
.../sys/subscription/ShowTopicsTaskTest.java | 98 +++++
.../node/pipe/PipeOperateSchemaQueueNodeTest.java} | 29 +-
.../relational/sql/parser/TopicStatementTest.java | 58 +++
.../binary/LogicBinaryColumnTransformerTest.java | 90 +++++
.../metric/SchemaMemMetricTableTest.java | 55 +++
.../dataregion/memtable/MemTableFlushTaskTest.java | 100 +++++
.../memtable/MemTableMemoryBlockTest.java | 167 ++++++++
.../dataregion/memtable/TsFileProcessorTest.java | 169 +++++++-
.../wal/compression/WALCompressionTest.java | 73 ++++
.../dataregion/wal/io/ProgressWALReaderTest.java | 75 ++++
.../rescon/memory/WriteMemoryBlockTest.java | 184 +++++++++
.../rescon/memory/WriteMemoryLifecycleTest.java | 133 +++++++
.../agent/SubscriptionTopicAgentTest.java | 63 +++
.../ConsensusLogToTabletConverterTest.java | 80 ++++
.../broker/consensus/ProgressWALIteratorTest.java | 3 +
.../batch/SubscriptionFilterSnapshotTest.java | 164 ++++++++
.../SubscriptionPipeTabletEventBatchTest.java | 28 ++
...ubscriptionPipeTsFileEventBatchCleanupTest.java | 32 ++
.../tagfilter/TabletTagFilterTest.java | 182 +++++++++
.../tagfilter/TagFilterParserTest.java | 122 ++++++
.../datastructure/PrimitiveArrayManagerTest.java | 122 ++++++
.../src/test/resources/iotdb-system.properties | 2 +-
.../reporter/prometheus/PrometheusReporter.java | 26 +-
.../prometheus/PrometheusReporterTest.java | 57 +++
.../apache/iotdb/commons/i18n/CommonMessages.java | 4 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 3 +
.../apache/iotdb/commons/memory/MemoryManager.java | 37 +-
.../iotdb/commons/memory/ReadOnlyMemoryBlock.java | 110 ++++++
.../iotdb/commons/request/IConsensusRequest.java | 8 +
.../schema/column/ColumnHeaderConstant.java | 9 +
.../commons/subscription/meta/topic/TopicMeta.java | 49 ++-
.../commons/memory/ReadOnlyMemoryBlockTest.java | 81 ++++
.../commons/subscription/topic/TopicMetaTest.java | 72 ++++
pom.xml | 1 -
115 files changed, 7175 insertions(+), 761 deletions(-)
mode change 120000 => 100644 AGENTS.md
delete mode 100644 CLAUDE.md
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBWriteMemoryLifecycleIT.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicProperty.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/WriteMemoryBlock.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/WriteMemoryManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionFilterSnapshot.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionTreeViewProjector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/tagfilter/TabletTagFilter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/BatchProcessException.java
=> subscription/tagfilter/TagFilterEvaluationException.java} (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/tagfilter/TagFilterEvaluator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/tagfilter/TagFilterMatcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/tagfilter/TagFilterParser.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/{columnfilter/ColumnFilterValidator.java
=> tagfilter/TagFilterValidator.java} (57%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/subscription/ShowTopicsTaskTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/{node/PlanNodeDeserializeHelper.java
=> plan/node/pipe/PipeOperateSchemaQueueNodeTest.java} (54%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemTableMemoryBlockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/WriteMemoryBlockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/rescon/memory/WriteMemoryLifecycleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionFilterSnapshotTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/tagfilter/TabletTagFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/tagfilter/TagFilterParserTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/ReadOnlyMemoryBlock.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/memory/ReadOnlyMemoryBlockTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/subscription/topic/TopicMetaTest.java
