This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch codex/ratis-historical-replay-20261029
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f6dedbdddf5 Fix Pipe coordinator drop races and Ratis PlanNode
admission
add 574d5eb6278 Implement UDP transport for air-gap sink (#17954)
add d4ea1fabcc9 Fix interrupted snapshot subscription delivery (#19040)
add 5d3e2eb121e Preserve unlisted pipes in partial metadata updates
(#19043)
add 45c46be6f0a Fix IT classes that are never executed in CI (#19052)
add 45a78ca18e1 Avoid empty pipe metadata sync on retained subscription
unsubscribe (#19055)
add 1c2e3c8e88f Bump org.xerial.snappy:snappy-java from 1.1.10.5 to
1.1.10.9 (#19038)
add 56aca60610f Document IT discovery and reliability guidelines (#19058)
add 45c962bc4c2 Fix the identity used by the asynchronous LOAD of the pipe
receiver (#19029)
add 3f36587d7c4 Downgrade the level of log when auto sync column schema
(#19060)
add 378196eaf6c [Subscription] Preserve trailing consensus progress
broadcasts (#19057)
add 3a51384b2dc Fix flaky SHOW RECEIVERS lifecycle assertions (#19061)
add 913970788f7 Merge master into codex/ratis-historical-replay-20261029
No new revisions were added by this update.
Summary of changes:
.github/scripts/build-it-shard-list.sh | 52 +++
.github/scripts/check-it-selection.py | 277 ++++++++++++++
.github/workflows/cluster-it-1c1d.yml | 20 +-
.github/workflows/pipe-it.yml | 70 +---
.github/workflows/table-cluster-it-1c1d.yml | 18 +-
LICENSE-binary | 2 +-
integration-test/AGENTS.md | 81 +++-
.../IoTDBRegionMigrateWithCompressionRatioIT.java | 6 +
.../IoTDBRegionMigrateWithLastEmptyDeletionIT.java | 6 +
.../iotdb/db/it/IoTDBCustomizedClusterIT.java | 7 +-
.../iotdb/db/it/IoTDBLoadTsFileClusterIT.java | 247 +++++++++---
.../db/it/aligned/IoTDBAlignedMemQueryIT.java | 7 +
.../db/it/query/IoTDBLoadEncryptedTsFileIT.java | 7 +
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 2 +
.../iotdb/db/it/schema/IoTDBDatabaseQuotaIT.java | 4 +
.../db/it/schema/quota/IoTDBClusterMixQuotaIT.java | 9 +-
.../db/it/schema/quota/IoTDBClusterQuotaIT.java | 40 +-
...nScanIT2.java => IoTDBActiveRegionScan2IT.java} | 4 +-
....java => IoTDBActiveRegionScanWithMods2IT.java} | 4 +-
.../auto/basic/IoTDBShowReceiversLifecycleIT.java | 4 +
.../single/IoTDBPipeReceiverAsyncLoadAuthIT.java | 413 +++++++++++++++++++++
.../iotdb/pipe/it/single/IoTDBShowReceiversIT.java | 4 +-
...umnTest.java => IoTDBTableViewAddColumnIT.java} | 9 +-
.../IoTDBTableViewQueryWithCachedDeviceIT.java | 7 +
.../iotdb/session/it/IoTDBSessionComplexIT.java | 2 +
.../iotdb/session/it/IoTDBSessionCompressedIT.java | 25 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 3 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 2 +
.../iotdb/confignode/i18n/ManagerMessages.java | 3 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 3 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 1 +
.../iotdb/confignode/i18n/ManagerMessages.java | 3 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 3 +-
.../rpc/TreeDeviceViewFieldDetectionHandler.java | 56 +++
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 29 ++
.../manager/schema/ClusterSchemaManager.java | 2 -
.../impl/schema/table/AddTableColumnProcedure.java | 2 +-
.../subscription/DropSubscriptionProcedure.java | 32 +-
.../DropSubscriptionProcedureTest.java | 19 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 2 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 5 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 2 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 28 ++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 11 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 43 +++
.../protocol/airgap/IoTDBAirGapReceiver.java | 163 ++++++--
.../protocol/airgap/IoTDBAirGapReceiverAgent.java | 177 ++++++++-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 154 +++++---
.../thrift/IoTDBDataNodeReceiverAgent.java | 24 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 4 +-
.../table/ViewColumnAutoSyncTrigger.java | 32 +-
.../converter/LoadTsFileDataTypeConverter.java | 89 +++--
.../iotdb/db/storageengine/load/util/LoadUtil.java | 25 +-
.../broker/SubscriptionPrefetchingQueue.java | 25 +-
.../ConsensusSubscriptionCommitManager.java | 141 ++++++-
.../db/subscription/event/SubscriptionEvent.java | 5 +-
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 141 +++++++
.../airgap/IoTDBAirGapReceiverAgentTest.java | 120 ++++++
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 110 +++++-
.../IoTDBDataNodeReceiverAuditEntityTest.java | 79 ++++
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 20 +-
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 238 +++++++++++-
.../db/storageengine/load/util/LoadUtilTest.java | 62 ++++
.../SubscriptionPrefetchingQueueRecoveryTest.java | 178 +++++++++
.../ConsensusSubscriptionCommitBroadcastTest.java | 288 ++++++++++++++
.../apache/iotdb/commons/i18n/PipeMessages.java | 10 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 10 +
.../pipe/config/constant/PipeSinkConstant.java | 20 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 74 +++-
.../pipe/sink/protocol/IoTDBAirGapSink.java | 290 ++++++++++++++-
.../pipe/receiver/IoTDBFileReceiverTest.java | 147 +++++++-
pom.xml | 2 +-
76 files changed, 3837 insertions(+), 382 deletions(-)
create mode 100644 .github/scripts/build-it-shard-list.sh
create mode 100644 .github/scripts/check-it-selection.py
rename
integration-test/src/test/java/org/apache/iotdb/db/it/schema/regionscan/{IoTDBActiveRegionScanIT2.java
=> IoTDBActiveRegionScan2IT.java} (93%)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/schema/regionscan/{IoTDBActiveRegionScanWithModsIT2.java
=> IoTDBActiveRegionScanWithMods2IT.java} (93%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeReceiverAsyncLoadAuthIT.java
rename
integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/{IoTDBTableViewAddColumnTest.java
=> IoTDBTableViewAddColumnIT.java} (88%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiverAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiverAuditEntityTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueueRecoveryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionCommitBroadcastTest.java
