This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch fix-pipe-tablet-with-nullable-binary-columns in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 981fd999c7630deed8ca5c31768632d2bc874b8b Merge: a0defb64a62 4e8cb333130 Author: Steve Yurong Su <[email protected]> AuthorDate: Thu Jun 22 03:58:55 2023 +0800 Merge branch 'master' of github.com:apache/iotdb into fix-pipe-tablet-with-nullable-binary-columns .../db/pipe/agent/plugin/PipePluginAgent.java | 11 +- .../db/pipe/agent/runtime/PipeRuntimeAgent.java | 6 +- .../SimpleConsensusProgressIndexAssigner.java | 5 +- .../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 135 +++++++++++---------- .../pipe/collector/IoTDBDataRegionCollector.java | 15 ++- .../PipeHistoricalDataRegionCollector.java | 4 +- .../PipeHistoricalDataRegionTsFileCollector.java | 8 +- .../realtime/PipeRealtimeDataRegionCollector.java | 2 +- .../PipeRealtimeDataRegionFakeCollector.java | 21 +++- .../PipeRealtimeDataRegionHybridCollector.java | 27 +++-- .../PipeRealtimeDataRegionLogCollector.java | 7 +- .../PipeRealtimeDataRegionTsFileCollector.java | 7 +- .../realtime/epoch/TsFileEpochManager.java | 11 +- .../matcher/CachedSchemaPatternMatcher.java | 4 +- .../pipe/connector/legacy/IoTDBSyncConnector.java | 56 ++++----- .../pipe/connector/legacy/IoTDBSyncReceiver.java | 37 ++---- .../legacy/pipedata/DeletionPipeData.java | 8 +- .../pipe/connector/legacy/pipedata/PipeData.java | 5 +- .../connector/legacy/pipedata/TsFilePipeData.java | 3 +- .../pipe/connector/v1/IoTDBThriftConnectorV1.java | 29 ++--- .../pipe/connector/v1/IoTDBThriftReceiverV1.java | 25 ++-- .../db/pipe/connector/v1/PipeRequestType.java | 5 +- .../PipeTransferTabletInsertionEventHandler.java | 4 +- .../PipeTransferTsFileInsertionEventHandler.java | 2 +- .../apache/iotdb/db/pipe/event/EnrichedEvent.java | 2 +- .../tablet/PipeInsertNodeTabletInsertionEvent.java | 3 - .../common/tablet/PipeRawTabletInsertionEvent.java | 10 +- .../tablet/TabletInsertionDataContainer.java | 27 ++--- .../common/tsfile/PipeTsFileInsertionEvent.java | 4 +- .../tsfile/TsFileInsertionDataContainer.java | 7 +- .../executor/PipeSubtaskExecutorManager.java | 6 +- .../resource/file/PipeFileResourceManager.java | 22 ++-- .../db/pipe/resource/wal/PipeWALResource.java | 10 +- .../pipe/resource/wal/PipeWALResourceManager.java | 79 ++++-------- .../db/pipe/task/connection/EventSupplier.java | 1 + .../db/pipe/task/stage/PipeTaskCollectorStage.java | 3 +- .../db/pipe/task/stage/PipeTaskConnectorStage.java | 4 +- .../iotdb/db/pipe/task/stage/PipeTaskStage.java | 25 ++-- .../db/pipe/task/subtask/PipeConnectorSubtask.java | 42 +++++-- .../task/subtask/PipeConnectorSubtaskManager.java | 13 +- .../db/pipe/task/subtask/PipeProcessorSubtask.java | 1 - .../iotdb/db/pipe/task/subtask/PipeSubtask.java | 46 +++++-- 42 files changed, 381 insertions(+), 361 deletions(-)
