This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch strong_password
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f387eccdf4b fix test
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 3ff855e98d0 Fix stuck when stopping a DataNode with large unremovable
WAL files (#15727)
add ecdf0d77bc1 Fixed the device NPE for table view in view device & Added
semantic check to prohibit the last data query for prefix paths with "*" &
Refactored metric log of tag number
add 1b9a446ecea Pipe: Delete the extra tags created by the
PipeWALInsertNodeCacheMetrics (#15761)
add 02febc0506e Optimize group by query in ClientRPCServiceImpl to reduce
cpu usage
add bbe031aaebe Fix thread leak in session while connected DN is down
add e1b6e890dbc Pipe: Fixed the NPE when closing sync connector (#15772)
add c603b990c75 Subscription: return immediately when unsubscribe empty
complete topics (#15770)
add bdc31b79f48 Merge branch 'master' into strong_password
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 4 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../IoTDBRemoveConfigNodeITFramework.java | 2 +-
.../IoTDBRemoveDataNodeNormalIT.java | 362 ++++++++++++++++++++-
.../removedatanode/IoTDBRemoveDataNodeUtils.java | 180 ++++++++++
...work.java => IoTDBRemoveUnknownDataNodeIT.java} | 297 +++++++----------
.../confignode/it/utils/ConfigNodeTestUtils.java | 12 +
.../iotdb/db/it/IoTDBCustomizedClusterIT.java | 148 +++++++++
.../recent/IoTDBTableViewWithTreeTTLQueryIT.java | 38 ++-
.../java/org/apache/iotdb/session/Session.java | 6 +-
.../apache/iotdb/session/TableSessionBuilder.java | 7 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 2 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 5 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 6 +-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 2 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 4 +-
.../dataregion/IoTDBDataRegionExtractor.java | 25 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 30 +-
.../overview/PipeWALInsertNodeCacheMetrics.java | 4 +-
.../pipeconsensus/PipeConsensusReceiverAgent.java | 138 ++++----
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +-
.../iotdb/db/protocol/session/SessionManager.java | 14 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 73 +++--
.../execution/driver/DriverContext.java | 6 +
.../fragment/FakedFragmentInstanceContext.java | 106 ++++++
.../fragment/FragmentInstanceContext.java | 17 +-
.../execution/fragment/QueryContext.java | 2 +-
.../process/PatternRecognitionOperator.java | 6 +
.../schema/source/TableDeviceQuerySource.java | 14 +-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../execution/schedule/task/DriverTaskId.java | 3 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 8 +-
.../plan/planner/OperatorTreeGenerator.java | 8 +-
.../memory/FakedMemoryReservationManager.java} | 16 +-
.../source/AlignedSeriesAggregationScanNode.java | 6 +
.../planner/plan/parameter/SeriesScanOptions.java | 24 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 12 +-
.../fetcher/TableDeviceSchemaValidator.java | 6 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 31 +-
.../dataregion/tsfile/TsFileResourceList.java | 2 +-
.../storageengine/dataregion/wal/WALManager.java | 11 +-
.../receiver/SubscriptionReceiverV1.java | 6 +
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 3 +-
.../conf/iotdb-system.properties.template | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 34 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 13 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 14 +-
.../thrift-datanode/src/main/thrift/client.thrift | 1 +
50 files changed, 1324 insertions(+), 422 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%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBCustomizedClusterIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FakedFragmentInstanceContext.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{relational/sql/ast/JoinCriteria.java
=> planner/memory/FakedMemoryReservationManager.java} (70%)
