This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch fix-pipe-tablet-with-nullable-binary-columns
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a0defb64a62 [IOTDB-6021] Pipe: NPE when sync TEXT timeseries with null
fields between IoTDB instances using file mode with pattern filter
add 4e8cb333130 Pipe: fix bugs & smells reported by SonarCloud
(org.apache.iotdb.db.pipe) (#10268)
new 981fd999c76 Merge branch 'master' of github.com:apache/iotdb into
fix-pipe-tablet-with-nullable-binary-columns
new 6d2ad66adc8 [IOTDB-6021] Pipe: NPE when sync TEXT timeseries with null
fields between IoTDB instances using file mode with pattern filter
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:
.../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 | 47 +++++--
.../task/subtask/PipeConnectorSubtaskManager.java | 13 +-
.../db/pipe/task/subtask/PipeProcessorSubtask.java | 1 -
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 46 +++++--
42 files changed, 386 insertions(+), 361 deletions(-)
