You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by sp...@apache.org on 2023/07/10 08:17:43 UTC
[iotdb] 01/01: Merge branch 'master' into refactor/new_auth
This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a commit to branch refactor/new_auth
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5377e2fda3af1245d27c5e4a9490ed6dbf5b6b19
Merge: f38a47d0f59 ab8743e8bd5
Author: spricoder <sp...@qq.com>
AuthorDate: Mon Jul 10 16:16:57 2023 +0800
Merge branch 'master' into refactor/new_auth
.github/workflows/client-python.yml | 2 +-
.github/workflows/cluster-it-1c1d.yml | 13 +-
.github/workflows/cluster-it-1c3d.yml | 30 +-
.github/workflows/main-unix.yml | 66 -
.github/workflows/{main-win.yml => unit-test.yml} | 33 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 4 +-
docs/UserGuide/Reference/SQL-Reference.md | 2 +-
.../UserGuide/API/Programming-Java-Native-API.md | 93 +
.../Administration-Management/Administration.md | 4 +-
.../{Data-Concept => Basic-Concept}/Compression.md | 0
.../Data-Model-and-Terminology.md | 96 +-
.../{Data-Concept => Basic-Concept}/Data-Type.md | 0
.../Deadband-Process.md | 0
.../Encoding-and-Compression.md} | 42 +-
.../{Data-Concept => Basic-Concept}/Encoding.md | 0
.../Schema-Template.md | 0
.../Time-Partition.md | 0
.../{Data-Concept => Basic-Concept}/Time-zone.md | 0
docs/zh/UserGuide/Delete-Data/Delete-Data.md | 2 +-
.../Deployment-and-Maintenance/Deployment-Guide.md | 655 +++
.../Deployment-and-Maintenance/Docker-Install.md | 156 +
.../Environmental-Requirement.md | 36 +
.../Get-Installation-Package.md | 84 +
.../Security-Management.md | 537 ++
.../Ecosystem-Integration/Grafana-Plugin.md | 2 +-
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 6 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 362 ++
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 102 +-
docs/zh/UserGuide/IoTDB-Introduction/Scenario.md | 75 +-
.../UserGuide/Maintenance-Tools/Watermark-Tool.md | 196 +
.../Operate-Metadata/Auto-Create-MetaData.md | 2 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
docs/zh/UserGuide/Query-Data/Select-Into.md | 2 +-
docs/zh/UserGuide/Query-Data/Where-Condition.md | 2 +-
docs/zh/UserGuide/QuickStart/ClusterQuickStart.md | 23 +-
.../UserGuide/QuickStart/General-SQL-Statements.md | 159 +
.../zh/UserGuide/Reference/Common-Config-Manual.md | 12 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 2 +-
docs/zh/UserGuide/SQL-Manual/SQL-Manual.md | 2511 ++++++++
.../Syntax-Conventions/Session-And-TsFile-API.md | 2 +-
docs/zh/UserGuide/Tools-System/Benchmark.md | 368 ++
docs/zh/UserGuide/Tools-System/CLI.md | 276 +
.../UserGuide/Tools-System/Import-Export-Tool.md | 427 ++
docs/zh/UserGuide/Tools-System/Maintenance-Tool.md | 388 ++
docs/zh/UserGuide/Tools-System/Monitor-Tool.md | 109 +
.../UserGuide/User-Manuel/Authority-Management.md | 535 ++
.../UserGuide/User-Manuel/Database-Programming.md | 6079 ++++++++++++++++++++
.../{Delete-Data => User-Manuel}/Delete-Data.md | 70 +-
.../Operate-Metadata.md} | 746 ++-
.../User-Manuel/Operator-and-Expression.md | 849 +++
docs/zh/UserGuide/User-Manuel/Query-Data.md | 2845 +++++++++
docs/zh/UserGuide/User-Manuel/Syntax-Rule.md | 287 +
docs/zh/UserGuide/User-Manuel/Trigger.md | 467 ++
docs/zh/UserGuide/User-Manuel/Write-Delete-Data.md | 256 +
.../iotdb/db/it/query/IoTDBArithmeticIT.java | 18 +
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 5 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 32 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 42 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 43 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 14 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 14 +-
.../db/it/schema/view/IoTDBAliasSeriesIT.java | 29 +
.../iotdb/db/it/schema/view/IoTDBAlterViewIT.java | 54 +
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 29 +
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 12 +-
.../iotdb/pipe/api/exception/PipeException.java | 13 +
iotdb-client/client-py/requirements.txt | 3 +-
iotdb-client/client-py/requirements_dev.txt | 3 +-
iotdb-client/client-py/tests/test_dataframe.py | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 19 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 21 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 31 +-
.../client/async/AsyncDataNodeClientPool.java | 3 +-
.../client/async/handlers/AsyncClientHandler.java | 11 +-
.../async/handlers/rpc/PipePushMetaRPCHandler.java | 87 +
.../response/pipe/task/PipeTableResp.java | 19 +-
.../statemachine/ConfigRegionStateMachine.java | 5 +-
.../confignode/manager/RetryFailedTasksThread.java | 4 +-
.../iotdb/confignode/manager/cq/CQManager.java | 5 +-
.../manager/load/service/HeartbeatService.java | 4 +-
.../manager/load/service/StatisticsService.java | 4 +-
.../manager/partition/PartitionManager.java | 4 +-
.../manager/pipe/runtime/PipeHeartbeatParser.java | 28 +-
.../manager/pipe/runtime/PipeMetaSyncer.java | 5 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 16 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 115 +-
.../confignode/procedure/ProcedureExecutor.java | 13 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 8 +-
.../procedure/env/DataNodeRemoveHandler.java | 2 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 137 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 3 +
.../runtime/PipeHandleLeaderChangeProcedure.java | 12 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 31 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 24 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 11 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 27 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 19 +-
.../iotdb/confignode/service/ConfigNode.java | 43 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 3 +-
.../consensus/iot/IoTConsensusServerImpl.java | 2 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 10 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 6 +-
.../src/assembly/resources/sbin/start-datanode.bat | 4 +-
.../apache/iotdb/db/audit/AuditLogOperation.java | 1 +
.../org/apache/iotdb/db/audit/AuditLogStorage.java | 1 +
.../org/apache/iotdb/db/audit/AuditLogger.java | 1 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 12 +-
.../apache/iotdb/db/auth/AuthorizerManager.java | 8 +-
.../exception/metadata/PathNotExistException.java | 8 +
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 43 +-
.../org/apache/iotdb/db/pipe/task/PipeBuilder.java | 2 +-
.../iotdb/db/pipe/task/stage/PipeTaskStage.java | 2 +-
.../subtask/connector/PipeConnectorSubtask.java | 4 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../connector/PipeConnectorSubtaskManager.java | 4 +-
.../rest/handler/AuthorizationHandler.java | 3 +-
.../rest/v1/handler/QueryDataSetHandler.java | 21 +-
.../rest/v2/handler/QueryDataSetHandler.java | 21 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 94 +-
.../common/schematree/ClusterSchemaTree.java | 14 +-
.../queryengine/execution/load/TsFileSplitter.java | 26 +-
.../execution/schedule/AbstractDriverThread.java | 24 +-
.../execution/schedule/DriverScheduler.java | 2 +-
.../execution/schedule/DriverTaskThread.java | 2 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 6 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 1 +
.../analyze/schema/AutoCreateSchemaExecutor.java | 32 +-
.../plan/expression/multi/FunctionExpression.java | 38 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 174 +-
.../node/metedata/write/ActivateTemplateNode.java | 16 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 9 +-
.../metedata/write/BatchActivateTemplateNode.java | 16 +-
.../planner/plan/node/process/AggregationNode.java | 1 +
.../plan/node/source/AlignedLastQueryScanNode.java | 20 +-
.../source/AlignedSeriesAggregationScanNode.java | 8 +-
.../plan/node/source/AlignedSeriesScanNode.java | 8 +-
.../plan/parameter/AggregationDescriptor.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 23 +-
.../dag/udf/UDTFInformationInferrer.java | 1 -
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 6 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 7 +-
.../impl/mem/mnode/impl/AboveDatabaseMNode.java | 1 +
.../impl/mem/mnode/impl/BasicInternalMNode.java | 13 +-
.../mtree/impl/mem/mnode/info/BasicMNodeInfo.java | 1 +
.../mnode/iterator/AbstractTraverserIterator.java | 1 +
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 2 +-
.../mtree/impl/pbtree/cache/CacheManager.java | 25 +-
.../impl/pbtree/cache/CacheMemoryManager.java | 18 +
.../impl/pbtree/schemafile/AliasIndexPage.java | 38 +-
.../schemafile/pagemgr/BTreePageManager.java | 7 +-
.../read/req/impl/AbstractShowSchemaPlanImpl.java | 8 +-
.../impl/ActivateTemplateInClusterPlanImpl.java | 4 +-
.../req/impl/AutoCreateDeviceMNodePlanImpl.java | 4 +-
.../req/impl/view/AlterLogicalViewPlanImpl.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 58 +-
.../iotdb/db/service/RegionMigrateService.java | 4 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 5 +-
.../writer/AbstractCrossCompactionWriter.java | 5 +-
.../dataregion/memtable/AbstractMemTable.java | 41 +-
.../memtable/AlignedReadOnlyMemChunk.java | 6 +-
.../memtable/AlignedWritableMemChunk.java | 15 +-
.../memtable/AlignedWritableMemChunkGroup.java | 4 +-
.../dataregion/wal/recover/WALRecoverManager.java | 2 +-
.../rescon/memory/PrimitiveArrayManager.java | 4 +-
.../trigger/service/TriggerInformationUpdater.java | 3 +-
.../org/apache/iotdb/db/utils/SetThreadName.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 39 +-
.../db/utils/datastructure/BackAlignedTVList.java | 1 +
.../db/utils/datastructure/BackBooleanTVList.java | 1 +
.../db/utils/datastructure/BackDoubleTVList.java | 1 +
.../db/utils/datastructure/BackFloatTVList.java | 1 +
.../db/utils/datastructure/BackIntTVList.java | 1 +
.../iotdb/db/utils/datastructure/BackwardSort.java | 5 +-
.../mtree/schemafile/WrappedSegmentTest.java | 4 +-
.../schemaRegion/SchemaStatisticsTest.java | 216 +-
.../db/queryengine/plan/plan/ExpressionTest.java | 68 +
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../metrics/metricsets/cpu/CpuUsageMetrics.java | 9 +
.../resources/conf/iotdb-common.properties | 6 +-
...DataNodeThreadModule.java => ThreadModule.java} | 9 +-
.../iotdb/commons/concurrent/ThreadName.java | 228 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 17 +-
.../commons/consensus/index/ProgressIndex.java | 6 +-
.../PipeRuntimeConnectorCriticalException.java | 24 +-
.../pipe/PipeRuntimeCriticalException.java | 24 +-
.../exception/pipe/PipeRuntimeException.java | 9 +-
.../pipe/PipeRuntimeNonCriticalException.java | 24 +-
.../service/PipePluginExecutableManager.java | 4 +-
.../commons/pipe/task/meta/PipeRuntimeMeta.java | 115 +-
.../commons/pipe/task/meta/PipeStaticMeta.java | 7 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 17 +-
.../apache/iotdb/commons/service/ServiceType.java | 1 -
.../exception/pipe/PipeRuntimeExceptionTest.java | 16 +-
.../apache/iotdb/commons/path/PartialPathTest.java | 12 -
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../thrift/src/main/thrift/datanode.thrift | 21 +-
197 files changed, 20856 insertions(+), 1039 deletions(-)
diff --cc iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/AuthorityChecker.java
index 307a229a6c7,86892dce6fb..652064d09f8
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/AuthorityChecker.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/AuthorityChecker.java
@@@ -74,9 -75,9 +75,9 @@@ public class AuthorityChecker
int permission = translateToPermissionId(type);
if (permission == -1) {
return false;
- } else if (permission == PrivilegeType.MODIFY_PASSWORD.ordinal()
+ } else if (permission == PrivilegeType.ALTER_PASSWORD.ordinal()
&& username.equals(targetUser)) {
- // a user can modify his own password
+ // A user can modify his own password
return true;
}