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 bb206ebcd19 rename
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 423de26c0cc Merge branch 'iotdb_master' into
fixWriteFlushWithConcurrentQuery
add 670547593e5 fix conflict
No new revisions were added by this update.
Summary of changes:
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 2 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 15 +++
.../it/query/recent/IoTDBDebugQueryIT.java | 105 +++++++++++++++++++++
.../assembly/resources/conf/logback-datanode.xml | 2 +-
.../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 +-
.../ExternalServiceManagementService.java | 42 ++++-----
.../load/active/ActiveLoadTsFileLoader.java | 3 +-
.../converter/LoadTsFileDataTypeConverter.java | 1 +
.../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 +-
.../memtable/MemChunkDeserializeTest.java | 4 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 21 +++--
.../reader/chunk/MemAlignedChunkLoaderTest.java | 2 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 12 +--
.../wal/recover/file/TsFilePlanRedoerTest.java | 21 +++--
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 5 +-
52 files changed, 555 insertions(+), 134 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBDebugQueryIT.java
