This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch IOTDB-3883
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9a6f0bad93 [IOTDB-3883] Support Order by timeseries in last query
add 5721496be8 [IOTDB-3624] Meet error when inserting data in SQL without
timestamp (#6642)
add 67d78fe47b [IOTDB-3827]support partition cache for query. (#6673)
add bafcd5b206 fix IOTDB-3899 (#6731)
add 53a15c5a6c Bump jetty.version from 9.4.35.v20201120 to
9.4.48.v20220622 (#6726)
add 6ad9f83cc1 [IOTDB-3881] strength the concurrency control of
regionReplicaSetCache. (#6708)
add 3b986fb935 [IoTDB-3842] Fix the issue that GroupByLevel cannot use
value filter
add 1ffe93cb27 [IOTDB-3815] replace remove data node to procedure (#6736)
add dfcb0a8903 fix timeout problem while using cli (#6741)
add 842105470d [IOTDB-3880] Optimize asyncclientpool retry logic (#6735)
add e429f89e7a update metric of confignode's number (#6754)
add d4b41bbb71 Modified the processing of metrics for collecting the
number of storage groups (#6749)
new 1605762a01 Merge remote-tracking branch 'origin/master' into IOTDB-3883
new 629f1e3e7e sort timeseries
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:
.../confignode/client/DataNodeRequestType.java | 3 +-
.../async/datanode/AsyncDataNodeClientPool.java | 221 +++---
.../async/handlers/AbstractRetryHandler.java | 33 +-
.../client/async/handlers/CreateRegionHandler.java | 14 +-
.../client/async/handlers/FlushHandler.java | 16 +-
.../async/handlers/FunctionManagementHandler.java | 11 +-
.../client/async/handlers/SetTTLHandler.java | 7 +-
.../handlers/UpdateRegionRouteMapHandler.java | 9 +-
.../request/write/RemoveDataNodePlan.java | 124 +---
.../statemachine/PartitionRegionStateMachine.java | 2 -
.../confignode/manager/ClusterSchemaManager.java | 30 +-
.../iotdb/confignode/manager/ConfigManager.java | 10 +-
.../confignode/manager/DataNodeRemoveManager.java | 806 ---------------------
.../apache/iotdb/confignode/manager/IManager.java | 6 +-
.../iotdb/confignode/manager/NodeManager.java | 71 +-
.../iotdb/confignode/manager/ProcedureManager.java | 34 +
.../iotdb/confignode/manager/UDFManager.java | 63 +-
.../iotdb/confignode/manager/load/LoadManager.java | 31 +-
.../iotdb/confignode/persistence/NodeInfo.java | 204 +-----
.../persistence/partition/PartitionInfo.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 26 +-
.../procedure/env/DataNodeRemoveHandler.java | 381 ++++++++++
.../procedure/impl/AbstractNodeProcedure.java | 64 ++
.../procedure/impl/AddConfigNodeProcedure.java | 33 +-
.../procedure/impl/RegionMigrateProcedure.java | 230 ++++++
.../procedure/impl/RemoveConfigNodeProcedure.java | 33 +-
.../procedure/impl/RemoveDataNodeProcedure.java | 184 +++++
.../confignode/procedure/scheduler/LockQueue.java | 63 ++
...igNodeState.java => RegionTransitionState.java} | 11 +-
...ageGroupState.java => RemoveDataNodeState.java} | 10 +-
.../procedure/store/ProcedureFactory.java | 14 +
.../iotdb/confignode/service/ConfigNode.java | 27 -
.../confignode/service/ConfigNodeCommandLine.java | 31 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 2 +-
.../request/write/RemoveDataNodePlanTest.java | 1 -
.../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 122 ++++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 12 +-
.../db/integration/IoTDBInsertWithoutTimeIT.java | 131 ----
.../commons/partition/DataPartitionQueryParam.java | 14 -
pom.xml | 2 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 47 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 31 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 63 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 166 +++--
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 15 +-
.../plan/planner/distribution/SourceRewriter.java | 19 +
.../planner/plan/node/process/MultiChildNode.java | 21 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 15 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 105 ---
.../db/service/DataNodeServerCommandLine.java | 120 ++-
.../iotdb/db/service/RegionMigrateService.java | 15 +-
.../mpp/plan/analyze/cache/PartitionCacheTest.java | 432 +++++++++++
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 8 +-
54 files changed, 2243 insertions(+), 1905 deletions(-)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/DataNodeRemoveManager.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/AbstractNodeProcedure.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/RegionMigrateProcedure.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/RemoveDataNodeProcedure.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/scheduler/LockQueue.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{AddConfigNodeState.java
=> RegionTransitionState.java} (82%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{DeleteStorageGroupState.java
=> RemoveDataNodeState.java} (86%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBInsertWithoutTimeIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertWithoutTimeIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCacheTest.java
