This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch mergeLastQueryScanNodeOfSameDevice
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0f3201ad7b2 fix last query sort operator
add 346ee720e7a [remove datanode] Fix ArrayIndexOutOfBoundsException in
computeInitialDbLoad (#15718)
add a2432d2fc2f Fixed the bug that the characters surrounded by "" cannot
be parsed in tree view path
add 7b5a2b39416 Using join to query views of non-aligned series may throw
NullPointerException
add 882c4b7898c Fixed the bug that the old view's cache is not cleared
when altering its name
add 232e0c9054f Fix timeout didn't pass to client bug
add 726d0935320 Subscription: fix drop subscription from session under
table model (#15725)
add cc3c442a1e2 Return empty result set for non aligned series when no
filed columns can be obtained from view
add b34e05e5da4 fix exception msg in RPR
add 58927a19d3a Fixed the potential failure for table view query with
pattern beyond databases
add ca2ad11712f Conf Template: Fix wrong symbol (#15742)
add 5d5e0478bc1 Pipe: Set WAL to uncompressed when using real-time sync
(#15733)
add f7992dd37fb Pipe: Fixed the insert node EMA logic for degrading
(#15741)
add 8763d57e8bb Fix RPROperator blocking behavior
add 55232d021e9 fix tsfile checker leak (#15710)
add 8a8a7bedb5b Avoiding error log by removing ThreadLocal for Mqtt Client
add 1fc3eae29b4 Fix TypeProvider and AggregationDescriptor serde in
Templated Query
add 0c35003d41e Reset global time filter for each device in table view scan
add f55dfe07e5e Add more tests for removing datanode (#15749)
add 732b459f96c Merge branch 'iotdb_master' into
mergeLastQueryScanNodeOfSameDevice
No new revisions were added by this update.
Summary of changes:
.../IoTDBRemoveConfigNodeITFramework.java | 2 +-
.../IoTDBRemoveDataNodeNormalIT.java | 362 ++++++++++++++++++++-
.../removedatanode/IoTDBRemoveDataNodeUtils.java | 180 ++++++++++
...work.java => IoTDBRemoveUnknownDataNodeIT.java} | 297 +++++++----------
.../confignode/it/utils/ConfigNodeTestUtils.java | 12 +
.../query/view/recent/IoTDBTableViewQueryIT.java | 5 +
.../recent/IoTDBTableViewWithTreeTTLQueryIT.java | 38 ++-
.../relational/it/schema/IoTDBDatabaseIT.java | 4 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 72 ++--
.../iotdb/confignode/manager/ConfigManager.java | 14 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../region/GreedyCopySetRegionGroupAllocator.java | 8 +-
.../subscription/SubscriptionCoordinator.java | 3 +-
.../procedure/impl/schema/SchemaUtils.java | 20 +-
.../table/AbstractAlterOrDropTableProcedure.java | 23 +-
.../impl/schema/table/CreateTableProcedure.java | 8 +-
.../impl/schema/table/RenameTableProcedure.java | 6 +-
.../GreedyCopySetRemoveNodeReplicaSelectTest.java | 11 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 6 +-
.../dataregion/IoTDBDataRegionExtractor.java | 25 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 30 +-
.../pipeconsensus/PipeConsensusReceiverAgent.java | 138 ++++----
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +-
.../iotdb/db/protocol/session/SessionManager.java | 14 +
.../impl/DataNodeInternalRPCServiceImpl.java | 10 +-
.../exchange/source/LocalSourceHandle.java | 13 +-
.../fragment/FragmentInstanceManager.java | 8 +-
.../process/PatternRecognitionOperator.java | 6 +
.../rowpattern/expression/ArithmeticOperator.java | 7 +-
.../rowpattern/expression/ComparisonOperator.java | 8 +-
.../process/rowpattern/expression/Computation.java | 9 +-
.../rowpattern/expression/LogicalOperator.java | 4 +-
.../expression/PatternExpressionComputation.java | 3 +-
.../schema/source/TableDeviceQuerySource.java | 9 +-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 8 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 1 +
.../metadata/relational/ShowCreateViewTask.java | 9 +-
.../plan/planner/OperatorTreeGenerator.java | 8 +-
.../plan/planner/TableOperatorGenerator.java | 28 +-
.../source/AlignedSeriesAggregationScanNode.java | 6 +
.../planner/plan/parameter/SeriesScanOptions.java | 24 +-
.../relational/analyzer/ExpressionAnalyzer.java | 19 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 12 +-
.../fetcher/TableDeviceSchemaValidator.java | 6 +-
.../relational/planner/TableLogicalPlanner.java | 5 +
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../planner/rowpattern/IrRowPattern.java | 40 +--
.../plan/relational/sql/parser/AstBuilder.java | 7 +-
.../db/schemaengine/table/DataNodeTableCache.java | 42 ++-
.../iotdb/db/schemaengine/table/ITableCache.java | 10 +-
.../SchemaRegionSimpleRecoverTest.java | 4 +-
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 4 +-
.../analyzer/RowPatternRecognitionTest.java | 32 ++
.../plan/relational/analyzer/TreeViewTest.java | 4 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 12 +-
.../storageengine/dataregion/DataRegionTest.java | 4 +-
.../TableModelCompactionWithTTLTest.java | 4 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 4 +-
.../conf/iotdb-system.properties.template | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 34 +-
.../commons/exception/QueryTimeoutException.java | 4 +
.../iotdb/commons/pipe/config/PipeConfig.java | 13 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 14 +-
.../src/main/thrift/datanode.thrift | 1 +
65 files changed, 1251 insertions(+), 480 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/IoTDBRemoveDataNodeUtils.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/{IoTDBRemoveDataNodeITFramework.java
=> IoTDBRemoveUnknownDataNodeIT.java} (56%)
