This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch AuthEnhance
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 35419d60576 Merge branch 'AuthEnhance' of
https://github.com/apache/iotdb into AuthEnhance
add 89ef1337744 Revert: cannot reuse time and column array in
InsertTabletStatementGenerator (#16424)
add eb0d3cb9ce0 some tools use getColumnDisplaySize, No exceptions should
be thrown. (#16429)
add 84ac94d1d0c Fix ConfigNodeClient thread leak at DataRegion.java
(#16427)
add c7b459c43d0 move TabletDecoder to org.apache.iotdb.db.utils (#16433)
add 9e0316fe21e Fix concurrent last cache query bug because of one device
in multi regions
add dd6f958ee98 Optimize FetchSchema requests (#16434)
add 9cbb7738ce6 fix cpp session mem leak (#16443)
add 5e7a8c763a9 Avoid NPE for show variables task (#16444)
add c49c06878e1 Subscription: Prevent IllegalArgumentException in
SubscriptionLogStatus by validating bounds for nextLong (#16447)
add d39e9a354e9 Pipe IT: always throw exception with failure when
executing non-queries & Fixed some semantic errors of IT (#16331)
add 993ec2f07ac AuditLogger Implementation (#16428)
add 316410ee709 resolve conflicts
No new revisions were added by this update.
Summary of changes:
.../src/TableModelSessionExample.cpp | 4 +-
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 15 +
.../IoTDBAutoRegionGroupExtension2IT.java | 2 +
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 3 +
.../it/partition/IoTDBPartitionCreationIT.java | 6 +
.../it/partition/IoTDBPartitionDurableIT.java | 12 +
...IoTDBRegionOperationReliabilityITFramework.java | 10 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 91 ++++-
.../pipe/it/dual/tablemodel/TableModelUtils.java | 25 +-
.../tablemodel/manual/basic/IoTDBPipeAlterIT.java | 18 +-
.../manual/basic/IoTDBPipeDataSinkIT.java | 217 +++++-------
.../manual/basic/IoTDBPipeLifeCycleIT.java | 193 +++--------
.../manual/basic/IoTDBPipePermissionIT.java | 85 +++--
.../manual/basic/IoTDBPipeProtocolIT.java | 58 +---
.../tablemodel/manual/basic/IoTDBPipeSourceIT.java | 264 +++++---------
.../manual/basic/IoTDBPipeSwitchStatusIT.java | 7 +-
.../manual/basic/IoTDBPipeWithLoadIT.java | 7 +-
.../manual/basic/IoTDBTablePatternFormatIT.java | 287 +++++----------
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 13 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 138 +++-----
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 83 ++---
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 32 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 72 ++--
.../enhanced/IoTDBPipeSinkCompressionIT.java | 18 +-
.../manual/enhanced/IoTDBPipeSinkParallelIT.java | 6 +-
.../IoTDBPipeTypeConversionISessionIT.java | 4 +-
.../manual/enhanced/IoTDBPipeTypeConversionIT.java | 14 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java | 4 +-
.../treemodel/auto/basic/IoTDBPipeAlterIT.java | 23 +-
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 79 ++---
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 200 ++++-------
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 12 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 52 +--
.../auto/basic/IoTDBPipeSinkParallelIT.java | 6 +-
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 94 ++---
.../auto/basic/IoTDBPipeSwitchStatusIT.java | 9 +-
.../auto/basic/IoTDBTreePatternFormatIT.java | 18 +-
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 104 ++----
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 12 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 130 +++----
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 15 +-
.../auto/enhanced/IoTDBPipeNullValueIT.java | 28 +-
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 18 +-
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 12 +-
.../manual/AbstractPipeDualTreeModelManualIT.java | 4 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 39 +--
.../manual/IoTDBPipeManualConflictIT.java | 24 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 28 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 28 +-
.../treemodel/manual/IoTDBPipeMetaRestartIT.java | 23 +-
.../manual/IoTDBPipeMultiSchemaRegionIT.java | 12 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 83 ++---
.../treemodel/manual/IoTDBPipeReqAutoSliceIT.java | 4 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 5 +-
.../manual/IoTDBPipeTypeConversionIT.java | 15 +-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 18 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 15 +-
.../pipe/it/single/IoTDBPipePermissionIT.java | 60 +---
.../it/query/recent/IoTDBTableAggregation2IT.java | 1 -
.../recent/IoTDBTableAggregationNonStream2IT.java | 1 -
.../IoTDBSubscriptionConsumerGroupIT.java | 58 ++--
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 12 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 7 +-
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 2 +
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 5 +-
iotdb-client/client-cpp/src/main/SessionBuilder.h | 6 +-
iotdb-client/client-cpp/src/main/TableSession.h | 12 +-
.../client-cpp/src/main/TableSessionBuilder.h | 6 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 4 +-
.../iotdb/confignode/audit/CNAuditLogger.java | 89 +++++
.../async/AsyncDataNodeHeartbeatClientPool.java | 11 +
.../audit/DataNodeWriteAuditLogHandler.java} | 42 +--
.../iotdb/confignode/manager/ConfigManager.java | 17 +
.../apache/iotdb/confignode/manager/IManager.java | 11 +
.../runtime/PipeLeaderChangeHandler.java | 4 +-
.../manager/schema/ClusterSchemaManager.java | 14 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 2 +
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 6 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 384 +++++++++++++++++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 50 ++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 +-
.../iotdb/db/protocol/thrift/OperationType.java | 3 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 27 ++
.../execution/fragment/DataNodeQueryContext.java | 68 +++-
.../process/InsertTabletStatementGenerator.java | 39 +--
.../TableInsertTabletStatementGenerator.java | 2 +-
.../TreeInsertTabletStatementGenerator.java | 2 +-
.../relational/LastQueryAggTableScanOperator.java | 99 ++++--
.../analyze/cache/partition/PartitionCache.java | 9 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 2 +
.../plan/analyze/schema/NormalSchemaFetcher.java | 11 +-
.../execution/config/TableConfigTaskVisitor.java | 12 +
.../execution/config/TreeConfigTaskVisitor.java | 12 +
.../config/executor/ClusterConfigTaskExecutor.java | 8 +-
.../plan/parser/StatementGenerator.java | 2 +-
.../plan/planner/TableOperatorGenerator.java | 60 +++-
.../plan/planner/distribution/SourceRewriter.java | 31 ++
.../metadata/cache/DeviceSchemaRequestCache.java | 88 +++++
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 13 +
.../distribute/TableDistributedPlanGenerator.java | 3 +
.../distribute/TableModelQueryFragmentPlanner.java | 42 +++
.../planner/node/AggregationTableScanNode.java | 62 ++++
.../java/org/apache/iotdb/db/service/DataNode.java | 28 ++
.../iotdb/db/service/DataNodeShutdownHook.java | 21 ++
.../db/storageengine/dataregion/DataRegion.java | 13 +-
.../resource/log/SubscriptionLogStatus.java | 2 +-
.../iotdb/{util => db/utils}/TabletDecoder.java | 2 +-
.../iotdb/commons/audit/AbstractAuditLogger.java | 112 ++++++
.../iotdb/commons/audit/AuditEventType.java} | 45 ++-
.../apache/iotdb/commons/audit/AuditLogFields.java | 92 +++++
.../iotdb/commons}/audit/AuditLogOperation.java | 4 +-
.../iotdb/commons/audit/PrivilegeLevel.java} | 8 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 79 +++++
.../iotdb/commons/conf/CommonDescriptor.java | 20 +-
.../pipe/config/constant/SystemConstant.java | 3 +
.../iotdb/commons/schema/SchemaConstant.java | 1 +
.../src/main/thrift/datanode.thrift | 22 +-
118 files changed, 2598 insertions(+), 2068 deletions(-)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/audit/CNAuditLogger.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/{consensus/response/database/CountDatabaseResp.java
=> client/async/handlers/audit/DataNodeWriteAuditLogHandler.java} (53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/DNAuditLogger.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/cache/DeviceSchemaRequestCache.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/{util =>
db/utils}/TabletDecoder.java (99%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/AbstractAuditLogger.java
copy
iotdb-core/{metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/SystemType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/audit/AuditEventType.java}
(59%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/AuditLogFields.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/audit/AuditLogOperation.java
(94%)
copy
iotdb-core/{metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/NodeType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/audit/PrivilegeLevel.java}
(90%)
