[iotdb] branch beyyes/remove_confignode_develop updated (2b48818d0a -> 3ca5cd6a55)

[ca...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

caogaofei pushed a change to branch beyyes/remove_confignode_develop
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from 2b48818d0a fix the null problem in borrow client of ClientManager
     add de822561f1 Turn off time partition on data node (#7144)
     add 23b05104df change response code to WRITE_PROCESS_REJECT when limitation is triggered by wal size (#7143)
     add 3c1f57c09d [IOTDB-4126] Optimize cache implementation using HashMap to find Node instead of traversal with a for loop (#6986)
     add 136bfd05e8 [IOTDB-4085] Add StateWindowAccessStrategy in UDF (#7005)
     add a1946680ab [IOTDB-4106] Add close method for FilterAndProjectOperator (#7132)
     add be3a931847 [IOTDB-4236] BackSlash in where clause may cause parse error (#7139)
     add 695b901bfa check and create log file in the init function of SnapshotLogger (#7151)
     add 2a5efd828e [IOTDB-2760][IOTDB-2769][IOTDB-3302] Fix some auth problems and add Auth IT test. (#7134)
     add dda8ac4ff7 [IOTDB-4241] Support set system mode in new cluster (#7148)
     add f218f0bdb9 [IOTDB-3164] Manage the memory of cross space compaction in write memory controller (#6914)
     add 9f4e7eb65b Merge branch 'master' into beyyes/remove_confignode_develop
     add 3ca5cd6a55 fix spotless problem

No new revisions were added by this update.

Summary of changes:
 .../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 |    3 +-
 .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4   |    4 +-
 .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4  |   14 +-
 .../confignode/client/DataNodeRequestType.java     |    1 +
 .../async/datanode/AsyncDataNodeClientPool.java    |   13 +
 ...ionHandler.java => SetSystemStatusHandler.java} |   12 +-
 .../sync/confignode/SyncConfigNodeClientPool.java  |    1 +
 .../confignode/conf/ConfigNodeRemoveCheck.java     |    4 +-
 .../iotdb/confignode/manager/ConfigManager.java    |    8 +
 .../apache/iotdb/confignode/manager/IManager.java  |    3 +
 .../iotdb/confignode/manager/NodeManager.java      |   14 +
 .../confignode/service/ConfigNodeCommandLine.java  |    3 +-
 .../thrift/ConfigNodeRPCServiceProcessor.java      |    5 +
 .../multileader/MultiLeaderServerImpl.java         |    2 +-
 .../Maintenance-Tools/Maintenance-Command.md       |    9 +-
 .../Maintenance-Tools/Maintenance-Command.md       |   10 +-
 .../db/query/udf/example/ExampleUDFConstant.java   |    2 +
 .../iotdb/db/query/udf/example/WindowStartEnd.java |   23 +
 .../java/org/apache/iotdb/it/env/AbstractEnv.java  |   28 +-
 .../org/apache/iotdb/it/env/RemoteServerEnv.java   |   11 +-
 .../iotdb/itbase/constant/UDFTestConstant.java     |    2 +
 .../java/org/apache/iotdb/itbase/env/BaseEnv.java  |   13 +-
 .../java/org/apache/iotdb/db/it/IoTDBAuthIT.java   |  807 +++++++++++++-
 .../org/apache/iotdb/db/it/IoTDBConfigNodeIT.java  |    4 +-
 .../db/it/IoTDBSyntaxConventionIdentifierIT.java   |   29 +
 .../org/apache/iotdb/db/it/env/StandaloneEnv.java  |   12 +-
 ...ueryIT.java => IoTDBUDFOtherWindowQueryIT.java} |  238 ++++-
 .../iotdb/db/integration/IoTDBAuthorizationIT.java |  699 +++---------
 .../iotdb/db/integration/IoTDBCheckConfigIT.java   |    4 +-
 .../IoTDBSetSystemReadOnlyWritableIT.java          |    2 +-
 .../apache/iotdb/commons/cluster/NodeStatus.java   |    9 +
 .../resources/conf/iotdb-datanode.properties       |   23 +-
 .../apache/iotdb/db/client/ConfigNodeClient.java   |   16 +
 .../java/org/apache/iotdb/db/conf/IoTDBConfig.java |   76 +-
 .../org/apache/iotdb/db/conf/IoTDBDescriptor.java  |   31 +-
 .../db/engine/compaction/CompactionScheduler.java  |    8 +-
 .../db/engine/compaction/CompactionUtils.java      |   16 -
 .../compaction/cross/CrossSpaceCompactionTask.java |   11 +
 .../RewriteCrossSpaceCompactionSelector.java       |  256 ++++-
 .../selector/RewriteCompactionFileSelector.java    |  285 -----
 .../cross/utils/InplaceCompactionEstimator.java    |    3 +-
 .../compaction/task/ICompactionSelector.java       |    5 +
 .../iotdb/db/engine/snapshot/SnapshotLogger.java   |    9 +-
 .../iotdb/db/localconfignode/LocalConfigNode.java  |   14 +-
 .../operator/process/FilterAndProjectOperator.java |   11 +
 .../plan/execution/config/ConfigTaskVisitor.java   |    8 +
 .../config/executor/ClusterConfigTaskExecutor.java |   40 +-
 .../config/executor/IConfigTaskExecutor.java       |   11 +-
 .../executor/StandaloneConfigTaskExecutor.java     |   21 +-
 .../plan/execution/config/sys/ClearCacheTask.java  |    4 +-
 .../mpp/plan/execution/config/sys/FlushTask.java   |    4 +-
 .../config/sys/LoadConfigurationTask.java          |    4 +-
 .../mpp/plan/execution/config/sys/MergeTask.java   |    4 +-
 ...learCacheTask.java => SetSystemStatusTask.java} |   15 +-
 .../visitor/IntermediateLayerVisitor.java          |    1 +
 .../iotdb/db/mpp/plan/parser/ASTVisitor.java       |   54 +-
 .../db/mpp/plan/statement/StatementVisitor.java    |    5 +
 .../db/mpp/plan/statement/sys/AuthorStatement.java |   10 +-
 .../plan/statement/sys/ClearCacheStatement.java    |   15 +-
 .../db/mpp/plan/statement/sys/FlushStatement.java  |   14 +-
 .../statement/sys/LoadConfigurationStatement.java  |   10 +-
 .../db/mpp/plan/statement/sys/MergeStatement.java  |   10 +-
 ...tatement.java => SetSystemStatusStatement.java} |   32 +-
 .../dag/column/ColumnTransformer.java              |    4 +
 .../column/multi/MappableUDFColumnTransformer.java |    6 +
 .../intermediate/ConstantIntermediateLayer.java    |    8 +
 .../dag/intermediate/IntermediateLayer.java        |    8 +
 .../MultiInputColumnIntermediateLayer.java         |    7 +
 ...InputColumnMultiReferenceIntermediateLayer.java |  121 +++
 ...nputColumnSingleReferenceIntermediateLayer.java |  121 +++
 .../transformation/dag/util/TransformUtils.java    |   90 ++
 .../db/mpp/transformation/datastructure/Cache.java |   77 +-
 .../row/ElasticSerializableRowRecordList.java      |    8 +-
 .../tv/ElasticSerializableTVList.java              |    8 +-
 .../datastructure/util/ValueRecorder.java          |   88 ++
 .../apache/iotdb/db/qp/executor/PlanExecutor.java  |    9 +-
 .../iotdb/db/qp/logical/sys/AuthorOperator.java    |   12 +-
 .../db/qp/logical/sys/SetSystemModeOperator.java   |   15 +-
 .../iotdb/db/qp/physical/sys/AuthorPlan.java       |   12 +-
 .../db/qp/physical/sys/SetSystemModePlan.java      |   21 +-
 .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java    |   16 +-
 .../iotdb/db/rescon/PrimitiveArrayManager.java     |    2 +-
 .../org/apache/iotdb/db/rescon/SystemInfo.java     |   29 +-
 .../impl/DataNodeInternalRPCServiceImpl.java       |   11 +
 .../db/service/thrift/impl/TSServiceImpl.java      |    4 +
 ...zedSize.java => HandleSystemErrorStrategy.java} |   15 +-
 .../org/apache/iotdb/db/wal/buffer/WALBuffer.java  |    4 +-
 .../engine/compaction/CompactionSchedulerTest.java |  194 ++--
 .../compaction/CompactionTaskComparatorTest.java   |    1 +
 .../compaction/CompactionTaskManagerTest.java      |    1 +
 .../compaction/cross/CrossSpaceCompactionTest.java |   33 +-
 .../cross/CrossSpaceCompactionValidationTest.java  | 1111 +++++++++++---------
 .../engine/compaction/cross/MergeUpgradeTest.java  |   19 +-
 .../cross/RewriteCompactionFileSelectorTest.java   |  296 ++++--
 .../cross/RewriteCrossSpaceCompactionTest.java     |    4 +
 .../iotdb/db/query/udf/datastructure/LRUCache.java |   12 +-
 .../db/query/udf/datastructure/LRUCacheTest.java   |   79 ++
 .../src/main/thrift/confignode.thrift              |    3 +
 thrift/src/main/thrift/datanode.thrift             |    2 +
 .../tsfile/read/common/parser/PathVisitor.java     |    4 -
 .../api/customizer/strategy/AccessStrategy.java    |    5 +-
 ...trategy.java => StateWindowAccessStrategy.java} |   48 +-
 102 files changed, 3514 insertions(+), 2009 deletions(-)
 copy confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/{LoadConfigurationHandler.java => SetSystemStatusHandler.java} (87%)
 rename integration-test/src/test/java/org/apache/iotdb/db/it/udf/{IoTDBUDFSessionWindowQueryIT.java => IoTDBUDFOtherWindowQueryIT.java} (53%)
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/RewriteCompactionFileSelector.java
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/{ClearCacheTask.java => SetSystemStatusTask.java} (75%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ClearCacheStatement.java => SetSystemStatusStatement.java} (71%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/datastructure/util/ValueRecorder.java
 copy server/src/main/java/org/apache/iotdb/db/utils/{SerializedSize.java => HandleSystemErrorStrategy.java} (75%)
 copy udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/{SessionTimeWindowAccessStrategy.java => StateWindowAccessStrategy.java} (63%)