This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch feature/memory_transfer
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8b4b0560c21 Merge branch 'master' into feature/memory_transfer
add 33733f48a13 Update name
add 7cef068e674 Pipe: Fixed the NPE for last table node in snapshot parser
& Added judging logic when table is also device in snapshot parser & Refactor &
Fixed the missing trimming logic for tsFile & Enhanced the table idempotency
logic & Fixed the ttl + table database privilege logic at receiver side & Fixed
the bug that the table write auto-create-db does not check privilege (#15135)
add cd5cd233d68 Updated moquette version to fix MQTT write direct memory
leak issue (#15144)
add f16cee80e50 Pipe: Fixed the bug that OPC DA sink may free a string
multiple times (#15165)
add b4e0b0278f5 Fix broken file genaterated after insert null to aligned
timeseries (#15163)
add c215fef2acc Fix table model UDF can be invoked after dropped.
add 3ec698db88c Clean databaseName when setSqlDialect
add af03c1692b4 [RTO/RPO] Topology awareness for query plan (#15014)
add 59e5b617c34 Merge branch 'master' into feature/memory_transfer
No new revisions were added by this update.
Summary of changes:
dependencies.json | 10 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 8 +
.../udf/IoTDBUserDefinedAggregateFunctionIT.java | 9 +-
.../it/query/recent/IoTDBNullIdQueryIT.java | 12 +
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 28 ++
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 2 +
.../iotdb/session/pool/TableSessionWrapper.java | 28 +-
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 5 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../iotdb/confignode/manager/ClusterManager.java | 12 +-
.../iotdb/confignode/manager/load/LoadManager.java | 10 +-
.../manager/load/cache/AbstractLoadCache.java | 2 +-
.../manager/load/cache/IFailureDetector.java | 5 +-
.../confignode/manager/load/cache/LoadCache.java | 29 +-
.../manager/load/cache/detector/FixedDetector.java | 2 +-
.../load/cache/detector/PhiAccrualDetector.java | 19 +-
.../load/cache/node/AINodeHeartbeatCache.java | 2 +-
.../load/cache/node/ConfigNodeHeartbeatCache.java | 2 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 2 +-
.../manager/load/cache/region/RegionCache.java | 9 +-
.../load/cache/region/RegionGroupCache.java | 15 +-
.../manager/load/service/EventService.java | 11 +-
.../manager/load/service/HeartbeatService.java | 8 +
.../manager/load/service/TopologyService.java | 297 +++++++++++++++++++++
.../load/subscriber/IClusterStatusSubscriber.java | 6 +-
.../load/subscriber/NodeStatisticsChangeEvent.java | 3 +-
.../runtime/PipeLeaderChangeHandler.java | 12 -
.../runtime/PipeRuntimeCoordinator.java | 12 -
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 61 ++++-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 20 +-
.../manager/load/cache/RegionGroupCacheTest.java | 19 +-
.../manager/load/cache/detector/DetectorTest.java | 21 +-
iotdb-core/datanode/pom.xml | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +-
.../agent/task/connection/PipeEventCollector.java | 15 +-
.../protocol/opcda/OpcDaServerHandle.java | 5 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 5 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 1 +
.../client/dn/AsyncTSStatusRPCHandler.java | 25 +-
.../client/dn/DataNodeAsyncRequestRPCHandler.java | 20 +-
...ger.java => DataNodeIntraHeartbeatManager.java} | 30 +--
.../iotdb/db/protocol/session/IClientSession.java | 6 +
.../impl/DataNodeInternalRPCServiceImpl.java | 28 ++
.../iotdb/db/queryengine/plan/ClusterTopology.java | 175 ++++++++++++
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../SimpleFragmentParallelPlanner.java | 11 +
.../distribution/WriteFragmentParallelPlanner.java | 7 +-
.../ReplicaSetUnreachableException.java} | 19 +-
.../exceptions/RootFIPlacementException.java} | 32 +--
.../plan/planner/plan/FragmentInstance.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 22 +-
.../distribute/TableModelQueryFragmentPlanner.java | 12 +
.../scheduler/FragmentInstanceDispatcherImpl.java | 5 +
.../storageengine/dataregion/DataRegionInfo.java | 1 +
.../dataregion/memtable/AbstractMemTable.java | 5 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 3 +-
.../db/tools/schema/SRStatementGenerator.java | 8 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 9 +-
.../iotdb/commons/client/ClientPoolFactory.java | 1 +
.../client/request/AsyncRequestManager.java | 10 +-
...a => DataNodeIntraHeartbeatRequestManager.java} | 5 +-
.../client/request/TestConnectionUtils.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/memory/MemoryManager.java | 4 +-
.../iotdb/commons/memory/MemoryRuntimeAgent.java | 3 +-
.../iotdb/commons/partition/ExecutorType.java | 8 +-
.../iotdb/commons/partition/QueryExecutor.java | 8 +-
.../iotdb/commons/partition/StorageExecutor.java | 10 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 2 +-
.../commons/udf/service/UDFManagementService.java | 2 +-
.../thrift-commons/src/main/thrift/common.thrift | 1 +
.../src/main/thrift/datanode.thrift | 4 +
pom.xml | 11 +-
75 files changed, 987 insertions(+), 226 deletions(-)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/TopologyService.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/{DnToDnInternalServiceAsyncRequestManager.java
=> DataNodeIntraHeartbeatManager.java} (60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/ClusterTopology.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/auth/AccessDeniedException.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/exceptions/ReplicaSetUnreachableException.java}
(58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/query/QueryProcessException.java
=> queryengine/plan/planner/exceptions/RootFIPlacementException.java} (55%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/request/{DataNodeInternalServiceRequestManager.java
=> DataNodeIntraHeartbeatRequestManager.java} (90%)
