This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/fix_procedure_bug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from afe82dfe06 perfect the RegionMigrateService
add f53029b133 Add doc for last query order by timeseries (#7232)
add 35dd0cc002 [IOTDB-4305] fix website building (#7233)
add 85fa188ed1 [IOTDB-4325] NaN and Infinity will be regard as positive
Infinity in where clause in 0.14.0 (#7226)
add 8a179d7868 [IOTDB-4243] Antlr and Statement for Drop Trigger (#7220)
add 94500581f6 [IOTDB-3224][IOTDB-3949] Sync pipe execution and data
collection process in standalone version (#7154)
add 0095eb3cee update website about release-0.13.2 (#7235)
add d81192ddca delete origin data before loading snapshot without log
(#7236)
add cc78392a77 Clean ThreadName of Thrift (#7244)
add 22c8ac1f7d Change some useless logs to debug level (#7246)
add 403f5a9f9b [IOTDB-4347]NPE error when session is expired (#7245)
add 326fc81d7a [IOTDB-3642] Add retry mechanism when resource unavailable
(#7240)
add ecaa0f2af3 [IOTDB-4343] Fix session manager in MQTT module. (#7247)
add c6ce7922ee [IOTDB-4349] Remove error status in data node (#7250)
add 0af48606c3 [IOTDB-4223] Maintain default node ip config (#7254)
add 3ecc1d27b8 [IOTDB-4352] PatialPath#overlapWith supports
MULTI_LEVEL_PATH_WILDCARD (#7259)
add 0f0816ec20 [IOTDB-4340] Refactor Region migration related interfaces
(#7243)
new db2729d119 Merge branch 'master' into beyyes/fix_procedure_bug
new c659d5aa48 perfect logs in RegionMigrateService
new 7294e35541 perfect addNewRegionPeer, removeRegionPeer logic
The 3 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:
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 -
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 -
.../resources/conf/iotdb-confignode.properties | 6 +-
.../confignode/client/DataNodeRequestType.java | 4 +-
.../sync/datanode/SyncDataNodeClientPool.java | 14 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 7 +
.../consensus/request/ConfigPhysicalPlan.java | 4 -
.../iotdb/confignode/manager/ConsensusManager.java | 3 +-
.../iotdb/confignode/manager/NodeManager.java | 4 +-
.../iotdb/confignode/manager/ProcedureManager.java | 9 +-
.../manager/load/balancer/RouteBalancer.java | 5 +-
.../procedure/env/DataNodeRemoveHandler.java | 191 +++++++++++++--------
.../procedure/impl/AbstractNodeProcedure.java | 6 +-
.../procedure/impl/RegionMigrateProcedure.java | 73 +++++---
.../procedure/state/RegionTransitionState.java | 4 +-
.../service/thrift/ConfigNodeRPCService.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 7 +
.../apache/iotdb/consensus/config/RatisConfig.java | 59 ++++++-
.../multileader/service/MultiLeaderRPCService.java | 4 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 53 +++++-
docs/Download/README.md | 28 +--
docs/UserGuide/API/Status-Codes.md | 3 +-
.../Maintenance-Tools/Maintenance-Command.md | 6 +-
docs/UserGuide/Query-Data/Last-Query.md | 18 +-
docs/zh/Download/README.md | 28 +--
docs/zh/UserGuide/API/Status-Codes.md | 3 +-
.../{Flink TsFile.md => Flink-TsFile.md} | 0
.../{Grafana Plugin.md => Grafana-Plugin.md} | 0
.../{Spark TsFile.md => Spark-TsFile.md} | 0
.../Maintenance-Tools/Maintenance-Command.md | 6 +-
docs/zh/UserGuide/Query-Data/Last-Query.md | 18 +-
...CacheWithDeletionIT.java => IoTDBFilterIT.java} | 79 ++++++---
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 2 +-
.../{IoTDBPipeSinkIT.java => IoTDBPipeIT.java} | 82 ++++++---
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 4 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 1 +
.../iotdb/commons/client/ClientPoolFactory.java | 6 +-
.../sync/SyncThriftClientWithErrorHandler.java | 6 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 8 +-
.../iotdb/commons/concurrent/ThreadName.java | 62 ++-----
.../apache/iotdb/commons/conf/CommonConfig.java | 10 +-
.../commons/enums/HandleSystemErrorStrategy.java | 17 +-
.../commons/exception/ConfigurationException.java | 23 ++-
.../org/apache/iotdb/commons/path/PartialPath.java | 64 ++++++-
.../apache/iotdb/commons/sync/SyncConstant.java | 4 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 7 +
.../client/mock/MockInternalRPCService.java | 4 +-
.../apache/iotdb/commons/path/PartialPathTest.java | 23 ++-
.../resources/conf/iotdb-datanode.properties | 13 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 6 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 ++
.../iotdb/db/client/DataNodeClientPoolFactory.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 1 +
.../apache/iotdb/db/engine/StorageEngineV2.java | 6 +
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 8 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 23 +--
.../db/engine/storagegroup/TsFileManager.java | 14 +-
.../db/engine/storagegroup/TsFileProcessor.java | 29 ++--
.../dataregion/StorageGroupManager.java | 10 --
.../iotdb/db/localconfignode/LocalConfigNode.java | 65 +++++--
.../iotdb/db/metadata/logfile/MLogWriter.java | 3 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 11 --
.../schemaregion/SchemaRegionSchemaFileImpl.java | 11 --
.../db/mpp/common/header/ColumnHeaderConstant.java | 17 ++
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../execution/exchange/MPPDataExchangeManager.java | 1 +
.../execution/exchange/MPPDataExchangeService.java | 6 +-
.../db/mpp/execution/exchange/SinkHandle.java | 3 +-
.../db/mpp/execution/exchange/SourceHandle.java | 7 +-
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +-
.../plan/execution/config/ConfigTaskVisitor.java | 15 +-
.../config/executor/ClusterConfigTaskExecutor.java | 39 ++++-
.../config/executor/IConfigTaskExecutor.java | 17 +-
.../executor/StandaloneConfigTaskExecutor.java | 90 ++++++----
...{DropFunctionTask.java => DropTriggerTask.java} | 13 +-
.../execution/config/sys/sync/CreatePipeTask.java | 4 +-
.../execution/config/sys/sync/DropPipeTask.java | 4 +-
.../execution/config/sys/sync/ShowPipeTask.java | 41 ++++-
.../execution/config/sys/sync/StartPipeTask.java | 4 +-
.../execution/config/sys/sync/StopPipeTask.java | 4 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 10 +-
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
.../statement/metadata/CreateTriggerStatement.java | 9 +
...ionStatement.java => DropTriggerStatement.java} | 17 +-
.../statement/sys/sync/CreatePipeStatement.java | 38 ++++
.../binary/CompareBinaryColumnTransformer.java | 12 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 36 ++--
.../iotdb/db/protocol/mqtt/PublishHandler.java | 39 +++--
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 2 -
.../iotdb/db/query/control/SessionManager.java | 16 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 8 +-
.../db/service/DataNodeInternalRPCService.java | 6 +-
.../iotdb/db/service/InfluxDBRPCService.java | 4 +-
.../org/apache/iotdb/db/service/RPCService.java | 8 +-
.../iotdb/db/service/RegionMigrateService.java | 80 ++++-----
.../impl/DataNodeInternalRPCServiceImpl.java | 85 ++++-----
.../java/org/apache/iotdb/db/sync/SyncService.java | 95 ++++++++++
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 5 +-
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 19 +-
.../org/apache/iotdb/db/sync/common/SyncInfo.java | 35 +++-
.../db/sync/common/persistence/SyncLogReader.java | 8 +-
.../db/sync/common/persistence/SyncLogWriter.java | 17 +-
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 54 +++---
.../sender/manager/ISyncManager.java} | 26 +--
.../db/sync/sender/manager/LocalSyncManager.java | 90 ++++++++++
.../db/sync/sender/manager/SchemaSyncManager.java | 149 ----------------
.../db/sync/sender/manager/TsFileSyncManager.java | 106 ------------
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 12 ++
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 144 ++++++----------
.../db/sync/transport/client/SenderManager.java | 1 -
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 8 +-
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 47 +++++
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 7 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 5 +-
.../engine/storagegroup/TsFileProcessorTest.java | 6 +-
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 7 +-
.../db/sync/receiver/manager/SyncInfoTest.java | 8 +-
.../db/sync/receiver/recovery/SyncLogTest.java | 8 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
site/src/main/.vuepress/config.js | 2 +-
.../src/main/thrift/confignode.thrift | 27 +++
thrift/src/main/thrift/datanode.thrift | 82 +++++----
126 files changed, 1732 insertions(+), 1090 deletions(-)
rename docs/zh/UserGuide/Ecosystem-Integration/{Flink TsFile.md =>
Flink-TsFile.md} (100%)
rename docs/zh/UserGuide/Ecosystem-Integration/{Grafana Plugin.md =>
Grafana-Plugin.md} (100%)
rename docs/zh/UserGuide/Ecosystem-Integration/{Spark TsFile.md =>
Spark-TsFile.md} (100%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
=> IoTDBFilterIT.java} (57%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/sync/{IoTDBPipeSinkIT.java
=> IoTDBPipeIT.java} (56%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{DropFunctionTask.java
=> DropTriggerTask.java} (78%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{DropFunctionStatement.java
=> DropTriggerStatement.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/planner/plan/node/write/BatchInsertNode.java
=> sync/sender/manager/ISyncManager.java} (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/LocalSyncManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/SchemaSyncManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/manager/TsFileSyncManager.java
