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 5e731bf8982 Merge branch 'master' of https://github.com/apache/iotdb
into pipe-meta-sync
add 2f6c6d048d1 Pipe Meta: Fixed concurrent bug of start and close
operation for schema region extractor & fixed IT flush problems (#12044)
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/AbstractPipeDualAutoIT.java | 7 +++-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 8 +++-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 44 +++++++++++++++++++---
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 16 --------
.../pipe/it/manual/AbstractPipeDualManualIT.java | 7 +++-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 4 +-
.../schemaregion/SchemaExecutionVisitor.java | 4 +-
.../dataregion/IoTDBDataRegionExtractor.java | 4 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 29 +++++++++-----
.../downsampling/DownSamplingProcessor.java | 3 +-
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 9 ++---
.../subtask/connector/PipeConnectorSubtask.java | 4 +-
.../plan/node/pipe/OperateSchemaQueueNode.java | 16 ++++----
.../AbstractSerializableListeningQueue.java | 5 +++
.../ConcurrentIterableLinkedQueue.java | 2 +-
.../commons/pipe/extractor/IoTDBMetaExtractor.java | 28 +++++++++-----
21 files changed, 168 insertions(+), 67 deletions(-)
