This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch Computing-resource-balancing
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 147a9eee96f Fix UT and IT
add e909394ebdd Add executeGroupByQueryIntervalQuery rpc interface (#10571)
add 7027790b9cb Add database limit threshold configuration and check when
creating new database.
add 9536db274e4 Add session interface of faster last query in one device
add 487e10ba904 Make the candidate size of seq tsfile in cross space
compaction will be smaller than target_compaction_file_size * 1.5. (#10602)
add e4607a23a98 Fix write performance degradation caused by the extra
overhead of last cache
add e33da6b82dd Fix aligned last query
add d4b235ea88a Fix the NPE issue when taking snapshot in WAL combined
with Aligned Binary (#10627)
add 1e11ab64cc1 [IOTDB-6075] Pipe: File resource races when different
tsfile load operations concurrently modify the same tsfile at receiver (#10629)
add 0e41957f289 [IOTDB-6072] Load: workaround to CPU 100% after loading
tsfile when using JDK8 runtime (#10624)
add 70cc42fa22d [IOTDB-6076] Add duplicate checking when upsert alias
add b804f0ab0d0 Keep special case consistent between
LastDataQueryForOneDevice and others
add 87a85d958b3 Add READ and WRITE into keyword
add deecd3c58e2 [IOTDB-6077]: Stop script addition -f(#10637)
add 3ac87d35237 [IOTDB-6073] Add ClientManager metrics (#10617)
add 9090c5d35f7 Fix the issue that Drivers of query with limit clause can
not be finished timely
new a1382eb686a Merge branch 'master' into Computing-resource-balancing
new caf85531843 Pass IT
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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 | 20 +-
.../it/env/cluster/MppSharedCommonConfig.java | 22 +-
.../iotdb/it/env/remote/RemoteCommonConfig.java | 17 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +-
.../partition/IoTDBPartitionInheritPolicyIT.java | 283 +++++++++----
.../confignode/it/utils/ConfigNodeTestUtils.java | 118 ++++++
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 11 +
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 10 +-
.../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/load/balancer/PartitionBalancer.java | 22 +-
.../load/balancer/partition/DataAllotTable.java | 68 ++--
.../manager/partition/PartitionManager.java | 7 +-
.../manager/schema/ClusterSchemaManager.java | 34 +-
.../partition/DatabasePartitionTable.java | 8 +-
.../persistence/partition/PartitionInfo.java | 7 +-
.../persistence/schema/ClusterSchemaInfo.java | 29 ++
.../iotdb/confignode/service/ConfigNode.java | 2 +
.../balancer/partition/DataAllotTableTest.java | 43 +-
.../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} | 6 +-
.../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 +
.../commons/partition/DataPartitionEntry.java | 87 ++++
.../commons/partition/DataPartitionTable.java | 10 +-
.../commons/partition/SeriesPartitionTable.java | 12 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 4 +
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../commons/partition/DataPartitionEntryTest.java | 58 +++
.../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 ++
92 files changed, 2957 insertions(+), 605 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBDatabaseQuotaIT.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureTimeoutException.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/exception/exchange/GetTsBlockFromClosedOrAbortedChannelException.java}
(79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/dualkeycache/{IDualKeyCacheComputation.java
=> IDualKeyCacheUpdating.java} (82%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientManagerMetrics.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionEntry.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/partition/DataPartitionEntryTest.java
