This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch IOTDB-3455
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d037f1b739 [IOTDB-4023]C++ interface execute SQL query statement and
the returned result set records error (#6870)
add ffd346c236 Support TimePartiton in mpp query (#6901)
add ade087b330 [IOTDB-4029] Latent routing policy for MultiLeader protocol
(#6880)
add 399340e6fd [IOTDB-3845] Add annotations in confignode.thrift (#6899)
add 8a97792086 [IOTDB-4030] Simplify Privilege Operations SQL (#6875)
add 742cc64c85 [IOTDB-4050] Failed to wait region migrate finished (#6908)
add 39db994138 [IOTDB-4051] fix nodeid duplicated problem (#6909)
add c04767fb60 update administration user-guide (#6913)
add a8f757d6e4 disable the log in state tracker for previous debugging
(#6917)
add a2a690b3d8 [IOTDB-2952] IOTDB Grafana Plugin: Build on Windows (#6907)
add b7c4062f28 [IOTDB-4056] Fix the problem that could not find or load
main class in shell `remove-confignode.sh` (#6916)
add 87d200e54b Move clientPool factory from ConfigNode to node-commons
(#6910)
add e514211827 [IOTDB-4065] support negative timestamp (before 1970 year.)
(#6918)
add 51cf191fe1 Refine writeValueColumn() to TsBlockBuilder for common use
(#6912)
add a04a1eb62b [IOTDB-3996] Forbidden CQ in REST query API (#6922)
add 0cac2c3237 [IOTDB-4046] Enhance PipeData serialize()/deserialize()
codes (#6902)
add 67c469305f purge log instantly when take a snapshot (#6724)
add a8880b51d2 [IOTDB-4054] Add some annotations for confignode.thrift
(#6919)
add 6421f4ea77 [IOTDB-4077] DataNode report region migrate result to
FOLLOWER ConfigNode sometimes, the LEADER Confignode is still waiting (#6933)
add b63c4aba78 [IOTDB-4010] Use FilterAndProjectOperator for query that
does not contain non-mappable UDF (#6929)
add ec873773e6 Correct typos in log (#6943)
add c30bb7c00d [IOTDB-3296] ext-pipe suport .mods file (#6102)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 33 +-
.../assembly/resources/sbin/remove-confignode.sh | 40 +-
.../assembly/resources/sbin/start-confignode.sh | 36 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 11 +-
.../AsyncConfigNodeHeartbeatClientPool.java | 4 +-
.../async/datanode/AsyncDataNodeClientPool.java | 4 +-
.../datanode/AsyncDataNodeHeartbeatClientPool.java | 4 +-
.../sync/datanode/SyncDataNodeClientPool.java | 4 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 41 --
.../confignode/conf/ConfigNodeDescriptor.java | 17 -
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../confignode/manager/ClusterSchemaManager.java | 37 +-
.../iotdb/confignode/manager/ConfigManager.java | 11 +-
.../apache/iotdb/confignode/manager/IManager.java | 9 +
.../iotdb/confignode/manager/PartitionManager.java | 21 +-
.../iotdb/confignode/manager/ProcedureManager.java | 21 +-
.../iotdb/confignode/manager/load/LoadManager.java | 95 +++--
.../manager/load/balancer/RouteBalancer.java | 60 ++-
.../load/balancer/router/LazyGreedyRouter.java | 154 +++++++
.../manager/load/heartbeat/IRegionGroupCache.java | 9 +
.../manager/load/heartbeat/RegionGroupCache.java | 7 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 103 ++---
.../iotdb/confignode/persistence/NodeInfo.java | 20 +-
.../persistence/executor/ConfigPlanExecutor.java | 10 +-
.../procedure/env/DataNodeRemoveHandler.java | 13 +-
.../procedure/impl/RegionMigrateProcedure.java | 11 +-
.../procedure/state/RegionTransitionState.java | 1 -
.../service/thrift/ConfigNodeRPCService.java | 15 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 14 +-
.../load/balancer/router/LazyGreedyRouterTest.java | 166 ++++++++
.../load/balancer/router/LeaderRouterTest.java | 2 +-
.../confignode/persistence/AuthorInfoTest.java | 43 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 4 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 2 +-
.../Administration-Management/Administration.md | 59 +--
.../Administration-Management/Administration.md | 119 +++---
.../backend-compile.bat | 29 +-
grafana-plugin/go.mod | 2 +-
grafana-plugin/go.sum | 15 +-
grafana-plugin/pom.xml | 54 +--
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 20 +-
.../iotdb/commons/client/ClientPoolFactory.java | 16 +-
.../iotdb/commons/concurrent/ThreadName.java | 3 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 40 ++
.../iotdb/commons/conf/CommonDescriptor.java | 17 +
.../iotdb/commons/partition/DataPartition.java | 1 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 3 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 90 ++--
.../db/mpp/execution/exchange/SourceHandle.java | 2 +-
.../operator/process/FilterAndProjectOperator.java | 11 +-
.../schema/TimeSeriesSchemaScanOperator.java | 25 +-
.../plan/expression/multi/FunctionExpression.java | 3 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 55 +--
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 56 ++-
.../scheduler/FixedRateFragInsStateTracker.java | 10 +-
.../db/mpp/plan/statement/sys/AuthorStatement.java | 8 -
.../handler/PhysicalPlanValidationHandler.java | 4 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 18 +-
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 12 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 8 -
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 57 +--
.../iotdb/db/sync/datasource/AbstractOpBlock.java | 16 +-
.../iotdb/db/sync/datasource/DeletionGroup.java | 242 +++++++++++
.../iotdb/db/sync/datasource/ModsfileOpBlock.java | 53 ---
.../iotdb/db/sync/datasource/PipeOpManager.java | 6 +-
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 463 +++++++++++++++++----
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 15 +-
.../db/sync/externalpipe/ExtPipePluginManager.java | 4 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 12 +-
.../apache/iotdb/db/sync/pipedata/PipeData.java | 24 +-
.../iotdb/db/sync/pipedata/SchemaPipeData.java | 12 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 31 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 2 +-
.../transport/server/TransportServiceImpl.java | 2 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 13 +-
.../db/sync/datasource/DeletionGroupTest.java | 231 ++++++++++
.../db/sync/datasource/PipeOpManagerTest.java | 226 +++++++++-
.../db/sync/datasource/TsFileOpBlockTest.java | 372 ++++++++++++++++-
.../iotdb/db/sync/pipedata/PipeDataTest.java | 12 +-
.../src/main/thrift/confignode.thrift | 216 ++++++++--
.../tsfile/read/common/block/TsBlockBuilder.java | 16 +
81 files changed, 2767 insertions(+), 962 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LazyGreedyRouter.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/LazyGreedyRouterTest.java
copy server/src/assembly/resources/sbin/stop-server.bat =>
grafana-plugin/backend-compile.bat (60%)
mode change 100755 => 100644
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/ConfigNodeClientPoolFactory.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java
(89%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/DeletionGroup.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/ModsfileOpBlock.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/sync/datasource/DeletionGroupTest.java
