You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by su...@apache.org on 2022/06/10 03:36:02 UTC
[iotdb] branch tsfile_v4 updated (1eedea8b28 -> 4e35c5c6df)
This is an automated email from the ASF dual-hosted git repository.
sunzesong pushed a change to branch tsfile_v4
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1eedea8b28 Fix format violations
add c01b1e1504 [IOTDB-3335] Redundant data recovered by wal in multi-leader consensus (#6076)
add 7fcb1044e7 [IOTDB-3306] Use rpc port check to avoid starting same IoTDB twice (#6069)
add 88adfbea69 [IOTDB-3229] Field is 0 rather than null when query two series in one device (#6071)
add b343478a41 [IOTDB-3339] Fix index out of bound while doing raw query (#6079)
add 48256e44f3 [IOTDB-3341] Fix timeseries id is not right while doing last query (#6082)
add 3918bf6992 [IOTDB-3346] Clear DriverTask when any RuntimeException is thrown (#6086)
add d26fa83c5d Make DataNode start DataNodeTSIServiceImpl RPC service (#6090)
add d9d2465f0d [IOTDB-3343] Aggregate existing and non-exsit timeseries together failure in AlignByDevice (#6084)
add f0fd1f5b40 [IOTDB-3165] Implement delete data (#6072)
add 1a18def1fc [IOTDB-3065]show lastest timeseries (#6063)
add ecbea664df optimize. (#6073)
add b940a652dd [IOTDB-3316] Add 'SHOW CLUSTER' implementation for IoTDB cluster mode (#6062)
add 9d420fd0f9 [IOTDB-3229] Apache IoTDB UDF Management in MPP Cluster: SHOW FUNCTIONS (#6098)
add 0b98a8cd5c [IOTDB-3358] Fix error message of insert wrong type of data by sql is meaningless (#6099)
add 96f4504e76 [IOTDB-3337] return error which insert wrong type of data (#6089)
add 9103a21b7b [IoTDB-2661]Query plan visualization (#6093)
add b47f7f0394 [IOTDB-3348] Miss some data while using or value filter (#6095)
add 45e46bf105 [IOTDB-3350] Recover wal search index when recovering from multi-leader (#6094)
add b514353fb2 [IOTDB-3251] Add ForwardTrigger doc and change api package (#6080)
add cb5f30916b Bump progressbar from 0.9.2 to 0.9.3 (#6106)
add 42609b36a4 [IOTDB-3178] Refactor integration test for the new cluster (#5901)
add d99d80772c jdbc getSchema error (#6115)
add 20804df90e [IOTDB-3334] Fix mismatched data columns and headers bug in AlignByDevice query (#6104)
add 611861c1b7 [IOTDB-3178] Emergency Bug Fix For IT framework (#6121)
add b95b7040c4 [IOTDB-3355] Adapt metric framework for config node and check metrics (#6096)
add 69b429b8d7 [IOTDB-3333] Distribution planning for SlidingWindowAggregationNode (#6103)
add aa175c2053 [IOTDB-3357] Throw an exception when using the select-into statement (#6117)
add 49b829998d [IOTDB-3342] Fix wrong parsing result for the full path in the where clause (#6118)
add 5ded7e581e [IOTDB-3356] The next() of child can only be invoked once in AggregationOperator and SlidingWindowAggregationOperator (#6097)
add fb160be99e fix IoTDBDatabaseMetadata type error. (#6125)
add 7a34696b3b revert timeseries version (#6124)
add aad6796deb [IOTDB-3364] Fix Query stucked with null valued aligned timeseries bug (#6120)
add 7fe40937a2 [IOTDB-3340] Fix NPE caused by deserialization of FunctionExpression (#6128)
add d4ccd578da [IOTDB-2931] Remove access to metadata manager during compaction (#5572)
add ab1451514b [IOTDB-3369] Fix some problems of metric module in confignode. (#6132)
add 92efe44edc [IOTDB-3289][IOTDB-3291][IOTDB-3217] Limit the number of regions (#6087)
add 37ecc6e166 [IOTDB-3195] Added a configuration interface for the consensus layer (#6081)
add 044d12ca63 Adapt wal memtabe snapshot to new cluster (#6138)
add 964f3218b5 fix: Fix `SessionDataSet` not close automatically (#6134)
add eff66ef3a3 [IOTDB-3327] Fix data region is created twice (#6136)
add e66320a169 [IOTDB-2988] Cache leader in session (#6083)
add 117f4d4060 fix: Fix `FileOutputStream` not close automatically (#6135)
add 93dae13b47 [IOTDB-3351] Add python Client schema template functions: create template function and drop template function (#6092)
add 18ce8537b7 Added a new document “How to Contribute Code” with chinese and english (#6141)
add 6fab5c3597 Fix some issues in MPP query prepared for representation (#6130)
add 23efe9791a fix aggregation bug (#6146)
add c77c70b249 [IOTDB-3375] Fix NPE when inserting multi-rows by SQL (#6148)
add 5527c66f67 Fix duplicated InputExpression in GroupByLevelNode (#6143)
add 464cbfe44d [IOTDB-3366] fix npe when no data when show latest timeseries. (#6126)
add cb6b1d542f [IOTDB-2978][compaction error log ] Log level and "null" error message handling (#6140)
add d3b4564e89 [IOTDB-3377] Enhance IT files code style checking (#6149)
add 38e730e4cf [IOTDB-3378] Fix iotdb reporter in metric framework and update rpc address and port when use cluster mode. (#6150)
add 3c3d6bd4c3 [ISSUE-5878] Fix FileOutputStream not close automatically
add 45ca963708 [IOTDB-3379] Add deserialize method for DeviceMergeNode in PlanNodeType (#6151)
add 18f185c261 change default settings (#6153)
add 1512a93845 [IOTDB-2880] Fix procedure worker threads config doesn't take effect, and remove id lock. (#6129)
add 83ef38a2eb [IOTDB-2919] Delete regions at once besides schedule in 300s interval (#6157)
add 565b14dbb1 [IOTDB-3383] Refactor calcInputLocationList() in LocalExecutionPlanner (#6152)
add 7f1b0a74de [IOTDB-3374] NPE when AggregationOperator receive the null tsblock from the child (#6144)
add 071cde31ad [IOTDB-3261][IOTDB-3332][IOTDB-3372] Ensure the concurrency security of Region alloction (#6156)
add c2afca12d5 [IOTDB-3317] RatisConsensus fallback for StateMachine RuntimeException (#6101)
add 3b59ee22a0 [IOTDB-3395] Use thrift server to fix clientManagerTest "bind address already used" issue (#6163)
add 7565b7987a [IOTDB-3393] Optimize log in auth module and fix the init of parameter in resp. (#6161)
add a9ee691ecc [IOTDB-3363][IOTDB-3252] Update thrift fileds about Authorization (#6165)
add 67cdb1737e Add an error message for setting TTL when the storagegroup does not exist (#6164)
add 5cd0a21f94 [IOTDB-3402] Fix abuse of ScheduledExecutorService.scheduleWithFixedDelay (#6172)
add d5b5aad3a2 Update ConfigNode startup process (#6168)
add a3f0606f3c [IOTDB-3403]JDBC storesUpperCaseIdentifiers interface should return false (#6173)
add 85d27c3e20 [IOTDB-3259] fix sg already exists check. (#6162)
add feddaa31b9 [IOTDB-3041] Add code example of using jdbc/session interface after updating syntax convention (#6145)
add 2fbfa556d0 Fix SchemaTree SearchDeviceSchema NPE (#6176)
add 7cb2d3f6cf [IOTDB-3168] Fix the path with * could be executed successfully when inserting in version 14. (#6158)
add 61e9a0e4db [IOTDB-3406] Correct the exclude part of xml format plugin (#6177)
add 8a8e727a20 [IOTDB-3370] Fix count nodes number (#6178)
add fbeddb9a77 Fix the issue that LastQuery lack MergeNode in some FI (#6186)
add 6c10edff06 [IOTDB-3417] Group by month unit bug in MPP (#6185)
add 922ee7b162 [IOTDB-3361] Exception if measurement is not exist in where clause in align by device
add dc08d01081 [IOTDB-3422] Fix metric tag in compaction task (#6191)
add 34c8b6f64a [IOTDB-3001] Read and write process for new standalone iotdb (#6159)
add d190615638 [IOTDB-3407] Checkstyle: force to use safe thread schedule interface (#6182)
add 4e9a5c2e91 [IOTDB-3359] Refactor the serialization interface for the consensus layer to avoid hard-coding size ByteBuffers (#6187)
add 9855b3688e [IOTDB-3432] Add IT for raw query (#6188)
add 08006e2ae0 [IOTDB-3360] Fix precision loss bug due to float converted to double (#6192)
add 0868dfa889 Add thread name for log (#6202)
add 4fde65e41e [IOTDB-3394] Add cache metrics (#6201)
add 5d48b1ecd8 [IOTDB-3425] [IOTDB-3415] add permission operate to LocalConfigNode && Abstract an interface for Standalone Authority Check (#6196)
add b0af35219e [IOTDB-3144] refactor sync recovery (#5985)
add e04af828e7 [IOTDB-3385] Reduce the serialization size for the Datanode consensus layer (#6209)
add 376632713c Fix insert OOM && Optimize new standalone auto create schema (#6204)
add ce5c5746cc [IOTDB-3423] Update default config of confignode. (#6194)
add 27eeae4e01 Make New Cluter CI stable (#6212)
add 4e35c5c6df Merge remote-tracking branch 'origin/master' into TsFile_v4_new
No new revisions were added by this update.
Summary of changes:
.github/workflows/{cluster.yml => cluster-it.yml} | 22 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 14 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
checkstyle.xml | 30 +-
client-py/README.md | 31 +
client-py/SessionExample.py | 49 +
client-py/iotdb/Session.py | 55 +
.../iotdb/template/InternalNode.py | 43 +-
client-py/iotdb/template/MeasurementNode.py | 56 +
client-py/iotdb/template/Template.py | 86 ++
.../iotdb/template/TemplateNode.py | 48 +-
client-py/iotdb/{ => template}/__init__.py | 0
.../iotdb/tsfile/common/constant/TsFileConstant.py | 21 +-
.../iotdb/{ => tsfile/common/constant}/__init__.py | 0
.../iotdb/tsfile/utils/Pair.py | 11 +-
client-py/iotdb/tsfile/utils/ReadWriteIOUtils.py | 77 +
client-py/iotdb/{ => tsfile/utils}/__init__.py | 0
client-py/tests/test_template.py | 74 +
.../java/org/apache/iotdb/cluster/ClientMain.java | 12 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 7 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 5 +-
.../serializable/SyncLogDequeSerializer.java | 4 +-
.../cluster/server/PullSnapshotHintService.java | 4 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 28 +-
confignode/pom.xml | 44 +-
confignode/src/assembly/confignode.xml | 4 +
.../resources/conf/iotdb-confignode.properties | 32 +-
confignode/src/assembly/resources/conf/logback.xml | 11 +
.../client/handlers/HeartbeatHandler.java | 19 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 30 +-
.../confignode/conf/ConfigNodeDescriptor.java | 15 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 44 +-
.../consensus/request/ConfigRequest.java | 33 +-
.../consensus/request/auth/AuthorReq.java | 24 +-
.../request/read/CountStorageGroupReq.java | 10 +-
.../consensus/request/read/GetDataNodeInfoReq.java | 8 +-
.../request/read/GetDataPartitionReq.java | 43 +-
.../request/read/GetNodePathsPartitionReq.java | 7 +-
.../request/read/GetSchemaPartitionReq.java | 26 +-
.../request/write/ApplyConfigNodeReq.java | 8 +-
.../request/write/CreateDataPartitionReq.java | 21 +-
.../consensus/request/write/CreateFunctionReq.java | 13 +-
.../consensus/request/write/CreateRegionsReq.java | 25 +-
.../request/write/CreateSchemaPartitionReq.java | 30 +-
.../request/write/DeleteProcedureReq.java | 7 +-
.../consensus/request/write/DeleteRegionsReq.java | 9 +-
.../request/write/DeleteStorageGroupReq.java | 8 +-
.../consensus/request/write/DropFunctionReq.java | 7 +-
.../request/write/PreDeleteStorageGroupReq.java | 9 +-
.../request/write/RegisterDataNodeReq.java | 8 +-
.../request/write/SetDataReplicationFactorReq.java | 9 +-
.../write/SetSchemaReplicationFactorReq.java | 9 +-
.../request/write/SetStorageGroupReq.java | 7 +-
.../consensus/request/write/SetTTLReq.java | 9 +-
.../request/write/SetTimePartitionIntervalReq.java | 9 +-
.../request/write/UpdateProcedureReq.java | 7 +-
.../statemachine/PartitionRegionStateMachine.java | 4 +-
.../confignode/exception/TimeoutException.java | 10 +-
.../confignode/manager/ClusterSchemaManager.java | 45 +-
.../iotdb/confignode/manager/ConfigManager.java | 13 +-
.../iotdb/confignode/manager/ConsensusManager.java | 8 +-
.../iotdb/confignode/manager/NodeManager.java | 18 +
.../iotdb/confignode/manager/PartitionManager.java | 132 +-
.../confignode/manager/PermissionManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../iotdb/confignode/manager/load/LoadManager.java | 58 +-
.../manager/load/balancer/RegionBalancer.java | 9 +-
.../balancer/allocator/CopySetRegionAllocator.java | 13 +-
.../load/balancer/allocator/IRegionAllocator.java | 4 +
.../iotdb/confignode/persistence/AuthorInfo.java | 29 +-
.../confignode/persistence/ClusterSchemaInfo.java | 140 +-
.../iotdb/confignode/persistence/NodeInfo.java | 24 +-
.../executor/ConfigRequestExecutor.java | 5 +-
.../procedure/CompletedProcedureRecycler.java | 3 -
.../confignode/procedure/InternalProcedure.java | 3 -
.../iotdb/confignode/procedure/Procedure.java | 47 +-
.../confignode/procedure/ProcedureExecutor.java | 12 -
.../procedure/StateMachineProcedure.java | 9 +-
.../impl/DeleteStorageGroupProcedure.java | 9 +-
.../confignode/procedure/store/ProcedureWAL.java | 12 +-
.../iotdb/confignode/service/ConfigNode.java | 5 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 38 +-
.../consensus/request/ConfigRequestSerDeTest.java | 181 +--
.../persistence/ClusterSchemaInfoTest.java | 14 +-
.../confignode/procedure/entity/IncProcedure.java | 8 +-
.../procedure/entity/SleepProcedure.java | 8 +-
.../procedure/entity/StuckSTMProcedure.java | 9 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 52 +-
.../resources/confignode1conf}/iotdb-metric.yml | 0
.../resources/confignode2conf}/iotdb-metric.yml | 34 +-
.../resources/confignode3conf}/iotdb-metric.yml | 34 +-
consensus/pom.xml | 67 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 11 +-
.../org/apache/iotdb/consensus/common/Peer.java | 7 +-
.../common/request/ByteBufferConsensusRequest.java | 4 +-
.../common/request/IConsensusRequest.java | 15 +-
.../common/request/IndexedConsensusRequest.java | 19 +-
.../iotdb/consensus/config/ConsensusConfig.java | 97 ++
.../iotdb/consensus/config/MultiLeaderConfig.java | 257 ++++
.../apache/iotdb/consensus/config/RatisConfig.java | 695 +++++++++
.../multileader/MultiLeaderConsensus.java | 17 +-
.../multileader/MultiLeaderServerImpl.java | 45 +-
.../multileader/client/DispatchLogHandler.java | 7 +-
.../client/MultiLeaderConsensusClientPool.java | 16 +-
.../conf/MultiLeaderConsensusConfig.java | 40 -
.../multileader/logdispatcher/LogDispatcher.java | 55 +-
.../multileader/logdispatcher/SyncStatus.java | 8 +-
.../multileader/service/MultiLeaderRPCService.java | 12 +-
.../service/MultiLeaderRPCServiceProcessor.java | 2 +-
.../multileader/wal/GetConsensusReqReaderPlan.java | 5 +-
.../ratis/ApplicationStateMachineProxy.java | 10 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 49 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 30 +-
.../iotdb/consensus/ratis/RequestMessage.java | 18 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 65 +
.../consensus/standalone/StandAloneConsensus.java | 7 +-
.../multileader/MultiLeaderConsensusTest.java | 25 +-
.../multileader/logdispatcher/SyncStatusTest.java | 79 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 7 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 11 +-
.../iotdb/consensus/standalone/RecoveryTest.java | 7 +-
.../standalone/StandAloneConsensusTest.java | 15 +-
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/confignode.xml | 4 +
docs/Development/HowtoContributeCode.md | 160 +++
docs/UserGuide/API/Programming-Java-Native-API.md | 8 +-
.../UserGuide/API/Programming-Python-Native-API.md | 31 +
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 6 +-
docs/UserGuide/Process-Data/Triggers.md | 108 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 2 +-
docs/zh/Development/HowtoContributeCode.md | 154 ++
.../UserGuide/API/Programming-Java-Native-API.md | 8 +-
.../UserGuide/API/Programming-Python-Native-API.md | 31 +
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 5 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 111 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 2 +-
.../iotdb/SyntaxConventionRelatedExample.java | 161 +++
.../iotdb/SyntaxConventionRelatedExample.java | 145 ++
.../java/org/apache/iotdb/flink/IoTDBSink.java | 1 +
integration-test/README.md | 124 ++
integration-test/checkstyle.xml | 42 +
.../import-control.xml | 42 +-
integration-test/pom.xml | 291 ++++
.../src/assembly/cluster-test.xml | 52 +-
.../iotdb/db/query/udf/example/Accumulator.java | 0
.../apache/iotdb/db/query/udf/example/Adder.java | 0
.../apache/iotdb/db/query/udf/example/Counter.java | 0
.../db/query/udf/example/ExampleUDFConstant.java | 0
.../org/apache/iotdb/db/query/udf/example/Max.java | 0
.../iotdb/db/query/udf/example/Multiplier.java | 0
.../SlidingSizeWindowConstructorTester0.java | 0
.../SlidingSizeWindowConstructorTester1.java | 0
.../SlidingTimeWindowConstructionTester.java | 0
.../db/query/udf/example/TerminateTester.java | 0
.../iotdb/db/query/udf/example/ValidateTester.java | 0
.../iotdb/db/query/udf/example/WindowStartEnd.java | 0
.../java/org/apache/iotdb/it/env/Cluster1Env.java | 20 +-
.../org/apache/iotdb/it/env/ClusterEnvBase.java | 225 +++
.../org/apache/iotdb/it/env/ClusterEnvConfig.java | 188 +++
.../org/apache/iotdb/it/env/ClusterNodeBase.java | 190 +++
.../org/apache/iotdb/it/env/ConfigFactory.java | 59 +
.../java/org/apache/iotdb/it/env/ConfigNode.java | 115 ++
.../java/org/apache/iotdb/it/env/DataNode.java | 119 ++
.../java/org/apache/iotdb/it/env/EnvFactory.java | 54 +
.../org/apache/iotdb/it/env/RemoteEnvConfig.java | 10 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 107 ++
.../apache/iotdb/itbase/category/ClusterIT.java | 10 +-
.../iotdb/itbase/category/LocalStandaloneIT.java | 10 +-
.../org/apache/iotdb/itbase/category/RemoteIT.java | 10 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 143 ++
.../org/apache/iotdb/itbase/env/BaseConfig.java | 140 ++
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 0
.../java/org/apache/iotdb/itbase/env/BaseNode.java | 24 +-
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 65 +
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 149 ++
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 58 +
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 58 +
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1472 ++++++++++++++++++++
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 60 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 150 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 93 ++
.../iotdb/db/it/env/StandaloneEnvConfig.java | 196 +++
.../src/test/resources/iotdb-engine.properties | 0
.../src/test/resources/logback-test.xml | 58 +
integration/checkstyle.xml | 232 +++
.../import-control.xml | 42 +-
.../db/engine/trigger/example/Accumulator.java | 0
.../iotdb/db/engine/trigger/example/Counter.java | 0
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 6 +
.../db/integration/aligned/IoTDBEmptyDataIT.java | 78 ++
.../db/integration/aligned/IoTDBLastQuery2IT.java | 65 -
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 68 -
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 381 -----
.../IoTDBRawQueryWithoutValueFilter2IT.java | 66 -
.../IoTDBRawQueryWithoutValueFilter3IT.java | 63 -
.../aligned/IoTDBRawQueryWithoutValueFilterIT.java | 633 ---------
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 59 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 27 +-
.../metrics/config/MetricConfigDescriptor.java | 15 +-
.../iotdb/metrics/config/MetricConstant.java | 2 +
.../apache/iotdb/metrics/utils/MetricsUtils.java | 16 +-
node-commons/pom.xml | 5 +
.../commons/client/ClientFactoryProperty.java | 2 +-
.../threadpool/ScheduledExecutorUtil.java | 106 ++
.../WrappedScheduledExecutorService.java | 2 +
.../WrappedSingleThreadScheduledExecutor.java | 2 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 7 +
.../iotdb/commons/partition/DataPartition.java | 5 +-
.../commons/partition/DataPartitionQueryParam.java | 16 +
.../apache/iotdb/commons/partition/Partition.java | 4 +
.../commons/partition/RegionReplicaSetInfo.java | 16 +-
.../iotdb/commons/partition/SchemaPartition.java | 5 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 17 +
.../org/apache/iotdb/commons/path/PathType.java | 10 +-
.../service/AbstractThriftServiceThread.java | 38 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 15 +
.../commons/utils/BasicStructureSerDeUtil.java | 86 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 34 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 10 +
.../iotdb/commons/IoTDBThreadPoolFactoryTest.java | 4 +-
.../commons/{ => client}/ClientManagerTest.java | 58 +-
.../client/mock/MockInternalRPCService.java | 45 +-
.../client/mock/MockInternalRPCServiceMBean.java | 9 +-
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 94 +-
pom.xml | 22 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 14 -
.../rocksdb/mnode/RMeasurementMNode.java | 10 -
server/pom.xml | 4 +
.../resources/conf/iotdb-engine.properties | 41 +-
server/src/assembly/resources/conf/logback.xml | 11 +
.../assembly/resources/sbin/start-new-server.bat | 126 ++
.../assembly/resources/sbin/start-new-server.sh | 88 ++
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 8 +-
.../org/apache/iotdb/db/auth/AuthorityFetcher.java | 182 ---
.../apache/iotdb/db/auth/AuthorizerManager.java | 212 +--
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 341 +++++
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 35 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 133 ++
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 40 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 +
.../db/consensus/DataRegionConsensusImpl.java | 27 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 10 +-
.../consensus/statemachine/BaseStateMachine.java | 18 +-
.../statemachine/DataRegionStateMachine.java | 14 +-
.../statemachine/SchemaRegionStateMachine.java | 4 +-
.../statemachine/visitor/DataExecutionVisitor.java | 19 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 27 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 122 +-
.../engine/compaction/CompactionTaskManager.java | 22 +-
.../rewrite/task/ReadPointPerformerSubTask.java | 26 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 4 +-
.../utils/AlignedSeriesCompactionExecutor.java | 32 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 3 +
.../utils/SingleSeriesCompactionExecutor.java | 44 +-
.../impl/ReadChunkCompactionPerformer.java | 18 +-
.../impl/ReadPointCompactionPerformer.java | 104 +-
.../compaction/task/AbstractCompactionTask.java | 2 +-
.../writer/AbstractCompactionWriter.java | 4 +-
.../iotdb/db/engine/cq/ContinuousQueryService.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 7 +-
.../querycontext/AlignedReadOnlyMemChunk.java | 13 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 122 +-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../db/engine/trigger/builtin/ForwardTrigger.java | 12 +-
.../http/HTTPForwardConfiguration.java | 2 +-
.../sink/{ => forward}/http/HTTPForwardEvent.java | 2 +-
.../{ => forward}/http/HTTPForwardHandler.java | 2 +-
.../mqtt/MQTTForwardConfiguration.java | 2 +-
.../sink/{ => forward}/mqtt/MQTTForwardEvent.java | 2 +-
.../{ => forward}/mqtt/MQTTForwardHandler.java | 2 +-
.../runtime/SerializationRunTimeException.java} | 9 +-
.../sql/MeasurementNotExistException.java | 12 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 483 ++++++-
.../localconfignode/LocalDataPartitionTable.java | 54 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 23 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 9 +-
.../idtable/entry/InsertMeasurementMNode.java | 10 -
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 4 -
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 12 -
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 24 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 1 +
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 2 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 25 +
.../iotdb/db/metadata/path/MeasurementPath.java | 44 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 6 -
.../db/metadata/schemaregion/SchemaEngine.java | 7 +
.../schemaregion/SchemaRegionMemoryImpl.java | 20 -
.../schemaregion/SchemaRegionSchemaFileImpl.java | 14 -
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 6 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 22 +
.../metadata/visitor/SchemaExecutionVisitor.java | 7 +-
.../TimeRangeIteratorFactory.java | 14 +-
.../iotdb/db/mpp/common/FragmentInstanceId.java | 14 +-
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 9 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 6 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 40 +
.../db/mpp/common/schematree/PathPatternNode.java | 13 +
.../db/mpp/common/schematree/PathPatternTree.java | 6 +
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 22 +-
.../common/schematree/node/SchemaInternalNode.java | 5 -
.../schematree/node/SchemaMeasurementNode.java | 12 +-
.../db/mpp/common/schematree/node/SchemaNode.java | 2 -
.../visitor/SchemaTreeMeasurementVisitor.java | 8 +-
.../execution/datatransfer/DataBlockManager.java | 265 ++--
.../db/mpp/execution/datatransfer/SinkHandle.java | 73 +-
.../mpp/execution/datatransfer/SourceHandle.java | 271 ++--
.../fragment/FragmentInstanceManager.java | 82 +-
.../operator/process/AggregationOperator.java | 24 +-
.../execution/operator/process/FilterOperator.java | 80 +-
.../operator/process/LastQueryMergeOperator.java | 7 +-
.../process/RawDataAggregationOperator.java | 28 +-
.../process/SlidingWindowAggregationOperator.java | 29 +-
.../operator/process/TransformOperator.java | 70 +-
.../operator/process/merge/SingleColumnMerger.java | 4 +-
.../schema/NodeManageMemoryMergeOperator.java | 7 +-
.../operator/schema/NodePathsConvertOperator.java | 5 +-
.../operator/schema/NodePathsCountOperator.java | 38 +-
.../operator/schema/SchemaQueryMergeOperator.java | 2 -
.../schema/SchemaQueryOrderByHeatOperator.java | 165 +++
.../source/SeriesAggregationScanOperator.java | 6 +-
.../execution/schedule/AbstractDriverThread.java | 8 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 115 +-
.../mpp/execution/schedule/DriverTaskThread.java | 69 +-
.../schedule/FragmentInstanceAbortedException.java | 1 +
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 48 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 222 +--
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 48 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 4 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 15 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 14 +-
.../mpp/plan/analyze/GroupByLevelController.java | 6 +-
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 3 +
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 22 +-
.../plan/analyze/StandalonePartitionFetcher.java | 150 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 233 +++-
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 10 +
.../DataNodeEndPoints.java} | 35 +-
.../db/mpp/plan/execution/IQueryExecution.java | 2 +
.../db/mpp/plan/execution/QueryExecution.java | 84 +-
...thorizerConfigTask.java => AuthorizerTask.java} | 42 +-
.../mpp/plan/execution/config/ConfigExecution.java | 5 +
.../plan/execution/config/ConfigTaskVisitor.java | 16 +-
.../plan/execution/config/SetStorageGroupTask.java | 12 +-
.../mpp/plan/execution/config/ShowClusterTask.java | 122 ++
.../plan/execution/config/ShowFunctionsTask.java | 153 ++
.../memory/StatementMemorySourceVisitor.java | 39 +
.../iotdb/db/mpp/plan/expression/Expression.java | 14 +
.../plan/expression/binary/BinaryExpression.java | 7 +
.../mpp/plan/expression/leaf/ConstantOperand.java | 7 +
.../plan/expression/leaf/TimeSeriesOperand.java | 6 +
.../mpp/plan/expression/leaf/TimestampOperand.java | 6 +
.../plan/expression/multi/FunctionExpression.java | 21 +-
.../db/mpp/plan/expression/unary/InExpression.java | 12 +
.../mpp/plan/expression/unary/LikeExpression.java | 8 +
.../plan/expression/unary/RegularExpression.java | 8 +
.../mpp/plan/expression/unary/UnaryExpression.java | 6 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 123 +-
.../db/mpp/plan/parser/StatementGenerator.java | 15 +
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 71 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 217 ++-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 135 +-
.../distribution/DistributionPlanContext.java | 17 +
.../planner/distribution/ExchangeNodeAdder.java | 55 +-
.../plan/planner/distribution/SourceRewriter.java | 292 ++--
.../db/mpp/plan/planner/plan/FragmentInstance.java | 57 +-
.../db/mpp/plan/planner/plan/PlanFragment.java | 13 +
.../plan/planner/plan/node/DeleteRegionNode.java | 8 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 168 ++-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 44 +-
.../db/mpp/plan/planner/plan/node/PlanNodeId.java | 8 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 16 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../node/metedata/read/CountSchemaMergeNode.java | 7 +
.../plan/node/metedata/read/DevicesCountNode.java | 9 +
.../node/metedata/read/DevicesSchemaScanNode.java | 12 +
.../metedata/read/LevelTimeSeriesCountNode.java | 10 +
.../read/NodeManagementMemoryMergeNode.java | 12 +
.../node/metedata/read/NodePathsConvertNode.java | 7 +
.../node/metedata/read/NodePathsCountNode.java | 7 +
.../metedata/read/NodePathsSchemaScanNode.java | 9 +
.../node/metedata/read/SchemaFetchMergeNode.java | 7 +
.../node/metedata/read/SchemaFetchScanNode.java | 9 +
.../node/metedata/read/SchemaQueryMergeNode.java | 11 +
...ntNode.java => SchemaQueryOrderByHeatNode.java} | 53 +-
.../node/metedata/read/TimeSeriesCountNode.java | 9 +
.../metedata/read/TimeSeriesSchemaScanNode.java | 22 +
.../node/metedata/write/AlterTimeSeriesNode.java | 51 +-
.../write/CreateAlignedTimeSeriesNode.java | 86 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 25 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 75 +-
.../node/metedata/write/DeleteTimeSeriesNode.java | 11 +
.../metedata/write/InvalidateSchemaCacheNode.java | 16 +
.../plan/node/metedata/write/MeasurementGroup.java | 82 +-
.../planner/plan/node/process/AggregationNode.java | 18 +
.../planner/plan/node/process/DeviceMergeNode.java | 13 +
.../planner/plan/node/process/DeviceViewNode.java | 25 +
.../planner/plan/node/process/ExchangeNode.java | 15 +
.../plan/planner/plan/node/process/FillNode.java | 8 +
.../plan/planner/plan/node/process/FilterNode.java | 14 +
.../planner/plan/node/process/FilterNullNode.java | 8 +
.../plan/node/process/GroupByLevelNode.java | 18 +
.../plan/node/process/LastQueryMergeNode.java | 13 +
.../plan/planner/plan/node/process/LimitNode.java | 8 +
.../plan/planner/plan/node/process/OffsetNode.java | 8 +
.../planner/plan/node/process/ProjectNode.java | 11 +
.../node/process/SlidingWindowAggregationNode.java | 28 +-
.../plan/planner/plan/node/process/SortNode.java | 8 +
.../planner/plan/node/process/TimeJoinNode.java | 8 +
.../planner/plan/node/process/TransformNode.java | 13 +
.../planner/plan/node/sink/FragmentSinkNode.java | 11 +
.../plan/node/source/AlignedLastQueryScanNode.java | 8 +
.../source/AlignedSeriesAggregationScanNode.java | 25 +
.../plan/node/source/AlignedSeriesScanNode.java | 23 +
.../plan/node/source/LastQueryScanNode.java | 8 +
.../node/source/SeriesAggregationScanNode.java | 25 +
.../planner/plan/node/source/SeriesScanNode.java | 23 +
.../planner/plan/node/write/DeleteDataNode.java | 121 +-
.../plan/node/write/InsertMultiTabletsNode.java | 21 +-
.../plan/planner/plan/node/write/InsertNode.java | 20 +-
.../planner/plan/node/write/InsertRowNode.java | 94 +-
.../planner/plan/node/write/InsertRowsNode.java | 23 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 53 +-
.../planner/plan/node/write/InsertTabletNode.java | 165 ++-
.../plan/parameter/AggregationDescriptor.java | 24 +-
.../planner/plan/parameter/AggregationStep.java | 7 +
.../planner/plan/parameter/FillDescriptor.java | 9 +
.../plan/parameter/FilterNullParameter.java | 10 +
.../plan/parameter/GroupByTimeParameter.java | 25 +-
.../scheduler/FixedRateFragInsStateTracker.java | 9 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 49 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 89 --
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 87 +-
.../db/mpp/plan/statement/StatementVisitor.java | 20 +
.../plan/statement/crud/DeleteDataStatement.java | 73 +
.../plan/statement/crud/InsertBaseStatement.java | 4 +
.../crud/InsertMultiTabletsStatement.java | 18 +
.../plan/statement/crud/InsertRowStatement.java | 12 +
.../crud/InsertRowsOfOneDeviceStatement.java | 9 +
.../plan/statement/crud/InsertRowsStatement.java | 17 +
.../plan/statement/crud/InsertTabletStatement.java | 14 +
.../mpp/plan/statement/literal/BooleanLiteral.java | 8 +
.../mpp/plan/statement/literal/DoubleLiteral.java | 8 +
.../db/mpp/plan/statement/literal/Literal.java | 4 +
.../db/mpp/plan/statement/literal/LongLiteral.java | 8 +
.../db/mpp/plan/statement/literal/NullLiteral.java | 7 +
.../mpp/plan/statement/literal/StringLiteral.java | 8 +
.../statement/metadata/ShowClusterStatement.java | 18 +-
.../metadata/ShowFunctionsStatement.java} | 26 +-
.../sys/ExplainStatement.java} | 38 +-
.../dag/transformer/binary/BinaryTransformer.java | 4 +-
.../transformer/binary/LogicBinaryTransformer.java | 85 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 7 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 13 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 2 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 2 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 2 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 14 +-
.../db/query/control/SessionTimeoutManager.java | 4 +-
.../query/reader/chunk/MemAlignedPageReader.java | 52 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 20 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 37 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 9 +-
.../iotdb/db/service/{IoTDB.java => NewIoTDB.java} | 87 +-
.../org/apache/iotdb/db/service/NewIoTDBMBean.java | 9 +-
.../db/service/basic/QueryFrequencyRecorder.java | 4 +-
.../iotdb/db/service/metrics/enums/Metric.java | 1 +
.../db/service/metrics/predefined/FileMetrics.java | 36 +-
.../metrics/recorder/CacheMetricsRecorder.java | 65 +
.../recorder/CompactionMetricsRecorder.java} | 18 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 79 +-
.../service/thrift/impl/InternalServiceImpl.java | 117 +-
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 4 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 12 +
.../iotdb/db/sync/sender/service/MsgManager.java | 2 +-
.../db/sync/sender/service/SenderService.java | 5 +
.../db/sync/sender/service/TransportHandler.java | 21 +-
.../db/sync/transport/client/ClientWrapper.java | 125 ++
.../db/sync/transport/client/ITransportClient.java | 2 +
.../db/sync/transport/client/TransportClient.java | 258 ++--
.../transport/server/TransportServiceImpl.java | 29 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 30 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 39 +-
.../allocation/AbstractNodeAllocationStrategy.java | 10 +
.../db/wal/allocation/FirstCreateStrategy.java | 6 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 8 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 8 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 40 +-
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 1 -
.../apache/iotdb/db/wal/io/CheckpointReader.java | 22 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 26 +-
.../db/wal/recover/CheckpointRecoverUtils.java | 32 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 65 +-
.../iotdb/db/wal/utils/CheckpointFileUtils.java | 3 +-
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 30 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 38 +-
.../compaction/CompactionTaskManagerTest.java | 21 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 2 +
.../ReadChunkCompactionPerformerNoAlignedTest.java | 1 -
.../db/engine/storagegroup/DataRegionTest.java | 12 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 24 +-
.../db/mpp/aggregation/TimeRangeIteratorTest.java | 22 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 35 +-
.../operator/AggregationOperatorTest.java | 3 +-
.../operator/RawDataAggregationOperatorTest.java | 12 +
.../SlidingWindowAggregationOperatorTest.java | 7 +-
.../schema/SchemaFetchScanOperatorTest.java | 9 +-
...erTest.java => DefaultDriverSchedulerTest.java} | 2 +-
.../execution/schedule/DriverSchedulerTest.java | 2 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 43 +
.../db/mpp/plan/StandaloneCoordinatorTest.java | 149 ++
.../plan/analyze/AggregationDescriptorTest.java | 41 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 8 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 6 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 14 +-
.../distribution/AggregationDistributionTest.java | 277 ++++
.../plan/distribution/DeleteTimeseriesTest.java | 71 -
.../plan/node/write/DeleteDataNodeSerdeTest.java | 21 +-
.../plan/scheduler/StandaloneSchedulerTest.java | 518 +++++++
.../iotdb/db/service/InternalServiceImplTest.java | 111 +-
.../db/wal/allocation/FirstCreateStrategyTest.java | 3 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 6 +-
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 12 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 14 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 2 +-
.../datanode1conf/iotdb-engine.properties | 2 +-
.../test/resources/datanode1conf/iotdb-metric.yml | 34 +-
.../datanode2conf/iotdb-engine.properties | 2 +-
.../test/resources/datanode2conf/iotdb-metric.yml | 34 +-
.../datanode3conf/iotdb-engine.properties | 2 +-
.../test/resources/datanode3conf/iotdb-metric.yml | 34 +-
.../java/org/apache/iotdb/session/Session.java | 43 +-
.../apache/iotdb/session/SessionConnection.java | 8 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 150 +-
site/src/main/.vuepress/config.js | 2 +
.../src/main/thrift/confignode.thrift | 26 +-
.../src/main/thrift/mutlileader.thrift | 8 +-
thrift/src/main/thrift/mpp.thrift | 23 +-
.../file/metadata/statistics/Statistics.java | 20 +-
.../file/metadata/statistics/TimeStatistics.java | 14 +
.../org/apache/iotdb/tsfile/read/common/Path.java | 15 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 3 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 4 +
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 43 +-
545 files changed, 17767 insertions(+), 6019 deletions(-)
rename .github/workflows/{cluster.yml => cluster-it.yml} (72%)
copy server/src/test/resources/datanode1conf/iotdb-engine.properties => client-py/iotdb/template/InternalNode.py (55%)
create mode 100644 client-py/iotdb/template/MeasurementNode.py
create mode 100644 client-py/iotdb/template/Template.py
copy server/src/test/resources/datanode3conf/iotdb-engine.properties => client-py/iotdb/template/TemplateNode.py (60%)
copy client-py/iotdb/{ => template}/__init__.py (100%)
copy server/src/test/resources/datanode1conf/iotdb-metric.yml => client-py/iotdb/tsfile/common/constant/TsFileConstant.py (67%)
copy client-py/iotdb/{ => tsfile/common/constant}/__init__.py (100%)
copy server/src/test/resources/datanode1conf/iotdb-metric.yml => client-py/iotdb/tsfile/utils/Pair.py (77%)
create mode 100644 client-py/iotdb/tsfile/utils/ReadWriteIOUtils.py
copy client-py/iotdb/{ => tsfile/utils}/__init__.py (100%)
create mode 100644 client-py/tests/test_template.py
copy server/src/main/java/org/apache/iotdb/db/metadata/utils/TimeseriesVersionUtil.java => confignode/src/main/java/org/apache/iotdb/confignode/exception/TimeoutException.java (81%)
copy {metrics/interface/src/main/assembly/resources/conf => confignode/src/test/resources/confignode1conf}/iotdb-metric.yml (100%)
copy {server/src/test/resources/datanode2conf => confignode/src/test/resources/confignode2conf}/iotdb-metric.yml (51%)
copy {server/src/test/resources/datanode2conf => confignode/src/test/resources/confignode3conf}/iotdb-metric.yml (51%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/config/ConsensusConfig.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/config/RatisConfig.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/conf/MultiLeaderConsensusConfig.java
create mode 100644 docs/Development/HowtoContributeCode.md
create mode 100644 docs/zh/Development/HowtoContributeCode.md
create mode 100644 example/jdbc/src/main/java/org/apache/iotdb/SyntaxConventionRelatedExample.java
create mode 100644 example/session/src/main/java/org/apache/iotdb/SyntaxConventionRelatedExample.java
create mode 100644 integration-test/README.md
create mode 100644 integration-test/checkstyle.xml
copy confignode/src/assembly/confignode.xml => integration-test/import-control.xml (52%)
create mode 100644 integration-test/pom.xml
copy distribution/src/assembly/all.xml => integration-test/src/assembly/cluster-test.xml (56%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/Accumulator.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/Adder.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/Counter.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/ExampleUDFConstant.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/Max.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/Multiplier.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester0.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester1.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/SlidingTimeWindowConstructionTester.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/TerminateTester.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/ValidateTester.java (100%)
copy {integration => integration-test}/src/main/java/org/apache/iotdb/db/query/udf/example/WindowStartEnd.java (100%)
copy consensus/src/main/java/org/apache/iotdb/consensus/multileader/wal/GetConsensusReqReaderPlan.java => integration-test/src/main/java/org/apache/iotdb/it/env/Cluster1Env.java (60%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/ClusterEnvBase.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/ClusterEnvConfig.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/ClusterNodeBase.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/ConfigFactory.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/ConfigNode.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/DataNode.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/EnvFactory.java
copy consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java => integration-test/src/main/java/org/apache/iotdb/it/env/RemoteEnvConfig.java (83%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
copy consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java => integration-test/src/main/java/org/apache/iotdb/itbase/category/ClusterIT.java (83%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java => integration-test/src/main/java/org/apache/iotdb/itbase/category/LocalStandaloneIT.java (83%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java => integration-test/src/main/java/org/apache/iotdb/itbase/category/RemoteIT.java (83%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/constant/TestConstant.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseConfig.java
copy {integration => integration-test}/src/main/java/org/apache/iotdb/itbase/env/BaseEnv.java (100%)
copy consensus/src/main/java/org/apache/iotdb/consensus/multileader/wal/GetConsensusReqReaderPlan.java => integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNode.java (72%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/AlignedWriteUtil.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery2IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery3IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCache2IT.java
rename integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryIT.java => integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheIT.java (61%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnv.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnvConfig.java
copy {integration => integration-test}/src/test/resources/iotdb-engine.properties (100%)
create mode 100644 integration-test/src/test/resources/logback-test.xml
create mode 100644 integration/checkstyle.xml
copy confignode/src/assembly/confignode.xml => integration/import-control.xml (52%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/engine/trigger/example/Accumulator.java (100%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/engine/trigger/example/Counter.java (100%)
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBEmptyDataIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQuery2IT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCache2IT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilter2IT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilter3IT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterIT.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/ScheduledExecutorUtil.java
rename node-commons/src/test/java/org/apache/iotdb/commons/{ => client}/ClientManagerTest.java (93%)
copy consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCService.java => node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCService.java (54%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java => node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCServiceMBean.java (83%)
create mode 100644 server/src/assembly/resources/sbin/start-new-server.bat
create mode 100644 server/src/assembly/resources/sbin/start-new-server.sh
delete mode 100644 server/src/main/java/org/apache/iotdb/db/auth/AuthorityFetcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java
copy node-commons/src/main/java/org/apache/iotdb/commons/partition/RegionReplicaSetInfo.java => server/src/main/java/org/apache/iotdb/db/auth/IAuthorityFetcher.java (52%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java
rename server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/{ => forward}/http/HTTPForwardConfiguration.java (96%)
copy server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/{ => forward}/http/HTTPForwardEvent.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/{ => forward}/http/HTTPForwardHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/{ => forward}/mqtt/MQTTForwardConfiguration.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/{ => forward}/mqtt/MQTTForwardEvent.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/{ => forward}/mqtt/MQTTForwardHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/{metadata/utils/TimeseriesVersionUtil.java => exception/runtime/SerializationRunTimeException.java} (78%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/config/MetricConstant.java => server/src/main/java/org/apache/iotdb/db/exception/sql/MeasurementNotExistException.java (79%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaQueryOrderByHeatOperator.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/{execution/IQueryExecution.java => constant/DataNodeEndPoints.java} (56%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{AuthorizerConfigTask.java => AuthorizerTask.java} (73%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowClusterTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowFunctionsTask.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{NodePathsCountNode.java => SchemaQueryOrderByHeatNode.java} (56%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/DeleteDataStatement.java
copy consensus/src/main/java/org/apache/iotdb/consensus/multileader/wal/GetConsensusReqReaderPlan.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowClusterStatement.java (60%)
rename server/src/main/java/org/apache/iotdb/db/{engine/trigger/sink/http/HTTPForwardEvent.java => mpp/plan/statement/metadata/ShowFunctionsStatement.java} (55%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/{analyze/ISchemaFetcher.java => statement/sys/ExplainStatement.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/service/{IoTDB.java => NewIoTDB.java} (79%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java => server/src/main/java/org/apache/iotdb/db/service/NewIoTDBMBean.java (80%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CacheMetricsRecorder.java
rename server/src/main/java/org/apache/iotdb/db/{engine/compaction/CompactionMetricsManager.java => service/metrics/recorder/CompactionMetricsRecorder.java} (93%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/client/ClientWrapper.java
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/{DefaultTaskSchedulerTest.java => DefaultDriverSchedulerTest.java} (99%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/StandaloneCoordinatorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/DeleteTimeseriesTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneSchedulerTest.java