This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/show-receivers
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 34a21798acf Merge branch 'master' of https://github.com/apache/iotdb
into feat/show-receivers
add 8735702a775 Reduce repeated failure logs (#18175)
add b05f4cadb76 Avoid readLock when serializing TimeIndex. (#18189)
add ce74949268e Fix tag index misalignment in read_tsfile when projection
pruning removes tag columns (#18191)
add 5ceb047fe83 Fix DataNode restart readiness race in IoTDBConnectionsIT
(#18192)
add 7ffb1364b84 Add mutual SSL support for pipe sinks (#18080)
add eaef430d2b9 Enforce REST query row limit as hard cap (#18149)
add 0d3304a106a Fix RPC buffer memory control activation (#18194)
add ededa9a57ba Pipe IT: disable pipe memory control in overridden setups
(#18198)
add e75d1466251 Fix retry bug in tree model query which ignore the time
filter (#18179)
add 5bb15d980f4 Pipe: optimize InsertRows schema aggregation (#18195)
add f1875ed5d06 Fix external TsFile grouping optimization (#18206)
add 58c5ce85f6a Merge branch 'master' of https://github.com/apache/iotdb
into feat/show-receivers
No new revisions were added by this update.
Summary of changes:
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 1 +
.../src/main/openapi3/iotdb_rest_v1.yaml | 1 +
.../src/main/openapi3/iotdb_rest_v2.yaml | 1 +
.../org/apache/iotdb/rest/i18n/RestMessages.java | 3 +
.../org/apache/iotdb/rest/i18n/RestMessages.java | 3 +
.../rest/protocol/handler/QueryRowLimitUtils.java | 71 ++++++
.../table/v1/handler/QueryDataSetHandler.java | 44 +---
.../protocol/table/v1/impl/RestApiServiceImpl.java | 9 +-
.../protocol/v1/handler/QueryDataSetHandler.java | 114 +++++----
.../protocol/v1/impl/GrafanaApiServiceImpl.java | 19 +-
.../rest/protocol/v1/impl/RestApiServiceImpl.java | 8 +-
.../rest/protocol/v2/handler/FastLastHandler.java | 65 +++++-
.../protocol/v2/handler/QueryDataSetHandler.java | 114 +++++----
.../protocol/v2/impl/GrafanaApiServiceImpl.java | 19 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 48 +---
.../protocol/handler/QueryRowLimitUtilsTest.java | 59 +++++
.../v1/handler/QueryDataSetHandlerTest.java | 222 ++++++++++++++++++
.../protocol/v2/handler/FastLastHandlerTest.java | 119 ++++++++++
.../treemodel/auto/basic/IoTDBPipeMutualSSLIT.java | 176 ++++++++++++++
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 16 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 6 +-
.../recent/IoTDBReadTsFileTableFunctionIT.java | 50 ++++
.../iotdb/session/it/IoTDBConnectionsIT.java | 30 ++-
.../api/customizer/parameter/PipeParameters.java | 1 +
.../customizer/parameter/PipeParametersTest.java | 12 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../org/apache/iotdb/rpc/AutoResizingBuffer.java | 24 +-
.../iotdb/rpc/AutoResizingBufferMemoryManager.java | 25 +-
.../apache/iotdb/rpc/AutoResizingBufferTest.java | 37 +++
.../src/test/resources/iotdb-common.properties | 3 +-
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 4 +
.../confignode/conf/ConfigNodeDescriptor.java | 4 +-
.../manager/partition/PartitionManager.java | 8 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 10 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 2 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 4 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 4 +
.../iotdb/confignode/service/ConfigNode.java | 2 -
.../pipe/sink/IoTDBConfigRegionSinkTest.java | 46 ++++
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 8 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 8 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 12 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 10 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
.../client/IoTDBDataNodeSyncClientManager.java | 4 +
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 123 +++++++++-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 27 ++-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 4 +
.../realtime/epoch/TsFileEpochManager.java | 70 ++++--
.../thrift/impl/DataNodeRegionManager.java | 8 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 106 +++++----
.../db/queryengine/plan/analyze/Analyzer.java | 16 +-
.../plan/analyze/ConcatPathRewriter.java | 23 +-
.../queryengine/plan/analyze/PredicateUtils.java | 177 ++++++++------
.../plan/analyze/TemplatedAggregationAnalyze.java | 71 ++++--
.../queryengine/plan/analyze/TemplatedAnalyze.java | 20 +-
.../plan/analyze/TreeAnalysisMutationJournal.java | 255 +++++++++++++++++++++
.../queryengine/plan/execution/QueryExecution.java | 47 +++-
.../visitor/predicate/PredicateSimplifier.java | 83 ++++---
.../db/queryengine/plan/planner/IPlanner.java | 6 +
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 20 +-
.../plan/planner/plan/node/PlanVisitor.java | 2 +-
.../relational/analyzer/StatementAnalyzer.java | 21 +-
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../sql/ast/AbstractQueryDeviceWithCache.java | 24 ++
.../plan/relational/sql/ast/CountDevice.java | 9 +
.../plan/relational/sql/ast/ShowDevice.java | 11 +
.../plan/statement/component/GroupByComponent.java | 5 +
.../plan/statement/component/OrderByComponent.java | 30 +++
.../plan/statement/component/WhereCondition.java | 7 +
.../schemaregion/SchemaRegionLoader.java | 8 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 1 +
.../dataregion/tsfile/TsFileResource.java | 3 +-
.../iotdb/db/conf/DataNodeMemoryConfigTest.java | 17 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 193 ++++++++++++++++
.../epoch/TsFileEpochManagerPerformanceTest.java | 212 +++++++++++++++++
.../realtime/epoch/TsFileEpochManagerTest.java | 105 +++++++++
.../db/queryengine/plan/analyze/AnalyzeTest.java | 238 +++++++++++++++++++
.../plan/analyze/PredicateUtilsTest.java | 172 ++++++++++++++
.../plan/analyze/TemplatedAnalyzeRetryTest.java | 127 ++++++++++
.../plan/execution/QueryExecutionRetryTest.java | 218 ++++++++++++++++++
.../plan/planner/LogicalPlanBuilderTest.java | 113 +++++++++
.../plan/relational/analyzer/AnalyzerTest.java | 117 ++++++++++
.../optimizations/ParallelizeGroupingTest.java | 111 +++++++++
.../plan/statement/QueryStatementTest.java | 26 +++
.../src/test/resources/iotdb-common.properties | 3 +-
.../src/test/resources/iotdb-system.properties | 3 +-
.../conf/iotdb-system.properties.template | 4 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 4 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 11 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 4 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 9 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 47 ++--
.../apache/iotdb/commons/disk/FolderManager.java | 5 +-
.../LoggerPeriodicalLogReducer.java} | 65 ++++--
.../apache/iotdb/commons/memory/MemoryConfig.java | 27 +--
.../iotdb/commons/pipe/config/PipeDescriptor.java | 16 +-
.../pipe/config/constant/PipeSinkConstant.java | 10 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 16 +-
.../commons/pipe/resource/log/PipeLogger.java | 22 +-
.../commons/pipe/sink/client/IoTDBSyncClient.java | 17 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 10 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 125 ++++++++--
.../LoggerPeriodicalLogReducerTest.java} | 21 +-
106 files changed, 4101 insertions(+), 599 deletions(-)
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/handler/QueryRowLimitUtils.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/handler/QueryRowLimitUtilsTest.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/v1/handler/QueryDataSetHandlerTest.java
create mode 100644
external-service-impl/rest/src/test/java/org/apache/iotdb/rest/protocol/v2/handler/FastLastHandlerTest.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeMutualSSLIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TreeAnalysisMutationJournal.java
copy
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java
=>
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/DataNodeMemoryConfigTest.java
(61%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/PredicateUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyzeRetryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecutionRetryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LogicalPlanBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/ParallelizeGroupingTest.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/resource/log/PipePeriodicalLogReducer.java
=> log/LoggerPeriodicalLogReducer.java} (55%)
rename
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/{pipe/resource/log/PipePeriodicalLogReducerTest.java
=> log/LoggerPeriodicalLogReducerTest.java} (67%)
