This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/show-receivers
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d6650ef1e37 [IT] Fix receiver test merge selection
add dc47a3baa0a Stabilize air-gap batch compression IT
add ada62cb1048 [Pipe] Fix conversion task ID collision after leader
switch (#18494)
add 5221cf49ed0 fix: make CompactionWorkerTest UT deterministic by using
CountDownLatch instead of fixed 2s sleep to wait for task drop status reset
(#18498)
add c63d0e82efc [DOC] Clarify internal RPC trust boundary in threat model
(#18504)
add c8e73f30ac3 Add the setting for JAVA_HOME in the start-cli.bat file
(#18503)
add 541b9a32d8e Fix unsolicited AirGap responses on idle timeout (#18502)
add 41c0e2d4ee8 [Subscription] Isolate tree and table consensus topics
(#18469)
add e591e66c0f5 Fix IoTConsensus batch accumulation and config reload
(#18501)
add fdce12d7972 Fix subscription event loss on poll payload overflow
(#18471)
add a4e56ce5c2f [Subscription] Fix WAL replay after leader failover
(#18474)
add 0a9fda0a4c3 [Subscription] Reduce consensus commit warning log noise
(#18450)
add c0c1d562aa0 [Pipe] Reject operations while pipe is being dropped
(#18485)
add 429587f629a Load: preserve pending tablets when parser fails (#18487)
add 91a44fd8c00 [Pipe] Split OPC UA sink requests by advertised server
limits (#18486)
add 20ce15e04a5 Fix fail-open authorization for pipe config plans (#18488)
add 6be80261199 Supported "need last cache" semantic for table/database
schema (#15538)
add 83f6303c253 Add TLS channel failure reporting hooks (#18299)
add ae163537785 [Subscription] Protect retained WAL by committed progress
(#18399)
add 86c37d0055a Merge branch 'master' of https://github.com/apache/iotdb
into feat/show-receivers
No new revisions were added by this update.
Summary of changes:
THREAT_MODEL.md | 41 ++-
external-service-impl/rest/pom.xml | 4 +
.../java/org/apache/iotdb/rest/RestService.java | 4 +
.../rest/TrustedChannelAuditHandshakeListener.java | 75 ++++
.../TrustedChannelAuditHandshakeListenerTest.java | 96 +++++
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 4 +-
.../it/single/IoTDBPipeOperationDiagnosticsIT.java | 395 +++++++++++++++++++++
.../relational/it/schema/IoTDBDatabaseIT.java | 127 +++++--
.../iotdb/relational/it/schema/IoTDBTableIT.java | 125 ++++++-
iotdb-client/client-cpp/examples/README.md | 4 +-
iotdb-client/client-cpp/examples/README_zh.md | 4 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 1 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 3 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 3 +
.../pipe/coordinator/task/PipeTaskCoordinator.java | 24 ++
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 21 +-
.../manager/schema/ClusterSchemaManager.java | 76 +++-
.../confignode/persistence/pipe/PipeTaskInfo.java | 11 +
.../persistence/schema/ClusterSchemaInfo.java | 20 ++
.../confignode/persistence/schema/ConfigMTree.java | 5 +
.../impl/schema/table/CreateTableProcedure.java | 4 +
.../table/view/CreateTableViewProcedure.java | 9 +
.../service/thrift/ConfigNodeRPCService.java | 8 +-
.../manager/ClusterSchemaManagerTest.java | 15 +
.../iotdb/consensus/config/ConsensusConfig.java | 23 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 9 +-
.../consensus/iot/IoTConsensusServerImpl.java | 17 +-
.../logdispatcher/IoTConsensusMemoryManager.java | 6 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 31 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 7 +-
.../iot/service/IoTConsensusRPCService.java | 16 +-
.../subscription/SubscriptionQueueRegistry.java | 55 ++-
.../SubscriptionWalRetentionCalculator.java | 12 +-
.../iotdb/consensus/pipe/IoTConsensusV2.java | 4 +-
.../pipe/service/IoTConsensusV2RPCService.java | 16 +-
.../IoTConsensusMemoryManagerTest.java | 22 ++
.../iot/logdispatcher/LogDispatcherTest.java | 224 ++++++++++++
.../SubscriptionWalRetentionCalculatorTest.java | 101 ++++++
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../db/consensus/DataRegionConsensusImpl.java | 3 +
.../protocol/airgap/IoTDBAirGapReceiver.java | 49 ++-
.../request/PipeTransferTsFileSealWithModReq.java | 11 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 113 +++++-
.../execution/exchange/MPPDataExchangeService.java | 7 +-
.../InformationSchemaContentSupplierFactory.java | 3 +
.../plan/analyze/ClusterPartitionFetcher.java | 4 +
.../plan/analyze/IPartitionFetcher.java | 2 +
.../analyze/cache/partition/PartitionCache.java | 81 ++++-
.../execution/config/TableConfigTaskVisitor.java | 69 +++-
.../config/metadata/DatabaseSchemaTask.java | 3 +
.../metadata/relational/AbstractDatabaseTask.java | 1 +
.../metadata/relational/ShowCreateTableTask.java | 8 +-
.../config/metadata/relational/ShowDBTask.java | 1 +
.../metadata/relational/ShowTablesDetailsTask.java | 3 +
.../db/queryengine/plan/parser/ASTVisitor.java | 7 +
.../relational/metadata/TableMetadataImpl.java | 2 +
.../fetcher/cache/TableDeviceSchemaCache.java | 38 +-
.../cache/TreeDeviceSchemaCacheManager.java | 9 +
.../metadata/DatabaseSchemaStatement.java | 15 +
.../statement/metadata/ShowDatabaseStatement.java | 1 +
.../db/schemaengine/table/DataNodeTableCache.java | 21 ++
.../schemaengine/table/InformationSchemaUtils.java | 4 +-
.../db/service/DataNodeInternalRPCService.java | 8 +-
.../iotdb/db/service/ExternalRPCService.java | 14 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 63 +++-
.../agent/SubscriptionBrokerAgent.java | 27 +-
.../broker/ConsensusSubscriptionBroker.java | 49 ++-
.../subscription/broker/ISubscriptionBroker.java | 3 +
.../db/subscription/broker/SubscriptionBroker.java | 21 +-
.../broker/SubscriptionPrefetchingQueue.java | 33 ++
.../consensus/ConsensusPrefetchingQueue.java | 280 +++++++++++++--
.../ConsensusSubscriptionCommitManager.java | 4 +-
.../ConsensusSubscriptionSetupHandler.java | 47 ++-
.../db/subscription/event/SubscriptionEvent.java | 5 +
.../receiver/SubscriptionReceiverV1.java | 14 +-
.../cache/TreeDeviceSchemaCacheManagerTest.java | 29 ++
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 69 ++++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 30 ++
.../opcua/client/IoTDBOpcUaClientTest.java | 94 +++++
.../plan/analyze/cache/PartitionCacheTest.java | 31 +-
.../config/metadata/DatabaseSchemaTaskTest.java | 57 +++
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 184 ++++++++--
.../compaction/CompactionWorkerTest.java | 58 ++-
...atementDataTypeConvertExecutionVisitorTest.java | 59 +++
...onsensusSubscriptionBrokerPayloadLimitTest.java | 93 +++++
.../SubscriptionBrokerAgentPayloadLimitTest.java | 104 ++++++
.../consensus/ConsensusPrefetchingQueueTest.java | 194 ++++++++++
.../ConsensusSubscriptionSetupHandlerTest.java | 35 ++
.../broker/consensus/ProgressWALIteratorTest.java | 11 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 2 +
.../iotdb/commons/audit/AbstractAuditLogger.java | 75 ++++
.../apache/iotdb/commons/audit/AuditEventType.java | 2 +-
.../audit/TrustedChannelFailureHandler.java | 12 +-
.../pipe/agent/plugin/meta/PipePluginMeta.java | 13 +-
.../service/PipePluginExecutableManager.java | 60 +++-
.../schema/column/ColumnHeaderConstant.java | 11 +-
.../commons/schema/table/InformationSchema.java | 8 +
.../iotdb/commons/schema/table/TreeViewSchema.java | 2 +
.../apache/iotdb/commons/schema/table/TsTable.java | 26 +-
.../TrustedChannelAuditServerEventHandler.java | 152 ++++++++
.../org/apache/iotdb/commons/utils/FileUtils.java | 16 +
.../commons/audit/AbstractAuditLoggerTest.java | 152 ++++++++
.../service/PipePluginExecutableManagerTest.java | 111 ++++++
.../pipe/plugin/meta/PipePluginMetaTest.java | 17 +
.../TrustedChannelAuditServerEventHandlerTest.java | 220 ++++++++++++
.../src/main/thrift/confignode.thrift | 3 +
pom.xml | 5 +
scripts/sbin/windows/start-cli.bat | 1 +
112 files changed, 4328 insertions(+), 272 deletions(-)
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/TrustedChannelAuditHandshakeListener.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/TrustedChannelAuditHandshakeListenerTest.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOperationDiagnosticsIT.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcherTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionWalRetentionCalculatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/DatabaseSchemaTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBrokerPayloadLimitTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/SubscriptionBrokerAgentPayloadLimitTest.java
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/QueryEndPointPolicy.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/TrustedChannelFailureHandler.java
(74%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/TrustedChannelAuditServerEventHandler.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/audit/AbstractAuditLoggerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/agent/plugin/service/PipePluginExecutableManagerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/TrustedChannelAuditServerEventHandlerTest.java
