This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-meta-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 21e1c83274d Merge branch 'master' of https://github.com/apache/iotdb
into pipe-meta-sync
add 994785b4547 Pipe Meta: Fixed the bug that queue may be cleared after
failed sync & clearing queue failure is not reported & may write consensus on
dataNode after consensus closed (#12062)
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 13 ------
.../env/cluster/config/MppSharedCommonConfig.java | 14 -------
.../it/env/remote/config/RemoteCommonConfig.java | 10 -----
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 --
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 15 +++++++
.../statemachine/ConfigRegionStateMachine.java | 11 ++---
.../manager/load/balancer/RegionBalancer.java | 8 ++--
.../confignode/persistence/pipe/PipeTaskInfo.java | 2 +-
.../persistence/ConfigPlanListeningQueueTest.java | 2 +-
.../schemaregion/SchemaRegionStateMachine.java | 12 ++++--
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 49 ++++++++++++----------
.../schemaregion/IoTDBSchemaRegionExtractor.java | 8 ++--
.../extractor/SchemaNodeListeningQueueTest.java | 2 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 21 ++++------
.../datastructure/AbstractPipeListeningQueue.java | 8 ++--
.../pipe/extractor/IoTDBCommonExtractor.java | 2 -
16 files changed, 84 insertions(+), 97 deletions(-)
