This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch showAvailableUrls
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2a93dac1e58 Merge branch 'iotdb_master' into showAvailableUrls
add d8efd155c38 remove some column
add 205e373a013 Refactored the schema cache (#16446)
add 25427da164a Insert SQL authentication audit logs for table model
(#16450)
add 05072035af8 Fix vulnerability check (#16455)
add 13afc0348e1 Add IAuthorPlanExecutor
add 5d6609c6e17 Add auth check for show related
add 7cd568c5ded remove org.reflections:reflections, only test use it
add f431f050d7d Add UserId in IClientSession (#16459)
add 7972dd8a884 Fix authentication related CI
add 2b641fdc952 Fix CreateTraining IT
add db819be0db6 Fix some metric bugs
add 19834e45cd8 Pipe: Fixed the concurrency bug of stop / start (#16461)
add 33be57566cf Implement IAuditEntity interface for
TreeAccessCheckContext (#16469)
add 4da1c88a415 Connection limit function. (#16462)
add c9b441a212c Refactor TreeAccessCheckVisitor
add f2fb4a8ff1a Feature/client hide password (#16468)
add 877c1c0d857 Fix compatibility issues for userid (#16473)
add 19de5b10f38 Fix some sonar smell
add 5be7be25d14 Unify access control to AccessControl
add c7515420f12 fix jdbc-srouce.jar include an abs path on feature.xml
(#16484)
add 6de15db3b37 fix client win-cmd exec issue (#16480)
add 078301bec02 Fix jdbc feature.xml error (#16487)
add 4b65b8de02f Added some common interfaces for compatibility
add 7ad8778ea5f Load: Re-enabled the is aligned exception check
add c73e0c0de3b Fix more sonar
add 5ea679f3af3 Implement audit log for tree model (#16475)
add 4b2913050c7 Move password history under __audit (#16496)
add 2ed021362c7 Audit log patch for both tree and table models (#16497)
add 326850435b6 Revert recent updates about audit log (#16498)
add 4bdba5c953d Pipe: Reduced the conversion logger & Fixed the illegal
formats of PipeLogger (#16503)
add 8160a18727a reformat procedure
add 49e857287a6 spotless procedure
add 2d9afef27d2 Throw exception when client with ssl try to connect with
server without ssl (#16504)
add 26a0534b0fa Fix the issue of incorrect %IOTDB_HOME% setting when
running start-cli.bat with parameters in other directories (#16508)
add 755cf0149b4 Audit log big patch (#16501)
add 254f016b75c Fix that TableSchema written in TsFile can be stale after
drop/alter table (#16495)
add a6c5650d2d0 set executedByUserID for AuthorRelationalPlan (#16506)
add 2d44ef034e9 Support user rename (#16512)
add e03560fa653 Fix ratis TLS not working (#16510)
add b4dde12d4cf [AINode][Bug fix] Concurrent inference (#16518)
add e7fb8c38fe5 No need to retry when meets SSL Handshake error between DN
and CN (#16513)
add 5c39de0ccd4 Improve string array class name constant implementation​
(#16514)
add 8ec5aace9c8 Ignore device alignment in timeSeries auto-creation
(#16516)
add 91c51321f3b [To dev/1.3] Load: Optimized the exception error message
of convertion to tablet (#16499)
add 5e00ed5e815 update readme links (#16523)
add 677f9b8e164 Load: Added "skipFailedTableSchemaCheck" parameter (#16522)
add b2175ffa672 Added some common interfaces for compatibility
add dbdc4b43cd2 fix confignode start (#16527)
add 764cedcbfed Pipe: Fixed the potentially missing database auto-create
in receiver (#16529)
add 781a3c98dce Feature/login lock manager (#16494)
add d583362ab98 Optimized the value type check for update device (#16448)
add b86ea430b69 Create Multi Time Series: Modify logger level & Pipe:
Adjusted the show pipe privilege (#16439)
add 7235ec91305 Adjust encrypt config file. (#16528)
add c2696b33ae4 Add audit logic for login and logout event (#16520)
add 6d610816259 Revert "Adjust encrypt config file. (#16528)" (#16534)
add 32c80280eba Patch for rename user and audit log (#16535)
add e4081b90a2c [AINode] Fix: reduce package size (#16511)
add 451024279b8 [AINode] Fix compile bug (#16536)
add 080a810b4e8 Modify script to use local environment variable changes
and avoid pol… (#16541)
add c4fc2e9c7bf Use userId to record password history (#16542)
add f39cf38d570 Ignore data of deprecated table in compaction (#16543)
add 73a0cd8d399 No filtering audit DBs in some procdure & update idle time
after logging in
add 72c3e915f70 Fixed the failure of IoTDBDistinctTagIT
add e188287645f fix: Handle NaN results in approx_percentile evaluation
add 9a25d725313 fix login locked error message (#16550)
add 76852612417 User userId to check whether the user is admin in
ConfigNode (#16554)
add db28f95e901 Add method to convert author type
add 26aa85378f5 Fix NPE for audit func. (#16556)
add a7e042fae03 fix: count device operation
add a3116f46591 Fix initial old password not encrypted & bump TsFile
Version (#16557)
add d6c2719f95a Fix that quotes cannot be passed to start-cli-table.bat
(#16558)
add e9a01f53bdc Merge branch 'master' into showAvailableUrls
add 0bb6267cc1a record audit log
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 31 +-
.github/workflows/cluster-it-1c3d.yml | 26 +-
.github/workflows/compile-check.yml | 24 +-
.github/workflows/daily-it.yml | 208 ++-
.github/workflows/daily-ut.yml | 14 +-
.github/workflows/dependency-check.yml | 22 +-
.github/workflows/pipe-it.yml | 128 +-
.github/workflows/sonar-codecov.yml | 10 +-
.github/workflows/table-cluster-it-1c1d.yml | 33 +-
.github/workflows/table-cluster-it-1c3d.yml | 26 +-
.github/workflows/unit-test.yml | 22 +-
.github/workflows/vulnerability-check.yml | 12 +-
CONTRIBUTING.md | 2 +-
README.md | 18 +-
README_ZH.md | 17 +-
dependencies.json | 1 -
docker/ReadMe.md | 2 +-
example/jdbc/pom.xml | 8 +
.../it/env/cluster/config/MppCommonConfig.java | 24 +
.../env/cluster/config/MppSharedCommonConfig.java | 28 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 2 +-
.../it/env/remote/config/RemoteCommonConfig.java | 20 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 8 +
.../itbase/runtime/ClusterTestConnection.java | 10 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 4 +-
.../iotdb/itbase/runtime/NodeConnection.java | 12 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 84 +-
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 7 +-
.../iotdb/auth/it/IoTDBLoginLockManagerIT.java | 179 ++
...oTDBMultiDBRegionGroupLeaderDistributionIT.java | 3 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 2 +-
.../it/partition/IoTDBPartitionGetterIT.java | 2 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 4 +-
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 2 +-
.../java/org/apache/iotdb/db/it/IoTDBMiscIT.java | 2 +-
.../iotdb/db/it/audit/IoTDBAuditLogBasicIT.java | 1272 ++++++++++++++
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 51 +-
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 92 +-
.../it/auth/IoTDBClusterAuthorityRelationalIT.java | 61 +-
.../iotdb/db/it/auth/IoTDBTemplateAuthIT.java | 84 +-
.../apache/iotdb/db/it/auth/IoTDBUserRenameIT.java | 132 ++
.../iotdb/db/it/schema/IoTDBCountDeviceIT.java | 268 +++
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 12 +
.../iotdb/db/it/schema/IoTDBDeleteDatabaseIT.java | 3 +-
.../IoTDBPipeTypeConversionISessionIT.java | 114 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 91 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 4 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 56 +
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 85 +-
.../scalar/IoTDBBitwiseFunctionTableIT.java | 36 +-
.../it/query/recent/IoTDBDistinctTagIT.java | 2 +
.../it/query/recent/IoTDBTableAggregationIT.java | 36 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 9 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 4 +-
.../it/session/IoTDBSessionRelationalIT.java | 44 +-
.../iotdb/session/it/IoTDBSessionCompressedIT.java | 10 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 4 -
.../relational/table/argument/ScalarArgument.java | 22 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 10 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 6 +-
.../iotdb/tool/backup/IoTDBDataBackTool.java | 4 +-
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 2 +
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 12 +
iotdb-client/client-cpp/README.md | 2 +-
.../tests/integration/sqlalchemy/test_dialect.py | 2 +-
iotdb-client/jdbc/pom.xml | 4 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 1763 ++++++++++----------
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 14 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 572 +++----
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 2 -
.../apache/iotdb/rpc/TElasticFramedTransport.java | 17 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../iotdb/rpc/TElasticFramedTransportTest.java | 37 +
.../org/apache/iotdb/session/NodesSupplier.java | 12 +-
.../java/org/apache/iotdb/session/Session.java | 2 +-
.../iotdb/ainode/core/manager/inference_manager.py | 2 +-
iotdb-core/ainode/pyproject.toml | 56 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 4 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 27 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 9 +
iotdb-core/confignode/pom.xml | 11 +
.../iotdb/confignode/audit/CNAuditLogger.java | 21 +-
.../client/async/CnToDnAsyncRequestType.java | 3 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 4 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 9 +-
.../conf/ConfigNodeSystemPropertiesHandler.java | 23 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 18 +
.../request/ConfigPhysicalPlanVisitor.java | 4 +
.../consensus/request/write/auth/AuthorPlan.java | 48 +-
.../request/write/auth/AuthorRelationalPlan.java | 85 +-
.../request/write/auth/AuthorTreePlan.java | 92 +-
.../response/pipe/task/PipeTableResp.java | 3 +-
.../iotdb/confignode/manager/ConfigManager.java | 52 +-
.../confignode/manager/PermissionManager.java | 17 +-
.../iotdb/confignode/manager/ProcedureManager.java | 10 +-
.../manager/load/balancer/PartitionBalancer.java | 4 +-
.../region/GreedyCopySetRegionGroupAllocator.java | 4 +-
.../region/GreedyRegionGroupAllocator.java | 4 +-
.../manager/load/service/HeartbeatService.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 25 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 10 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 10 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 11 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 5 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 2 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 5 +-
.../pipe/source/ConfigRegionListeningFilter.java | 11 +-
.../confignode/persistence/auth/AuthorInfo.java | 211 +++
.../AuthorPlanExecutor.java} | 251 ++-
.../persistence/auth/IAuthorPlanExecutor.java | 62 +
.../persistence/executor/ConfigPlanExecutor.java | 12 +-
.../schema/CNPhysicalPlanGenerator.java | 18 +-
.../persistence/schema/TemplateTable.java | 8 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 17 +-
.../confignode/procedure/store/ProcedureType.java | 2 +
.../iotdb/confignode/service/ConfigNode.java | 6 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 33 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 4 +-
.../confignode/persistence/AuthorInfoTest.java | 5 +-
.../persistence/CNPhysicalPlanGeneratorTest.java | 28 +-
.../pipe/annotation/PipePluginAnnotationTest.java | 11 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedureTest.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 3 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 13 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 9 +-
.../utils/NoHostnameVerificationTrustManager.java | 88 +
.../apache/iotdb/consensus/ratis/utils/Utils.java | 25 +-
iotdb-core/datanode/pom.xml | 7 +
.../org/apache/iotdb/db/audit/AuditLogStorage.java | 30 -
.../org/apache/iotdb/db/audit/AuditLogger.java | 271 ---
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 259 ++-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 67 +-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 3 +
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 57 +-
.../org/apache/iotdb/db/auth/LoginLockManager.java | 396 +++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 90 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 5 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 7 +-
.../agent/task/connection/PipeEventCollector.java | 9 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 6 +
.../db/pipe/event/common/PipeInsertionEvent.java | 8 +
.../common/deletion/PipeDeleteDataNodeEvent.java | 19 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 6 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 10 +
.../schema/PipeSchemaRegionWritePlanEvent.java | 10 +-
.../statement/PipeStatementInsertionEvent.java | 6 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 20 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 24 +-
.../event/common/terminate/PipeTerminateEvent.java | 4 +
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 6 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 19 +-
.../table/TsFileInsertionEventTableParser.java | 9 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 12 +
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 9 +-
.../protocol/legacy/loader/DeletionLoader.java | 9 +-
.../protocol/legacy/loader/TsFileLoader.java | 9 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 44 +-
.../statement/PipeConvertedInsertRowStatement.java | 13 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 15 +-
.../client/IoTDBDataNodeSyncClientManager.java | 5 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 5 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 5 +-
.../sink/protocol/writeback/WriteBackSink.java | 27 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 13 +
.../realtime/PipeRealtimeDataRegionSource.java | 22 +
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +
.../matcher/CachedSchemaPatternMatcher.java | 23 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 9 +-
.../PipePlanTablePrivilegeParseVisitor.java | 36 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 56 +-
.../db/protocol/client/DataNodeInternalClient.java | 13 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 7 +-
.../protocol/rest/filter/AuthorizationFilter.java | 2 +
.../apache/iotdb/db/protocol/rest/filter/User.java | 9 +
.../rest/handler/AuthorizationHandler.java | 5 +-
.../iotdb/db/protocol/session/IClientSession.java | 10 +
.../iotdb/db/protocol/session/SessionManager.java | 210 +--
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 357 ++--
.../impl/DataNodeInternalRPCServiceImpl.java | 23 +-
.../db/queryengine/common/MPPQueryContext.java | 116 +-
.../iotdb/db/queryengine/common/SessionInfo.java | 75 +-
.../common/schematree/DeviceSchemaInfo.java | 12 +-
.../execution/executor/RegionWriteExecutor.java | 14 +-
.../fragment/FragmentInstanceContext.java | 7 +-
.../operator/schema/SchemaCountOperator.java | 54 +-
.../operator/schema/source/DeviceSchemaSource.java | 8 +
.../operator/schema/source/ISchemaSource.java | 4 +
.../InformationSchemaContentSupplierFactory.java | 122 +-
.../AbstractApproxPercentileAccumulator.java | 13 +-
.../aggregation/approximate/HyperLogLog.java | 11 +-
...AbstractGroupedApproxPercentileAccumulator.java | 13 +-
.../queue/IndexedBlockingReserveQueue.java | 3 +-
.../metric/DriverSchedulerMetricSet.java | 20 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 15 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 2 +-
.../analyze/cache/partition/PartitionCache.java | 34 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 2 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 9 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 100 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 20 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 36 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 4 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 36 -
.../plan/analyze/schema/SchemaValidator.java | 4 +-
.../execution/config/TableConfigTaskVisitor.java | 208 ++-
.../execution/config/TreeConfigTaskVisitor.java | 40 +-
.../config/executor/ClusterConfigTaskExecutor.java | 3 +-
.../config/metadata/ShowAvailableUrlsTask.java | 15 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 53 +-
.../plan/planner/OperatorTreeGenerator.java | 10 +-
.../plan/planner/TableOperatorGenerator.java | 2 +-
.../metadata/write/view/AlterLogicalViewNode.java | 44 +-
.../relational/analyzer/StatementAnalyzer.java | 49 +-
.../plan/relational/metadata/TableSchema.java | 12 +-
.../metadata/fetcher/SchemaPredicateUtil.java | 28 +-
.../fetcher/TableHeaderSchemaValidator.java | 45 +-
.../fetcher/cache/TableDeviceLastCache.java | 4 +
.../cache/TreeDeviceSchemaCacheManager.java | 155 +-
.../plan/relational/planner/TranslationMap.java | 2 +-
.../plan/relational/security/AccessControl.java | 84 +-
.../relational/security/AccessControlImpl.java | 353 ++--
.../relational/security/AllowAllAccessControl.java | 113 +-
.../relational/security/ITableAuthChecker.java | 48 +-
.../relational/security/ITableAuthCheckerImpl.java | 325 +++-
.../relational/security/TableModelPrivilege.java | 23 +
.../security/TreeAccessCheckContext.java | 119 +-
.../security/TreeAccessCheckVisitor.java | 986 ++++++++---
.../sql/ast/AbstractQueryDeviceWithCache.java | 3 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 2 +-
.../plan/relational/sql/ast/DeleteDevice.java | 5 +-
.../sql/ast/RelationalAuthorStatement.java | 49 +-
.../relational/sql/ast/WrappedInsertStatement.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 54 +-
.../plan/relational/type/AuthorRType.java | 5 +-
.../db/queryengine/plan/statement/AuthorType.java | 14 +-
.../queryengine/plan/statement/StatementType.java | 2 +
.../metadata/DeleteTimeSeriesStatement.java | 9 +
.../plan/statement/sys/AuthorStatement.java | 52 +-
.../statement/sys/ShowConfigurationStatement.java | 2 +
.../schemaregion/SchemaRegionLoader.java | 18 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 3 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 5 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 17 -
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 17 -
.../mtree/loader/MNodeFactoryLoader.java | 25 +-
.../template/ClusterTemplateManager.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 29 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 28 +-
.../metrics/IoTDBInternalLocalReporter.java | 15 +-
.../performer/impl/FastCompactionPerformer.java | 7 +-
.../impl/ReadChunkCompactionPerformer.java | 5 +-
.../impl/ReadPointCompactionPerformer.java | 6 +-
.../execute/utils/CompactionTableSchema.java | 11 +-
.../utils/CompactionTableSchemaCollector.java | 33 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 23 +
.../compaction/tool/SingleSequenceFileTask.java | 11 +-
.../compaction/tool/TimePartitionProcessTask.java | 9 +-
.../dataregion/memtable/TsFileProcessor.java | 5 +-
.../dataregion/modification/ModificationFile.java | 2 -
.../read/reader/chunk/MemAlignedPageReader.java | 3 +
.../read/reader/chunk/MemPageReader.java | 3 +
...rtedInsertTabletStatementExceptionVisitor.java} | 18 +-
...leStatementDataTypeConvertExecutionVisitor.java | 23 +-
...rtedInsertTabletStatementExceptionVisitor.java} | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 19 +-
.../converter/LoadTsFileDataTypeConverter.java | 8 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../agent/SubscriptionAgentLauncher.java | 4 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 25 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 16 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 5 +-
.../iotdb/db/tools/utils/TsFileStatisticScan.java | 6 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 164 +-
.../iotdb/db/utils/datastructure/BackwardSort.java | 3 +
.../apache/iotdb/db/auth/LoginLockManagerTest.java | 538 ++++++
.../auth/authorizer/LocalFileAuthorizerTest.java | 6 +-
.../cache/TreeDeviceSchemaCacheManagerTest.java | 19 +-
.../db/pipe/consensus/DeletionResourceTest.java | 2 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 2 +
.../annotation/PipePluginAnnotationTest.java | 11 +-
.../plan/parser/StatementGeneratorTest.java | 5 +
.../plan/relational/analyzer/AuthTest.java | 22 +-
.../CompactionTableSchemaCollectorTest.java | 8 +-
.../TableModelFastCompactionPerformerTest.java | 125 +-
...TableModelReadChunkCompactionPerformerTest.java | 94 +-
iotdb-core/metrics/ReadMe.md | 4 +-
iotdb-core/node-commons/pom.xml | 1 +
.../conf/iotdb-system.properties.template | 2 +-
.../iotdb/commons/audit/AbstractAuditLogger.java | 71 +-
.../apache/iotdb/commons/audit/AuditEventType.java | 4 +-
.../apache/iotdb/commons/audit/AuditLogFields.java | 118 +-
.../IAuditEntity.java} | 49 +-
.../org/apache/iotdb/commons/audit/UserEntity.java | 154 ++
.../commons/auth/authorizer/BasicAuthorizer.java | 36 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 11 +-
.../auth/authorizer/LocalFileAuthorizer.java | 5 -
.../commons/auth/authorizer/OpenIdAuthorizer.java | 6 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 35 +
.../org/apache/iotdb/commons/auth/entity/User.java | 7 +
.../commons/auth/role/LocalFileRoleAccessor.java | 18 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 132 +-
.../commons/auth/user/LocalFileUserAccessor.java | 10 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 28 +-
.../iotdb/commons/conf/CommonDescriptor.java | 10 +
.../iotdb/commons/conf/ConfigurationFileUtils.java | 3 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 6 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 6 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 4 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../pipe/config/constant/PipeSinkConstant.java | 6 +
.../pipe/config/constant/PipeSourceConstant.java | 6 +
.../pipe/config/constant/SystemConstant.java | 2 -
.../visibility/VisibilityTestUtils.java | 10 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 16 +
.../commons/pipe/event/PipeSnapshotEvent.java | 4 +
.../commons/pipe/event/PipeWritePlanEvent.java | 4 +
.../commons/pipe/event/ProgressReportEvent.java | 4 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 52 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 2 +-
.../pipe/sink/client/IoTDBClientManager.java | 7 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 12 +-
.../common/PipeTransferHandshakeConstant.java | 2 +
.../commons/pipe/sink/protocol/IoTDBSink.java | 15 +
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 5 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 4 +
.../iotdb/commons/pipe/source/IoTDBSource.java | 15 +
.../schema/column/ColumnHeaderConstant.java | 2 -
.../builtin/UDTFEqualSizeBucketRandomSample.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 3 +-
.../pipe/datastructure/PipeCommitQueueTest.java | 8 +
.../annotation/PipePluginAnnotationTest.java | 11 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 36 +-
.../src/main/thrift/confignode.thrift | 16 +
.../src/main/thrift/datanode.thrift | 11 +-
pom.xml | 4 +-
scripts/sbin/start-cli.sh | 9 +-
scripts/sbin/windows/start-cli-table.bat | 116 +-
scripts/sbin/windows/start-cli.bat | 234 +--
341 files changed, 11418 insertions(+), 4647 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/auth/it/IoTDBLoginLockManagerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/audit/IoTDBAuditLogBasicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBUserRenameIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBCountDeviceIT.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/auth/AuthorInfo.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/{AuthorInfo.java
=> auth/AuthorPlanExecutor.java} (90%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/auth/IAuthorPlanExecutor.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/NoHostnameVerificationTrustManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/AuditLogStorage.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/LoginLockManager.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/{LoadConvertedInsertTabletStatementExceptionVisitor.java
=> LoadTableConvertedInsertTabletStatementExceptionVisitor.java} (76%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/{LoadConvertedInsertTabletStatementExceptionVisitor.java
=> LoadTreeConvertedInsertTabletStatementExceptionVisitor.java} (97%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/LoginLockManagerTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{exception/IllegalPrivilegeException.java
=> audit/IAuditEntity.java} (51%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/UserEntity.java
