This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch fixWriteFlushWithConcurrentQuery
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a0d71bdbdb2 add comments
add c08dc674c74 Pipe: Reduced the downgraded epochs' downgrading limit to
reduce the latency (#17184)
add 1b0a9d76883 Pipe: Enabled locally retry for PipeConnectionException
(#17182)
add 06537dc2fd0 correct metadata "modified" flags and related logic
(#17172)
add 69142ce7477 Pipe: Enabled retry locally for air gap receiver &
temporary unavailable exception (#17188)
add ba6327e19d0 Remove unused AGGREGATE_TIME_LIST (#17186)
add 659d88b16ef Merge branch 'iotdb_master' into
fixWriteFlushWithConcurrentQuery
add 955b4ea5839 fix ut
No new revisions were added by this update.
Summary of changes:
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 6 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 1 -
.../src/main/java/org/apache/iotdb/cli/Cli.java | 2 -
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 9 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 2 +-
.../exchange/sender/TwoStageAggregateSender.java | 5 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 62 +++---
.../client/IoTDBDataNodeAsyncClientManager.java | 4 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 2 +-
.../pipeconsensus/PipeConsensusSyncSink.java | 2 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 2 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 37 ++--
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../async/handler/PipeTransferTsFileHandler.java | 8 +-
.../PipeRealtimeDataRegionHybridSource.java | 16 +-
.../execution/operator/source/FileLoaderUtils.java | 80 ++------
.../execution/operator/source/SeriesScanUtil.java | 47 +----
.../GeneralRegionAttributeSecurityService.java | 4 +-
.../schemaregion/utils/ResourceByPathUtils.java | 6 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 7 +
.../read/reader/chunk/MemAlignedPageReader.java | 9 +-
.../read/reader/chunk/MemChunkReader.java | 7 +
.../read/reader/chunk/MemPageReader.java | 9 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 126 ++++--------
.../dataregion/memtable/PrimitiveMemTableTest.java | 10 +-
.../iotdb/commons/client/ClientPoolFactory.java | 20 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 211 ++++++++++++++-------
.../task/subtask/PipeAbstractSinkSubtask.java | 20 +-
.../agent/task/subtask/PipeReportableSubtask.java | 23 ++-
.../iotdb/commons/pipe/config/PipeConfig.java | 117 +++++++-----
.../iotdb/commons/pipe/config/PipeDescriptor.java | 57 ++++--
.../pipe/sink/client/IoTDBClientManager.java | 2 +-
.../commons/pipe/sink/client/IoTDBSyncClient.java | 2 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 4 +-
.../pipe/sink/limiter/GlobalRPCRateLimiter.java | 2 +-
.../pipe/sink/protocol/IoTDBAirGapSink.java | 4 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 12 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 2 +-
pom.xml | 2 +-
40 files changed, 488 insertions(+), 457 deletions(-)
