This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/change_ip_port_of_cluster
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ea0d2a10c2 fix port usage in maintenace-command.md
add 9436a29446 Update Time zone description in UserGuide (#7391)
add e6a85b6352 print redundancy clean session log when no session exist
(#7372)
add 5036ee2c61 [IOTDB-3862] Fix: Guarantee to add Ratis MetaFile
add 3c40544133 [IOTDB-4394] Build SessionIT environment (#7326)
add 265992dc21 [IOTDB-4251] Persist ChunkMetadata in TsFileIOWriter ahead
of time to save memory (#7276)
add bbd0ee0b8f [IOTDB-4469]add data size while loading enire chunk (#7389)
add 31b1ea198a [IOTDB-4477] Support datatype cast while inserting with
schema mismatch (#7378)
add 4eced0661c [IOTDB-4480]fix file name incorrect in compaction test
add 1363abf0a7 [IOTDB-4420] Monitor DataNode's remain disk space through
cluster heartbeat (#7361)
add b0dac5ec59 [IOTDB-4399] Control text chunk size in memtable (#7320)
add 08829f5b9c [IOTDB-4449][IOTDB-4450] Optimize SchemaFetch (#7395)
add 22149b0f99 [IOTDB-4477] fix castDataType error (#7398)
add 5cc478c8e6 [IOTDB-4392] build separate cache queue for MultiLeader log
sync
add f0ecd841aa add a section of delete data (#7311)
add 634a128f94 rename methods (#7396)
new 0c0a1b85ac merge with master
The 1 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:
.../resources/conf/iotdb-confignode.properties | 18 +-
.../confignode/client/DataNodeRequestType.java | 46 +-
.../async/handlers/ConfigNodeHeartbeatHandler.java | 4 +-
.../async/handlers/DataNodeHeartbeatHandler.java | 8 +-
.../sync/datanode/SyncDataNodeClientPool.java | 2 +
.../confignode/manager/ClusterSchemaManager.java | 2 +
.../iotdb/confignode/manager/ConfigManager.java | 8 +-
.../iotdb/confignode/manager/ConsensusManager.java | 1 +
.../apache/iotdb/confignode/manager/IManager.java | 2 +
.../iotdb/confignode/manager/ProcedureManager.java | 1 +
.../iotdb/confignode/manager/load/LoadManager.java | 6 +-
.../manager/load/LoadManagerMetrics.java | 4 +-
.../manager/load/balancer/RegionBalancer.java | 4 +-
.../manager/load/balancer/RouteBalancer.java | 4 +-
.../partition/GreedyPartitionAllocator.java | 2 +-
.../{load/heartbeat => node}/BaseNodeCache.java | 28 +-
.../ConfigNodeHeartbeatCache.java | 9 +-
.../heartbeat => node}/DataNodeHeartbeatCache.java | 28 +-
.../heartbeat => node}/NodeHeartbeatSample.java | 37 +-
.../confignode/manager/{ => node}/NodeManager.java | 57 +-
.../manager/{ => partition}/PartitionManager.java | 7 +-
.../{load/heartbeat => partition}/RegionCache.java | 6 +-
.../heartbeat => partition}/RegionGroupCache.java | 2 +-
.../RegionHeartbeatSample.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 9 +-
.../procedure/env/DataNodeRemoveHandler.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 3 +-
.../hash/DeviceGroupHashExecutorManualTest.java | 2 +-
.../load/balancer/router/LeaderRouterTest.java | 10 +-
.../balancer/router/LoadScoreGreedyRouterTest.java | 6 +-
.../request/BatchIndexedConsensusRequest.java | 8 +-
.../multileader/logdispatcher/LogDispatcher.java | 5 +-
.../service/MultiLeaderRPCServiceProcessor.java | 3 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 13 +-
docs/UserGuide/Data-Concept/Time-zone.md | 2 +-
.../Delete-Data.md | 0
.../{Operate-Metadata => Delete-Data}/TTL.md | 0
.../Maintenance-Tools/Maintenance-Command.md | 44 +-
.../CSV-Tool.md | 0
.../Load-External-Tsfile.md | 0
.../TsFile-Tool.md | 0
.../Write-Data.md | 0
docs/zh/UserGuide/Data-Concept/Time-zone.md | 2 +-
.../Delete-Data.md | 0
.../{Operate-Metadata => Delete-Data}/TTL.md | 0
.../Maintenance-Tools/Maintenance-Command.md | 70 +-
.../CSV-Tool.md | 0
.../Load-External-Tsfile.md | 0
.../TsFile-Tool.md | 0
.../Write-Data.md | 0
.../iotdb/influxdb/session/InfluxDBSession.java | 12 +-
integration-test/checkstyle.xml | 2 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 14 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 6 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 10 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 8 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 65 +
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 48 +
.../iotdb/session/IoTDBSessionComplexIT.java | 407 +++++++
.../session/IoTDBSessionDisableMemControlIT.java | 220 ++++
.../java/org/apache/iotdb/session/SessionTest.java | 180 +++
.../apache/iotdb/session/pool/SessionPoolTest.java | 16 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 49 +-
.../iotdb/commons/conf/CommonDescriptor.java | 11 +
.../resources/conf/iotdb-datanode.properties | 13 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 32 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 17 +
.../statemachine/DataRegionStateMachine.java | 161 +--
.../rewrite/task/ReadPointPerformerSubTask.java | 10 +-
.../utils/AlignedSeriesCompactionExecutor.java | 1 +
.../inner/utils/MultiTsFileDeviceIterator.java | 4 +-
.../utils/SingleSeriesCompactionExecutor.java | 1 +
.../compaction/performer/ICompactionPerformer.java | 4 +-
.../impl/ReadChunkCompactionPerformer.java | 15 +-
.../impl/ReadPointCompactionPerformer.java | 92 +-
.../writer/AbstractCompactionWriter.java | 12 +-
.../writer/CrossSpaceCompactionWriter.java | 35 +-
.../writer/InnerSpaceCompactionWriter.java | 30 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 23 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 43 +-
.../engine/memtable/AlignedWritableMemChunk.java | 23 +-
.../memtable/AlignedWritableMemChunkGroup.java | 10 +-
.../db/engine/memtable/IWritableMemChunk.java | 16 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 5 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 29 +-
.../db/engine/memtable/WritableMemChunkGroup.java | 26 +-
.../db/engine/storagegroup/TsFileProcessor.java | 9 +-
.../db/engine/storagegroup/TsFileResource.java | 8 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 4 +-
.../plan/node/load/LoadSingleTsFileNode.java | 5 +-
.../plan/node/write/InsertMultiTabletsNode.java | 5 +
.../plan/planner/plan/node/write/InsertNode.java | 5 +
.../planner/plan/node/write/InsertRowNode.java | 17 +
.../planner/plan/node/write/InsertRowsNode.java | 5 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 5 +
.../planner/plan/node/write/InsertTabletNode.java | 23 +
.../db/query/control/SessionTimeoutManager.java | 12 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +
.../impl/DataNodeInternalRPCServiceImpl.java | 55 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 4 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 79 ++
.../db/utils/datastructure/AlignedTVList.java | 54 +
.../iotdb/db/utils/datastructure/BinaryTVList.java | 46 +
.../iotdb/db/utils/datastructure/TVList.java | 7 +
.../file/AbstractTsFileRecoverPerformer.java | 18 +-
.../ReadPointCompactionPerformerTest.java | 70 +-
.../cross/RewriteCompactionFileSelectorTest.java | 30 +-
.../compaction/inner/InnerSeqCompactionTest.java | 7 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 13 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 3 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 10 +-
.../db/utils/datastructure/BinaryTVListTest.java | 30 +
.../db/utils/datastructure/VectorTVListTest.java | 67 ++
.../java/org/apache/iotdb/session/ISession.java | 4 +-
.../java/org/apache/iotdb/session/Session.java | 136 +--
.../session/{Config.java => SessionConfig.java} | 2 +-
.../apache/iotdb/session/SessionConnection.java | 2 +-
.../org/apache/iotdb/session/SessionDataSet.java | 4 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 62 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 12 +-
site/src/main/.vuepress/config.js | 36 +-
.../src/main/thrift/confignode.thrift | 2 +
.../src/main/thrift/mutlileader.thrift | 6 +-
thrift/src/main/thrift/datanode.thrift | 15 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 8 +
.../file/metadata/MetadataIndexConstructor.java | 9 +-
.../tsfile/file/metadata/MetadataIndexNode.java | 2 +-
.../iotdb/tsfile/file/metadata/TsFileMetadata.java | 9 +-
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 4 +-
.../write/writer/RestorableTsFileIOWriter.java | 12 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 337 ++++--
.../write/writer/tsmiterator/DiskTSMIterator.java | 132 ++
.../write/writer/tsmiterator/TSMIterator.java | 147 +++
.../tsfile/write/TsFileIntegrityCheckingTool.java | 251 ++++
.../writer/TsFileIOWriterMemoryControlTest.java | 1261 ++++++++++++++++++++
136 files changed, 4418 insertions(+), 749 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{load/heartbeat =>
node}/BaseNodeCache.java (76%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{load/heartbeat =>
node}/ConfigNodeHeartbeatCache.java (91%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{load/heartbeat =>
node}/DataNodeHeartbeatCache.java (81%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{load/heartbeat =>
node}/NodeHeartbeatSample.java (67%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ =>
node}/NodeManager.java (92%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ =>
partition}/PartitionManager.java (99%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{load/heartbeat =>
partition}/RegionCache.java (91%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{load/heartbeat =>
partition}/RegionGroupCache.java (98%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{load/heartbeat =>
partition}/RegionHeartbeatSample.java (96%)
rename docs/UserGuide/{Write-And-Delete-Data => Delete-Data}/Delete-Data.md
(100%)
rename docs/UserGuide/{Operate-Metadata => Delete-Data}/TTL.md (100%)
rename docs/UserGuide/{Write-And-Delete-Data => Write-Data}/CSV-Tool.md (100%)
rename docs/UserGuide/{Write-And-Delete-Data =>
Write-Data}/Load-External-Tsfile.md (100%)
rename docs/UserGuide/{Write-And-Delete-Data => Write-Data}/TsFile-Tool.md
(100%)
rename docs/UserGuide/{Write-And-Delete-Data => Write-Data}/Write-Data.md
(100%)
rename docs/zh/UserGuide/{Write-And-Delete-Data => Delete-Data}/Delete-Data.md
(100%)
rename docs/zh/UserGuide/{Operate-Metadata => Delete-Data}/TTL.md (100%)
rename docs/zh/UserGuide/{Write-And-Delete-Data => Write-Data}/CSV-Tool.md
(100%)
rename docs/zh/UserGuide/{Write-And-Delete-Data =>
Write-Data}/Load-External-Tsfile.md (100%)
rename docs/zh/UserGuide/{Write-And-Delete-Data => Write-Data}/TsFile-Tool.md
(100%)
rename docs/zh/UserGuide/{Write-And-Delete-Data => Write-Data}/Write-Data.md
(100%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/IoTDBSessionComplexIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/IoTDBSessionDisableMemControlIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/SessionTest.java
rename session/src/main/java/org/apache/iotdb/session/{Config.java =>
SessionConfig.java} (98%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/tsmiterator/DiskTSMIterator.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/tsmiterator/TSMIterator.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileIntegrityCheckingTool.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriterMemoryControlTest.java
