This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch multitimeseries
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d282f23363 add more test and fix code smalls
add 7a8c3a6524 [IOTDB-3169] Add Library-UDF to IOTDB Distribution (#5874)
add a0e2aed850 [IOTDB-3179] Printing logs when get/getOrCreate Partition
in ConfigNode
add 6a34de5006 [IOTDB-3054] Cluster heartbeat framework (#5873)
add 2145522213 [IOTDB-3114] NodeInfo snapshot interface (#5887)
add 984dfd9058 [IOTDB-3117][snapshot] add authInfo snapshot. (#5843)
add 2d43fd913f [IOTDB-3045] Deleted timeseries are created again after
restart (#5897)
add 13c732b43a Scripts of stop and remove datanode (#5894)
add d93a848fd7 Fix config node compile error (#5905)
add 409d4a16fb Merge branch 'master' of https://github.com/apache/iotdb
into multitimeseries
No new revisions were added by this update.
Summary of changes:
.../resources/conf/iotdb-confignode.properties | 18 ++
.../confignode/client/AsyncDataNodeClientPool.java | 17 ++
.../client/SyncConfigNodeClientPool.java | 2 +-
.../client/handlers/HeartbeatHandler.java | 31 ++--
.../iotdb/confignode/conf/ConfigNodeConf.java | 24 ++-
.../confignode/conf/ConfigNodeDescriptor.java | 10 +
.../confignode/conf/ConfigNodeStartupCheck.java | 2 +-
.../request/write/ApplyConfigNodeReq.java | 2 +-
.../response/DataNodeConfigurationResp.java | 2 +-
.../consensus/response/DataPartitionResp.java | 4 +
.../consensus/response/SchemaPartitionResp.java | 4 +
.../iotdb/confignode/manager/ConfigManager.java | 53 +++++-
.../iotdb/confignode/manager/ConsensusManager.java | 4 +-
.../apache/iotdb/confignode/manager/Manager.java | 1 +
.../iotdb/confignode/manager/PartitionManager.java | 1 +
.../confignode/manager/{ => load}/LoadManager.java | 55 +++++-
.../allocator/CopySetRegionAllocator.java | 2 +-
.../{ => load}/allocator/IRegionAllocator.java | 2 +-
.../{ => load}/balancer/RegionBalancer.java | 2 +-
.../balancer/SeriesPartitionSlotBalancer.java | 2 +-
.../manager/load/heartbeat/HeartbeatCache.java | 40 ++--
.../manager/load/heartbeat/HeartbeatPackage.java | 23 ++-
.../manager/load/heartbeat/HeartbeatWindow.java | 51 ++++++
.../load/heartbeat/IHeartbeatStatistic.java | 22 ++-
.../iotdb/confignode/persistence/AuthorInfo.java | 35 +++-
.../confignode/persistence/ClusterSchemaInfo.java | 1 +
.../iotdb/confignode/persistence/NodeInfo.java | 140 +++++++++++++-
.../confignode/persistence/PartitionInfo.java | 1 +
.../executor/ConfigRequestExecutor.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 2 +-
.../consensus/request/ConfigRequestSerDeTest.java | 2 +-
.../confignode/persistence/AuthorInfoTest.java | 47 +++++
.../iotdb/confignode/persistence/NodeInfoTest.java | 102 +++++++++++
distribution/pom.xml | 8 +
.../{grafana-connector.xml => library-udf.xml} | 21 ++-
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 2 +-
.../iotdb/db/integration/IoTDBRestartIT.java | 29 ++-
library-udf/src/assembly/tools/register-UDF.bat | 102 +++++++++++
library-udf/src/assembly/tools/register-UDF.sh | 104 +++++++++++
.../commons/auth/authorizer/BasicAuthorizer.java | 16 ++
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 4 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 6 +-
.../iotdb/commons/auth/role/IRoleAccessor.java | 3 +-
.../iotdb/commons/auth/role/IRoleManager.java | 3 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 45 +++++
.../commons/auth/role/LocalFileRoleManager.java | 15 ++
.../iotdb/commons/auth/user/BasicUserManager.java | 6 +-
.../iotdb/commons/auth/user/IUserAccessor.java | 3 +-
.../iotdb/commons/auth/user/IUserManager.java | 3 +-
.../commons/auth/user/LocalFileUserAccessor.java | 48 ++++-
.../commons/auth/user/LocalFileUserManager.java | 15 ++
.../iotdb/commons/snapshot}/SnapshotProcessor.java | 2 +-
.../org/apache/iotdb/commons}/utils/FileUtils.java | 56 +++++-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 2 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 2 +-
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 2 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 2 +-
.../assembly/resources/sbin/remove-datanode.bat | 7 +-
.../src/assembly/resources/sbin/remove-datanode.sh | 10 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 20 +-
.../apache/iotdb/db/auth/AuthorizerManager.java | 201 ++++++++++++++++++---
.../apache/iotdb/db/client/ConfigNodeClient.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 14 ++
.../iotdb/db/service/metrics/MetricsService.java | 2 +-
.../service/thrift/impl/InternalServiceImpl.java | 8 +
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 2 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 2 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 2 +-
.../db/engine/compaction/TsFileIdentifierUT.java | 2 +-
thrift-commons/src/main/thrift/common.thrift | 13 ++
.../src/main/thrift/confignode.thrift | 13 +-
thrift/src/main/thrift/mpp.thrift | 6 +
74 files changed, 1321 insertions(+), 195 deletions(-)
copy cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogCallback.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/HeartbeatHandler.java
(52%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ =>
load}/LoadManager.java (81%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ =>
load}/allocator/CopySetRegionAllocator.java (98%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ =>
load}/allocator/IRegionAllocator.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ =>
load}/balancer/RegionBalancer.java (93%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ =>
load}/balancer/SeriesPartitionSlotBalancer.java (93%)
copy
server/src/main/java/org/apache/iotdb/db/engine/memtable/PrimitiveMemTable.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/HeartbeatCache.java
(54%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/HeartbeatPackage.java
(64%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/HeartbeatWindow.java
copy server/src/main/java/org/apache/iotdb/db/rescon/package-info.java =>
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/IHeartbeatStatistic.java
(62%)
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/persistence/NodeInfoTest.java
copy distribution/src/assembly/{grafana-connector.xml => library-udf.xml} (72%)
create mode 100644 library-udf/src/assembly/tools/register-UDF.bat
create mode 100644 library-udf/src/assembly/tools/register-UDF.sh
rename {confignode/src/main/java/org/apache/iotdb/confignode/persistence =>
node-commons/src/main/java/org/apache/iotdb/commons/snapshot}/SnapshotProcessor.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/utils/FileUtils.java (54%)
copy cluster/src/assembly/resources/sbin/remove-node.bat =>
server/src/assembly/resources/sbin/remove-datanode.bat (93%)
mode change 100755 => 100644
copy cluster/src/assembly/resources/sbin/remove-node.sh =>
server/src/assembly/resources/sbin/remove-datanode.sh (92%)
mode change 100755 => 100644
