This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch Computing-resource-balancing in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a1382eb686a089f8e73d22d8194e8f3d59f38beb Merge: 147a9eee96f 9090c5d35f7 Author: YongzaoDan <[email protected]> AuthorDate: Sat Jul 22 10:37:20 2023 +0800 Merge branch 'master' into Computing-resource-balancing docs/UserGuide/Monitor-Alert/Metric-Tool.md | 20 +- docs/UserGuide/Reference/Common-Config-Manual.md | 12 + docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 20 +- .../zh/UserGuide/Reference/Common-Config-Manual.md | 12 + .../main/java/org/apache/iotdb/SessionExample.java | 20 + .../iotdb/it/env/cluster/MppCommonConfig.java | 6 + .../it/env/cluster/MppSharedCommonConfig.java | 7 + .../iotdb/it/env/remote/RemoteCommonConfig.java | 5 + .../org/apache/iotdb/itbase/env/CommonConfig.java | 2 + .../confignode/it/utils/ConfigNodeTestUtils.java | 1 + .../db/it/aligned/IoTDBAlignedLastQueryIT.java | 11 + .../db/it/last/IoTDBLastQueryLastCacheIT.java | 7 + .../iotdb/db/it/schema/IoTDBDatabaseQuotaIT.java | 79 ++++ .../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 29 ++ .../iotdb/session/it/IoTDBSessionQueryIT.java | 65 +++ .../java/org/apache/iotdb/isession/ISession.java | 4 + .../apache/iotdb/isession/pool/ISessionPool.java | 4 + .../java/org/apache/iotdb/session/Session.java | 32 ++ .../apache/iotdb/session/SessionConnection.java | 49 +++ .../org/apache/iotdb/session/pool/SessionPool.java | 29 ++ .../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 + .../src/assembly/resources/sbin/stop-confignode.sh | 27 +- .../iotdb/confignode/manager/ConfigManager.java | 5 + .../manager/schema/ClusterSchemaManager.java | 34 +- .../persistence/schema/ClusterSchemaInfo.java | 29 ++ .../iotdb/confignode/service/ConfigNode.java | 2 + .../iot/client/IoTConsensusClientPool.java | 73 ++-- .../iotdb/consensus/ratis/RatisConsensus.java | 19 +- .../src/assembly/resources/sbin/stop-datanode.sh | 27 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 3 +- .../metadata/SchemaQuotaExceededException.java | 14 + .../db/pipe/agent/receiver/PipeReceiverAgent.java | 24 ++ .../db/pipe/agent/runtime/PipeRuntimeAgent.java | 1 + .../connector/v1/IoTDBThriftConnectorClient.java | 3 +- .../pipe/connector/v1/IoTDBThriftConnectorV1.java | 10 +- .../pipe/connector/v1/IoTDBThriftReceiverV1.java | 304 +++++++++++--- .../protocol/client/DataNodeClientPoolFactory.java | 65 +-- .../protocol/thrift/impl/ClientRPCServiceImpl.java | 450 ++++++++++++++++++++- ...sBlockFromClosedOrAbortedChannelException.java} | 22 +- .../execution/exchange/MPPDataExchangeManager.java | 5 + .../execution/exchange/sink/SinkChannel.java | 5 +- .../execution/exchange/source/SourceHandle.java | 4 +- .../fragment/FragmentInstanceContext.java | 30 +- .../fragment/FragmentInstanceManager.java | 2 +- .../execution/load/LoadTsFileManager.java | 2 +- .../cache/schema/TimeSeriesSchemaCache.java | 12 +- .../cache/schema/dualkeycache/IDualKeyCache.java | 8 +- .../dualkeycache/IDualKeyCacheComputation.java | 5 +- ...Computation.java => IDualKeyCacheUpdating.java} | 11 +- .../schema/dualkeycache/impl/DualKeyCacheImpl.java | 42 +- .../schema/lastcache/DataNodeLastCacheManager.java | 8 +- .../schema/lastcache/ILastCacheContainer.java | 3 +- .../cache/schema/lastcache/LastCacheContainer.java | 21 +- .../plan/planner/OperatorTreeGenerator.java | 3 +- .../scheduler/FixedRateFragInsStateTracker.java | 7 +- .../iotdb/db/schemaengine/SchemaConstant.java | 3 + .../schemaregion/impl/SchemaRegionMemoryImpl.java | 43 +- .../schemaregion/impl/SchemaRegionPBTreeImpl.java | 46 +-- .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 23 ++ .../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 27 ++ .../db/service/metrics/DataNodeMetricsHelper.java | 2 + .../iotdb/db/storageengine/StorageEngine.java | 19 +- .../impl/RewriteCrossSpaceCompactionSelector.java | 2 +- .../apache/iotdb/db/utils/QueryDataSetUtils.java | 191 +++++++++ .../db/utils/datastructure/AlignedTVList.java | 12 +- .../cache/dualkeycache/DualKeyCacheTest.java | 13 +- .../schemaRegion/SchemaRegionAliasAndTagTest.java | 19 + .../resources/conf/iotdb-common.properties | 14 +- .../src/assembly/resources/sbin/stop-standalone.sh | 31 +- .../iotdb/commons/client/ClientManagerMetrics.java | 221 ++++++++++ .../iotdb/commons/client/ClientPoolFactory.java | 282 +++++++------ .../apache/iotdb/commons/conf/CommonConfig.java | 20 + .../iotdb/commons/conf/CommonDescriptor.java | 8 + .../iotdb/commons/pipe/config/PipeConfig.java | 4 + .../iotdb/commons/service/metric/enums/Metric.java | 1 + .../org/apache/iotdb/tsfile/read/common/Path.java | 2 +- .../iotdb/tsfile/read/filter/TimeFilter.java | 89 ++++ .../tsfile/read/filter/factory/FilterFactory.java | 4 + .../read/filter/factory/FilterSerializeId.java | 3 +- .../src/main/thrift/confignode.thrift | 1 + .../thrift/src/main/thrift/client.thrift | 32 ++ 81 files changed, 2380 insertions(+), 428 deletions(-)
