This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/support_schema_evolution
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3d1325f18f9 spotless
add 69142ce7477 Pipe: Enabled retry locally for air gap receiver &
temporary unavailable exception (#17188)
add ba6327e19d0 Remove unused AGGREGATE_TIME_LIST (#17186)
add c052179dccf Support debug for query (#17178)
add d5f902333f8 Fix process of restore external-service instance #17194
add b929aa22350 Fix incorrect time slice calculation in
AbstractDefaultAggTableScanOperator (#17195)
add 7ee7a83b86f Fix race condition in SharedTsBlockQueue async listener
causing NPE in MemoryPool.free() (#17196)
add 15a0a7288cd Fixed concurrency issues caused by write and flush sorting
during query execution (#17193)
add fe0d62e3d7b Fix external service ClassLoader context handling and
dependency scope (#17202)
add f3e0b35c7f9 Merge branch 'master' into
force_ci/support_schema_evolution
add 6dc63c0f2e2 fix test
No new revisions were added by this update.
Summary of changes:
distribution/pom.xml | 1 -
external-service-impl/rest/pom.xml | 1 -
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 2 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 15 +++
.../it/query/recent/IoTDBDebugQueryIT.java | 105 +++++++++++++++++++++
.../java/org/apache/iotdb/cli/AbstractCli.java | 1 -
.../src/main/java/org/apache/iotdb/cli/Cli.java | 2 -
iotdb-core/datanode/pom.xml | 4 -
.../assembly/resources/conf/logback-datanode.xml | 2 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 60 +++++++-----
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 1 +
.../protocol/legacy/loader/DeletionLoader.java | 3 +-
.../protocol/legacy/loader/TsFileLoader.java | 3 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 6 +-
.../sink/protocol/writeback/WriteBackSink.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 42 ++++++---
.../impl/DataNodeInternalRPCServiceImpl.java | 1 +
.../db/queryengine/common/MPPQueryContext.java | 10 ++
.../execution/exchange/SharedTsBlockQueue.java | 34 +++++--
.../fragment/FakedFragmentInstanceContext.java | 2 +-
.../fragment/FragmentInstanceContext.java | 48 +++++++---
.../fragment/FragmentInstanceManager.java | 8 +-
.../execution/fragment/QueryContext.java | 10 +-
.../AbstractDefaultAggTableScanOperator.java | 2 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 93 ++++++++++++++++--
.../load/TreeSchemaAutoCreatorAndVerifier.java | 1 +
.../analyze/schema/AutoCreateSchemaExecutor.java | 1 +
.../analyze/schema/ClusterSchemaFetchExecutor.java | 3 +-
.../plan/execution/IQueryExecution.java | 2 +
.../queryengine/plan/execution/QueryExecution.java | 5 +
.../plan/execution/config/ConfigExecution.java | 5 +
.../config/executor/ClusterConfigTaskExecutor.java | 1 +
.../SimpleFragmentParallelPlanner.java | 1 +
.../distribution/WriteFragmentParallelPlanner.java | 3 +-
.../plan/planner/plan/FragmentInstance.java | 32 +++++--
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 4 +-
.../fetcher/TableDeviceSchemaValidator.java | 1 +
.../plan/relational/planner/CteMaterializer.java | 3 +-
.../distribute/TableModelQueryFragmentPlanner.java | 1 +
...ithUncorrelatedScalarSubqueryReconstructor.java | 3 +-
.../plan/relational/sql/ast/Statement.java | 9 ++
.../plan/relational/sql/parser/AstBuilder.java | 4 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 6 +-
.../view/visitor/TransformToExpressionVisitor.java | 21 ++---
.../ExternalServiceManagementService.java | 71 +++++++-------
.../dataregion/flush/MemTableFlushTask.java | 1 +
.../memtable/AbstractWritableMemChunk.java | 43 ++++++++-
.../memtable/AlignedWritableMemChunk.java | 94 +++++++++++-------
.../dataregion/memtable/IWritableMemChunk.java | 2 +
.../dataregion/memtable/WritableMemChunk.java | 38 ++++----
.../load/active/ActiveLoadTsFileLoader.java | 3 +-
.../converter/LoadTsFileDataTypeConverter.java | 1 +
.../db/utils/datastructure/AlignedTVList.java | 12 +++
.../iotdb/db/utils/datastructure/BinaryTVList.java | 9 ++
.../db/utils/datastructure/BooleanTVList.java | 9 ++
.../iotdb/db/utils/datastructure/DoubleTVList.java | 9 ++
.../iotdb/db/utils/datastructure/FloatTVList.java | 9 ++
.../iotdb/db/utils/datastructure/IntTVList.java | 9 ++
.../iotdb/db/utils/datastructure/LongTVList.java | 9 ++
.../iotdb/db/utils/datastructure/TVList.java | 2 +
.../execution/exchange/SharedTsBlockQueueTest.java | 82 +++++++++++++++-
.../operator/MergeTreeSortOperatorTest.java | 5 +
.../plan/planner/FragmentInstanceSerdeTest.java | 6 +-
.../relational/planner/CteMaterializerTest.java | 3 +-
.../plan/relational/planner/CteSubqueryTest.java | 3 +-
.../storageengine/dataregion/DataRegionTest.java | 8 +-
.../memtable/MemChunkDeserializeTest.java | 4 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 67 +++++++++++--
.../reader/chunk/MemAlignedChunkLoaderTest.java | 2 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 12 +--
.../wal/recover/file/TsFilePlanRedoerTest.java | 21 +++--
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 52 ++++++++--
.../iotdb/commons/externalservice/ServiceInfo.java | 9 ++
.../iotdb/commons/pipe/config/PipeConfig.java | 8 ++
.../iotdb/commons/pipe/config/PipeDescriptor.java | 11 ++-
.../db/relational/grammar/sql/RelationalSql.g4 | 5 +-
77 files changed, 934 insertions(+), 254 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBDebugQueryIT.java
