This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch IOTDB-5787
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ba4dea63069 [IOTDB-5765] Support ORDER BY expression [FE Part]
new 02f77a7000a interface for task management
new 15f62d4efe7 createPipe impl (TBD)
add e2114510329 Avoid Result Handle clean up twice which will cause NPE
add 8db6527e80c [IOTDB-5825]Fix error in aligned empty value chunk in fast
compaction (#9719)
add 17711231b88 [IOTDB-5834] Fix unclear error msg when querying
nonexistent schema template (#9738)
add 87ea559d63b [rest service] support show data regionid query (#9737)
add ad3c2979610 [IOTDB-5835] Fix wal accumulation caused by datanode
restart
add 0a7d2b73d8b [IOTDB-5832] Fix Bug: The size of readyQueue is negative
incorrectly
add efc61e2b06a update disk usage and file num when delete wal node (#9730)
add 5fb6e2b76c6 [IOTDB-5701] Upgrade Performance Overview Metrics to Core
(#9741)
add f6e8473a8dd [IOTDB-5817] Optimize error message of python client
(#9744)
add 970f727721b add dn_consensus_dir doc (#9729)
add dbd1f93dd6a [IOTDB-5831] Fix drop database won't delete totally files
in disk during data insertion (#9754)
add d66dff323e7 [IOTDB-5828] Optimize the performance of some parts in
metrics, and correcting the metrics count of temporal file size in inner space
compaction (#9753)
add bafa3aefb06 [IOTDB-5808] Refactor RouteBalancer to match LoadManager
framework (#9694)
add 6acf8db72bc Bump progressbar from 0.9.3 to 0.9.5 (#9752)
add ea66fc5bee0 Bump openapi-generator-maven-plugin from 5.0.0 to 5.0.1
(#9751)
add b0ca86dbff4 update doc of Community material (#9748)
add 4ca333c8e57 Update workbench documentation with installation method
and name bug (#9759)
add 3f166ed37a5 [IOTDB-5824] Fix show devices with * cannot display
satisfied devices (#9755)
add 18cdc0b75f8 Fix typo in syntax conventions doc (#9760)
add aaa20e3ae26 [IOTDB-5831]Fix drop database won't delete totally files
in disk during data insertion (#9763)
add c98016f9962 [IOTDB-5840] Enhance the problem that the insertRecords
interface may cause the number of threads to balloon when there are too many
data regions (#9768)
add 2ac9b5197c6 Add config min_cross_compaction_unseq_file_level for
cross compaction (#9766)
add ee4df02d5b0 [IOTDB-5842] Sync: Delete BufferedPipeDataQueueTest (#9774)
new c16bc7f7a06 Merge branch 'master' of github.com:apache/iotdb into
IOTDB-5787
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
client-py/SessionExample.py | 1 -
client-py/iotdb/Session.py | 323 +++++-----
.../IoTDBConnectionException.py} | 27 +-
client-py/iotdb/utils/IoTDBRpcDataSet.py | 10 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 6 +-
.../statemachine/ConfigRegionStateMachine.java | 2 -
.../confignode/manager/ClusterSchemaManager.java | 20 +-
.../iotdb/confignode/manager/ConfigManager.java | 4 +-
.../iotdb/confignode/manager/load/LoadManager.java | 117 ++--
.../manager/load/balancer/RouteBalancer.java | 268 ++-------
.../load/balancer/router/RegionRouteMap.java | 176 ------
.../confignode/manager/load/cache/LoadCache.java | 156 ++++-
.../manager/load/cache/route/RegionRouteCache.java | 138 +++++
.../manager/load/service/HeartbeatService.java | 1 -
.../manager/load/service/StatisticsService.java | 70 ++-
.../manager/load/subscriber/RouteChangeEvent.java | 35 +-
.../manager/partition/PartitionManager.java | 6 +-
.../persistence/executor/ConfigPlanExecutor.java | 7 +-
.../persistence/partition/PartitionInfo.java | 5 +
.../procedure/env/ConfigNodeProcedureEnv.java | 34 +-
.../procedure/env/DataNodeRemoveHandler.java | 4 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 2 +-
.../impl/schema/DataNodeRegionTaskExecutor.java | 4 +-
.../impl/schema/DeleteDatabaseProcedure.java | 2 -
.../statemachine/CreateRegionGroupsProcedure.java | 1 -
.../load/balancer/router/RegionRouteMapTest.java | 82 ---
.../consensus/iot/IoTConsensusServerImpl.java | 13 +-
docs/Community/Materials.md | 103 ++--
docs/UserGuide/QuickStart/Files.md | 2 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 14 +-
.../Syntax-Conventions/Session-And-TsFile-API.md | 4 +-
.../UserGuide/Ecosystem-Integration/Workbench.md | 79 +--
docs/zh/UserGuide/QuickStart/Files.md | 2 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 21 +-
.../Syntax-Conventions/Session-And-TsFile-API.md | 4 +-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 31 +-
.../metricsets/net/LinuxNetMetricManager.java | 27 +-
.../iotdb/metrics/metricsets/net/NetMetrics.java | 2 +-
.../resources/conf/iotdb-common.properties | 4 +
.../commons/pipe/task/meta/PipeStaticMeta.java | 18 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 122 +++-
pom.xml | 4 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +
.../iotdb/db/engine/TsFileMetricManager.java | 63 +-
.../performer/impl/FastCompactionPerformer.java | 19 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../impl/ReadPointCompactionPerformer.java | 21 +-
.../execute/task/AbstractCompactionTask.java | 12 +-
.../execute/task/CompactionTaskSummary.java | 18 +
.../execute/task/CrossSpaceCompactionTask.java | 11 +-
.../execute/task/InnerSpaceCompactionTask.java | 7 +-
.../fast/AlignedSeriesCompactionExecutor.java | 16 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 6 -
.../utils/writer/AbstractCompactionWriter.java | 3 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 2 +-
.../db/metadata/mtree/traverser/Traverser.java | 61 ++
.../traverser/TraverserWithLimitOffsetWrapper.java | 5 +
.../mtree/traverser/basic/DatabaseTraverser.java | 5 +
.../mtree/traverser/basic/EntityTraverser.java | 8 +
.../mtree/traverser/basic/MNodeTraverser.java | 5 +
.../traverser/basic/MeasurementTraverser.java | 5 +
.../metadata/template/ClusterTemplateManager.java | 7 +-
.../db/metadata/template/ITemplateManager.java | 3 +-
.../visitor/SchemaTreeDeviceVisitor.java | 5 +
.../visitor/SchemaTreeMeasurementVisitor.java | 5 +
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 6 +
.../iotdb/db/mpp/execution/driver/Driver.java | 2 +-
.../execution/schedule/AbstractDriverThread.java | 9 +
.../schedule/queue/IndexedBlockingQueue.java | 1 +
.../multilevelqueue/MultilevelPriorityQueue.java | 4 +-
.../db/mpp/plan/execution/QueryExecution.java | 7 +-
.../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 74 ++-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 27 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 20 +-
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 2 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 50 +-
.../rest/v1/handler/ExecuteStatementHandler.java | 4 +-
.../rest/v1/handler/QueryDataSetHandler.java | 5 +-
.../rest/v2/handler/ExecuteStatementHandler.java | 4 +-
.../rest/v2/handler/QueryDataSetHandler.java | 5 +-
.../db/service/metrics/CompactionMetrics.java | 12 +-
.../iotdb/db/service/metrics/FileMetrics.java | 26 +-
.../metrics/recorder/CompactionMetricsManager.java | 6 +-
.../db/service/thrift/ProcessorWithMetrics.java | 2 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 36 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 8 +-
.../db/wal/allocation/FirstCreateStrategy.java | 3 +
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 41 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 14 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 -
.../engine/compaction/AbstractCompactionTest.java | 3 +
.../compaction/CompactionTaskComparatorTest.java | 8 +-
.../compaction/FastAlignedCrossCompactionTest.java | 347 ++++++++++-
.../FastInnerCompactionPerformerTest.java | 30 +-
.../FastNonAlignedCrossCompactionTest.java | 347 ++++++++++-
.../ReadPointAlignedCrossCompactionTest.java | 347 ++++++++++-
.../ReadPointNonAlignedCrossCompactionTest.java | 347 ++++++++++-
.../CrossSpaceCompactionWithFastPerformerTest.java | 7 +-
...eCompactionWithFastPerformerValidationTest.java | 194 +++---
...actionWithReadPointPerformerValidationTest.java | 168 +++---
.../utils/MultiTsFileDeviceIteratorTest.java | 12 +-
.../schemaRegion/SchemaRegionBasicTest.java | 103 +++-
.../apache/iotdb/db/metric/MetricServiceTest.java | 3 -
.../DataNodeInternalRPCServiceImplTest.java | 31 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 658 ---------------------
thrift/src/main/thrift/datanode.thrift | 16 +-
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 4 -
108 files changed, 3088 insertions(+), 2167 deletions(-)
copy client-py/iotdb/{tsfile/common/constant/TsFileConstant.py =>
utils/IoTDBConnectionException.py} (67%)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMap.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/route/RegionRouteCache.java
delete mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMapTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/pipedata/BufferedPipeDataQueueTest.java
