This is an automated email from the ASF dual-hosted git repository.
weihao pushed a change to branch addQueryDebug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 136abea61fc fix UT
add bfb0d32284d [AINode] Optimize the statuscode for remove AINode (#17176)
add d9b692bcca7 Pipe: Changed the separator check semantic for pipes /
pipe plugins (#17175)
add 861d3eec35b Pipe: Fixed the idempotent semantic for MULTIPLE_ERROR
(#17177)
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 4782366fa17 Merge branch 'master' of github.com:apache/iotdb into
addQueryDebug
add 3d3687d3ba1 modify
No new revisions were added by this update.
Summary of changes:
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 2 +-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 6 +-
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 2 +-
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 2 -
.../it/query/recent/IoTDBDebugQueryIT.java | 12 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 1 -
.../src/main/java/org/apache/iotdb/cli/Cli.java | 2 -
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 9 +-
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 2 +-
.../exchange/sender/TwoStageAggregateSender.java | 5 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 62 +++---
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
.../visitor/PipeStatementTSStatusVisitor.java | 219 ++++++++++-----------
...leStatementDataTypeConvertExecutionVisitor.java | 12 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 10 +-
.../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 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../execution/operator/source/FileLoaderUtils.java | 80 ++------
.../execution/operator/source/SeriesScanUtil.java | 47 +----
.../iotdb/db/queryengine/plan/Coordinator.java | 18 +-
.../plan/execution/IQueryExecution.java | 2 +
.../queryengine/plan/execution/QueryExecution.java | 5 +
.../plan/execution/config/ConfigExecution.java | 5 +
.../config/executor/ClusterConfigTaskExecutor.java | 17 +-
.../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 ++++--------
.../receiver/PipeStatementTsStatusVisitorTest.java | 65 ++++++
.../operator/MergeTreeSortOperatorTest.java | 5 +
.../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 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 2 +-
pom.xml | 2 +-
57 files changed, 720 insertions(+), 601 deletions(-)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTsStatusVisitorTest.java
