This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d39e9a354e9 Pipe IT: always throw exception with failure when
executing non-queries & Fixed some semantic errors of IT (#16331)
add 993ec2f07ac AuditLogger Implementation (#16428)
No new revisions were added by this update.
Summary of changes:
.../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/tool/data/ExportDataTree.java | 7 +-
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 2 +
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 5 +-
.../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 | 22 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 1 -
.../iotdb/db/protocol/thrift/OperationType.java | 3 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 27 ++
.../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 +
.../plan/planner/distribution/SourceRewriter.java | 31 ++
.../java/org/apache/iotdb/db/service/DataNode.java | 28 ++
.../iotdb/db/service/DataNodeShutdownHook.java | 21 ++
.../db/storageengine/dataregion/DataRegion.java | 3 +
.../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 +-
43 files changed, 1133 insertions(+), 81 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/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%)