This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch TriggerTest
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b8e3e13f88 Show Trigger (#7438)
add 7dc11bae56 [IOTDB-4493] Fix null message in TSStatus (#7402)
add c9fc325bd3 [IoTDB-4328] Complete add/remove replica for
MultiLeaderConsensus (#7390)
add fb8400e161 reset ResultHandleContext before retyr (#7405)
add f99850c542 terminate workerMonitorExecutor (#7404)
add 46de3f32a5 [IOTDB-3586] ext-pipe FWK support Time-Aligned data (#7138)
add 0d34cda0a6 print absolute file path when flush error occured (#7415)
add aebafee38e [IOTDB-4495][PartitionCache] Add auto create schema
judgement (#7411)
add e4250bb101 [IOTDB-4080] Change the port name of show cluster, show
regions, show confignodes, show datandoes; make running result of
`Remove-datanode.sh` clear (#7403)
add 09e358731c [IOTDB-4312] header parsing error in ImportCSV (#7214)
add f58133d4f6 [IOTDB-4324][IOTDB-4339] Antlr and Statement for Show
Triggers and Implementation (#7234)
add 6b04945052 [IOTDB-4481] Use time_partition_interval_for_routing in
PartitionFetcher (#7407)
add d8e310e1c6 Test reporter will never fail due to path (#7418)
add e2594a3a6d [MultiLeader] Fix the issue that the wal won't be deleted
when leader transfer to follower (#7421)
add 630c68a01e [IOTDB-4518] Fix cannot delete .cmt -> .meta file in disk
(#7423)
add 04d9a4a540 [IOTDB-4501]fix FileAlreadyExistsException when taking
snapshot (#7408)
add 7da6d051e0 [IOTDB-4519] Fix existing measurement check during auto
creating schema (#7428)
add 38831292ed [IOTDB-4503] fix load error when autoregister is
false(#7426)
add 60a2621460 [IOTDB-4487] Remove enable_timed_close_tsfile in the time
partition doc (#7431)
add 2bc3954df3 fix some log and potential memory leak. (#7414)
add c66e890dca Make some comments and logs tidy in remove-nodes (#7435)
add 8ff428b0ae Add Error log for ConfigExecution (#7436)
add a29d38dacd change port to InternalPort for show cluster (#7440)
add b01996544a [IOTDB-4456][IOTDB-4459] Sync cluster framework in
ConfigNode and PipeSink operation (#7386)
add 31996b05ec Move all path related class to node-commons module (#7437)
add 85329a92a8 [IOTDB-4491] Achieve idempotence of Create Trigger On
DataNode (#7409)
new b4c37fdeb4 Resolve conflicts
new 92cf3f94a5 Resolve conflicts
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:
.../consensus/request/ConfigPhysicalPlan.java | 12 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
.../sync/CreatePipeSinkPlan.java} | 30 +--
.../DropPipeSinkPlan.java} | 29 ++-
.../GetPipeSinkPlan.java} | 30 ++-
.../{TemplateInfoResp.java => PipeSinkResp.java} | 15 +-
.../iotdb/confignode/manager/ConfigManager.java | 43 +++-
.../apache/iotdb/confignode/manager/IManager.java | 28 +++
.../iotdb/confignode/manager/SyncManager.java | 101 ++++++++
.../iotdb/confignode/persistence/TriggerInfo.java | 10 +-
.../persistence/executor/ConfigPlanExecutor.java | 15 +-
.../persistence/sync/ClusterSyncInfo.java | 118 +++++++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 21 ++
.../request/ConfigPhysicalPlanSerDeTest.java | 47 ++++
.../multileader/MultiLeaderServerImpl.java | 26 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 48 ++--
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 48 ++--
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 6 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 27 ---
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 3 +-
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 18 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 2 +-
.../exception/sync/PipeDataLoadException.java | 2 +-
.../commons}/exception/sync/PipeException.java | 2 +-
.../exception/sync/PipeServerException.java | 2 +-
.../commons}/exception/sync/PipeSinkException.java | 2 +-
.../commons/executable/ExecutableManager.java | 8 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 26 ++
.../apache/iotdb/commons/service/ServiceType.java | 3 -
.../iotdb/commons/sync/metadata/SyncMetadata.java | 212 +++++++++++++++++
.../apache/iotdb/commons/sync}/pipe/PipeInfo.java | 4 +-
.../iotdb/commons/sync}/pipe/PipeMessage.java | 2 +-
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 10 +-
.../pipe/SyncOperation.java} | 10 +-
.../iotdb/commons/sync}/pipe/TsFilePipeInfo.java | 4 +-
.../commons/sync/pipesink}/IoTDBPipeSink.java | 29 ++-
.../iotdb/commons/sync/pipesink}/PipeSink.java | 25 +-
.../commons/sync/{ => utils}/SyncConstant.java | 2 +-
.../commons/sync/{ => utils}/SyncPathUtil.java | 2 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 21 +-
.../trigger/service/TriggerExecutableManager.java | 34 +--
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 ++
.../apache/iotdb/db/client/ConfigNodeClient.java | 52 ++++
.../iotdb/db/engine/storagegroup/DataRegion.java | 6 +-
.../engine/trigger/executor/TriggerExecutor.java | 2 +-
.../trigger/service/TriggerClassLoaderManager.java | 2 +-
.../service/TriggerRegistrationService.java | 2 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 18 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 17 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 2 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 6 +-
.../mpp/plan/execution/config/ConfigExecution.java | 9 +-
.../config/executor/ClusterConfigTaskExecutor.java | 132 ++++++++---
.../executor/StandaloneConfigTaskExecutor.java | 16 +-
.../config/sys/sync/ShowPipeSinkTask.java | 27 ++-
.../memory/StatementMemorySourceVisitor.java | 2 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 15 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/statement/crud/LoadTsFileStatement.java | 7 +-
.../sys/sync/CreatePipeSinkStatement.java | 2 +-
.../statement/sys/sync/CreatePipeStatement.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 6 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 2 +-
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 17 +-
.../db/service/DataNodeServerCommandLine.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 7 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 35 +--
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 6 +-
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 164 +++++++++++++
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 92 +++----
.../org/apache/iotdb/db/sync/common/SyncInfo.java | 264 ---------------------
.../db/sync/common/persistence/SyncLogReader.java | 8 +-
.../db/sync/common/persistence/SyncLogWriter.java | 11 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 2 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 4 +-
.../db/sync/receiver/load/DeletionLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/ILoader.java | 2 +-
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 2 +-
.../db/sync/sender/pipe/ExternalPipeSink.java | 10 +-
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 14 +-
.../{PipeMessage.java => PipeSinkFactory.java} | 45 ++--
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 11 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 4 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 4 +-
.../db/sync/transport/client/SenderManager.java | 8 +-
.../sync/transport/client/SyncClientFactory.java | 6 +-
.../db/sync/transport/server/ReceiverManager.java | 6 +-
.../db}/trigger/service/TriggerClassLoader.java | 2 +-
.../trigger/service/TriggerClassLoaderManager.java | 55 ++---
.../trigger/service/TriggerManagementService.java | 64 ++---
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 32 ++-
.../db/metadata/path/MeasurementPathTest.java | 46 ++++
.../org/apache/iotdb/db/sync/SyncTestUtils.java | 8 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 4 +-
.../{SyncInfoTest.java => LocalSyncInfoTest.java} | 46 ++--
.../db/sync/receiver/recovery/SyncLogTest.java | 16 +-
.../iotdb/db/sync/transport/SyncTransportTest.java | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../src/main/thrift/confignode.thrift | 34 ++-
thrift/src/main/thrift/datanode.thrift | 2 +
103 files changed, 1575 insertions(+), 904 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/template/GetPathsSetTemplatePlan.java
=> write/sync/CreatePipeSinkPlan.java} (61%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DropFunctionPlan.java
=> sync/DropPipeSinkPlan.java} (66%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DropFunctionPlan.java
=> sync/GetPipeSinkPlan.java} (66%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{TemplateInfoResp.java
=> PipeSinkResp.java} (79%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeDataLoadException.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeException.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeServerException.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeSinkException.java
(96%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/metadata/SyncMetadata.java
rename {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/PipeInfo.java
(95%)
copy {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/PipeMessage.java
(97%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionMaintainType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/PipeStatus.java
(85%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{schema/tree/ITreeNode.java
=> sync/pipe/SyncOperation.java} (87%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/TsFilePipeInfo.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender/pipe =>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipesink}/IoTDBPipeSink.java
(78%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender/pipe =>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipesink}/PipeSink.java
(65%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{ =>
utils}/SyncConstant.java (98%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{ =>
utils}/SyncPathUtil.java (99%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/SyncInfo.java
rename
server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/{PipeMessage.java =>
PipeSinkFactory.java} (55%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
server/src/main/java/org/apache/iotdb/db}/trigger/service/TriggerClassLoader.java
(97%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
server/src/main/java/org/apache/iotdb/db}/trigger/service/TriggerClassLoaderManager.java
(63%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/path/MeasurementPathTest.java
rename
server/src/test/java/org/apache/iotdb/db/sync/receiver/manager/{SyncInfoTest.java
=> LocalSyncInfoTest.java} (62%)
