This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch change_rpc_port
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from a21f05e add name predix for some threads in cluster module; add rpc
ip for Nodes
add 6a68db0 Fix the risk of deadlock by WeakReference (#1968)
add da02c71 [IOTDB-825] aggregation by natural month (#2029)
add a75b722 [IOTDB-868] change mlog from txt to bin (#1721)
add 8da5cdf change null pointer log way (#2266)
add 3812910 Move memtable plan index from ChunkGroupFooter to a separate
marker (#2263)
add 087a2a2 fix SDT chinese doc (#2269)
add a712b52 Add compaction test (#2220)
add fd68ec5 using sonar secret token
add f563161 fix fileNotException
add 8252ed8 revert fix fileNotException
add 12abbe9 fix file not found when restart and reader for txt mlog
(#2272)
add c7f6bea [IOTDB-1057] Remove Data type ALL in create time series
sentence (#2268)
add eef210c [IOTDB-1060] Support full deletion for delete statement
without where clause (#2276)
add 07a7689 Arrange query test (#2245)
add b85ddfc Fix Last query output when last value does not exist in a
series (#2275)
add 39e68b2 Fix hive-connector CI (#2279)
add 491c17f fix TsFile doc (#2282)
add f77b851 Add Unit tests for Utils module (#2246)
add e97d532 add auth test UT (#2271)
add 413fe1b Fix the path of seed_nodes configuration (#2206)
add 113bd38 add new committer HouliangQi (#2286)
new ce6cd51 Merge remote-tracking branch 'origin/master' into
change_rpc_port
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:
.github/workflows/sonar_and_coverall.yml | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 8 +-
.../cluster/partition/slot/SlotPartitionTable.java | 4 +-
docs/SystemDesign/SchemaManager/SchemaManager.md | 20 +-
docs/SystemDesign/TsFile/Format.md | 4 +-
.../DML Data Manipulation Language.md | 100 +-
docs/UserGuide/Operation Manual/SQL Reference.md | 7 +-
docs/UserGuide/Server/Cluster Setup.md | 2 +-
.../UserGuide/System Tools/MLogParser Tool.md | 17 +-
.../zh/SystemDesign/SchemaManager/SchemaManager.md | 20 +-
docs/zh/SystemDesign/StorageEngine/Compaction.md | 10 +-
docs/zh/SystemDesign/TsFile/Format.md | 4 +-
docs/zh/UserGuide/Concept/SDT.md | 22 +-
.../DML Data Manipulation Language.md | 103 +-
.../zh/UserGuide/Operation Manual/SQL Reference.md | 7 +-
docs/zh/UserGuide/Server/Cluster Setup.md | 2 +-
.../zh/UserGuide/System Tools/MLogParser Tool.md | 17 +-
hive-connector/pom.xml | 6 +-
server/file-changelists/mlog-changelist.md | 4 +
.../resources/conf/iotdb-engine.properties | 11 +-
.../mLogParser.bat} | 4 +-
.../print-tsfile-sketch.sh => mlog/mLogParser.sh} | 4 +-
.../org/apache/iotdb/db/auth/AuthException.java | 5 -
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 2 +-
.../db/auth/authorizer/LocalFileAuthorizer.java | 2 +-
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 10 +-
.../apache/iotdb/db/auth/entity/PathPrivilege.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 16 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 35 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 7 +-
.../level/LevelCompactionTsFileManagement.java | 152 +--
.../no/NoCompactionTsFileManagement.java | 10 +-
.../compaction/utils/CompactionLogAnalyzer.java | 19 +-
.../engine/compaction/utils/CompactionLogger.java | 16 +-
.../engine/compaction/utils/CompactionUtils.java | 84 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 1 +
.../db/engine/storagegroup/TsFileResource.java | 14 +-
.../{MLogWriter.java => MLogTxtWriter.java} | 72 +-
.../org/apache/iotdb/db/metadata/MManager.java | 236 ++--
.../java/org/apache/iotdb/db/metadata/MTree.java | 127 ++-
.../apache/iotdb/db/metadata/MetadataConstant.java | 10 +-
.../iotdb/db/metadata/logfile/MLogReader.java | 74 ++
.../iotdb/db/metadata/logfile/MLogTxtReader.java | 79 ++
.../iotdb/db/metadata/logfile/MLogWriter.java | 454 ++++++++
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 25 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 37 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 22 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 5 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 18 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 28 +-
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 19 +
...tStorageGroupPlan.java => ChangeAliasPlan.java} | 74 +-
...rageGroupPlan.java => ChangeTagOffsetPlan.java} | 76 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 4 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 66 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 4 +
.../{SetStorageGroupPlan.java => MNodePlan.java} | 88 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 143 +++
.../db/qp/physical/sys/SetStorageGroupPlan.java | 18 +-
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 1 -
...geGroupPlan.java => StorageGroupMNodePlan.java} | 79 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 18 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 2 +
.../iotdb/db/query/control/TracingManager.java | 2 +-
.../dataset/groupby/GroupByEngineDataSet.java | 70 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 18 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 5 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 37 +-
.../org/apache/iotdb/db/tools/mlog/MLogParser.java | 194 ++++
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 1 +
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 1 -
.../org/apache/iotdb/db/utils/SerializeUtils.java | 12 +-
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 56 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 13 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 147 +++
.../{ => authorizer}/LocalFileAuthorizerTest.java | 295 +++--
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 107 +-
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 45 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 22 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 44 +
.../auth/{ => role}/LocalFileRoleAccessorTest.java | 13 +-
.../auth/{ => role}/LocalFileRoleManagerTest.java | 45 +-
.../auth/{ => user}/LocalFileUserAccessorTest.java | 13 +-
.../auth/{ => user}/LocalFileUserManagerTest.java | 69 +-
.../LevelCompactionLogTest.java} | 61 +-
.../compaction/LevelCompactionMergeTest.java | 142 +++
.../compaction/LevelCompactionRecoverTest.java | 507 +++++++++
.../LevelCompactionSelectorTest.java} | 50 +-
.../LevelCompactionTest.java} | 68 +-
.../LevelCompactionTsFileManagementTest.java | 120 ++
.../NoCompactionTsFileManagementTest.java | 127 +++
.../apache/iotdb/db/engine/merge/MergeTest.java | 2 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 101 ++
.../iotdb/db/integration/IoTDBAddSubDeviceIT.java | 15 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 31 +-
.../org/apache/iotdb/db/integration/IoTDBAsIT.java | 10 +
.../db/integration/IoTDBAutoCreateSchemaIT.java | 19 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 154 ---
.../db/integration/IoTDBCreateSnapshotIT.java | 74 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 18 +
.../apache/iotdb/db/integration/IoTDBLastIT.java | 13 +-
.../db/integration/IoTDBLevelCompactionIT.java | 1180 ++++++++++++++++++++
.../iotdb/db/integration/IoTDBRestartIT.java | 2 -
.../IoTDBAggregationByLevelIT.java | 9 +-
.../IoTDBAggregationDeleteIT.java | 16 +-
.../{ => aggregation}/IoTDBAggregationIT.java | 2 +-
.../IoTDBAggregationLargeDataIT.java | 247 +---
.../IoTDBAggregationSmallDataIT.java | 179 +--
.../{ => auth}/IoTDBAuthorizationIT.java | 2 +-
.../iotdb/db/mqtt/BrokerAuthenticatorTest.java | 16 +
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 9 +-
.../db/query/aggregation/AggregateResultTest.java | 19 +-
.../query/aggregation/DescAggregateResultTest.java | 126 +++
.../iotdb/db/query/control/TracingManagerTest.java | 111 ++
.../db/query/dataset/ShowTimeSeriesResultTest.java | 57 +
.../dataset/groupby/GroupByEngineDataSetTest.java | 476 ++++++++
.../{ => groupby}/GroupByFillDataSetTest.java | 2 +-
.../{ => groupby}/GroupByLevelDataSetTest.java | 2 +-
.../{ => groupby}/GroupByTimeDataSetTest.java | 2 +-
.../query/executor/GroupByEngineDataSetTest.java | 177 ---
.../org/apache/iotdb/db/tools/MLogParserTest.java | 150 +++
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 5 +-
.../iotdb/db/utils/CopyOnReadLinkedListTest.java | 67 ++
.../db/utils/EncodingInferenceUtilsTest.java} | 46 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 114 ++
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 64 ++
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 312 ++++++
.../db/utils/datastructure/BinaryTVListTest.java | 58 +
.../db/utils/datastructure/BooleanTVListTest.java | 62 +
.../db/utils/datastructure/DoubleTVListTest.java | 72 ++
.../db/utils/datastructure/FloatTVListTest.java | 72 ++
.../db/utils/datastructure/IntTVListTest.java | 71 ++
.../db/utils/datastructure/LongTVListTest.java | 18 +
.../iotdb/db/writelog/io/LogWriterReaderTest.java | 4 +-
.../db/writelog/io/MultiFileLogReaderTest.java | 4 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 10 +-
.../theme/global-components/Contributor.vue | 7 +
tsfile/format-changelist.md | 2 +-
.../org/apache/iotdb/tsfile/file/MetaMarker.java | 4 +
.../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 31 +-
.../file/metadata/MetadataIndexConstructor.java | 9 +-
.../tsfile/file/metadata/MetadataIndexNode.java | 7 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 20 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 10 +-
.../tsfile/read/TsFileSequenceReaderTest.java | 2 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 8 +
147 files changed, 7251 insertions(+), 1873 deletions(-)
copy client-cpp/README.md => docs/UserGuide/System Tools/MLogParser Tool.md
(67%)
copy client-cpp/README.md => docs/zh/UserGuide/System Tools/MLogParser Tool.md
(67%)
copy
server/src/assembly/resources/tools/{tsfileToolSet/print-tsfile-sketch.bat =>
mlog/mLogParser.bat} (95%)
copy server/src/assembly/resources/tools/{tsfileToolSet/print-tsfile-sketch.sh
=> mlog/mLogParser.sh} (92%)
mode change 100755 => 100644
rename server/src/main/java/org/apache/iotdb/db/metadata/{MLogWriter.java =>
MLogTxtWriter.java} (70%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogTxtReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogWriter.java
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{SetStorageGroupPlan.java
=> ChangeAliasPlan.java} (60%)
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{SetStorageGroupPlan.java
=> ChangeTagOffsetPlan.java} (59%)
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{SetStorageGroupPlan.java
=> MNodePlan.java} (53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/MeasurementMNodePlan.java
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{SetStorageGroupPlan.java
=> StorageGroupMNodePlan.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/tools/mlog/MLogParser.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/auth/AuthorityCheckerTest.java
rename server/src/test/java/org/apache/iotdb/db/auth/{ =>
authorizer}/LocalFileAuthorizerTest.java (52%)
copy tsfile/src/test/java/org/apache/iotdb/tsfile/common/LRUCacheTest.java =>
server/src/test/java/org/apache/iotdb/db/auth/entity/PathPrivilegeTest.java
(52%)
copy cli/src/test/java/org/apache/iotdb/tool/CsvLineSplitTest.java =>
server/src/test/java/org/apache/iotdb/db/auth/entity/RoleTest.java (55%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/auth/entity/UserTest.java
rename server/src/test/java/org/apache/iotdb/db/auth/{ =>
role}/LocalFileRoleAccessorTest.java (85%)
rename server/src/test/java/org/apache/iotdb/db/auth/{ =>
role}/LocalFileRoleManagerTest.java (73%)
rename server/src/test/java/org/apache/iotdb/db/auth/{ =>
user}/LocalFileUserAccessorTest.java (89%)
rename server/src/test/java/org/apache/iotdb/db/auth/{ =>
user}/LocalFileUserManagerTest.java (70%)
copy server/src/test/java/org/apache/iotdb/db/engine/{merge/MergeLogTest.java
=> compaction/LevelCompactionLogTest.java} (52%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/LevelCompactionMergeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/LevelCompactionRecoverTest.java
copy server/src/test/java/org/apache/iotdb/db/engine/{merge/MergeLogTest.java
=> compaction/LevelCompactionSelectorTest.java} (60%)
copy server/src/test/java/org/apache/iotdb/db/engine/{merge/MergeTest.java =>
compaction/LevelCompactionTest.java} (79%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/LevelCompactionTsFileManagementTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/NoCompactionTsFileManagementTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompactionIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBLevelCompactionIT.java
rename server/src/test/java/org/apache/iotdb/db/integration/{ =>
aggregation}/IoTDBAggregationByLevelIT.java (97%)
rename server/src/test/java/org/apache/iotdb/db/integration/{ =>
aggregation}/IoTDBAggregationDeleteIT.java (89%)
rename server/src/test/java/org/apache/iotdb/db/integration/{ =>
aggregation}/IoTDBAggregationIT.java (99%)
rename server/src/test/java/org/apache/iotdb/db/integration/{ =>
aggregation}/IoTDBAggregationLargeDataIT.java (77%)
rename server/src/test/java/org/apache/iotdb/db/integration/{ =>
aggregation}/IoTDBAggregationSmallDataIT.java (87%)
rename server/src/test/java/org/apache/iotdb/db/integration/{ =>
auth}/IoTDBAuthorizationIT.java (99%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/query/aggregation/DescAggregateResultTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/query/control/TracingManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/query/dataset/ShowTimeSeriesResultTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByEngineDataSetTest.java
rename server/src/test/java/org/apache/iotdb/db/query/dataset/{ =>
groupby}/GroupByFillDataSetTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/query/dataset/{ =>
groupby}/GroupByLevelDataSetTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/query/dataset/{ =>
groupby}/GroupByTimeDataSetTest.java (99%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/query/executor/GroupByEngineDataSetTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/tools/MLogParserTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/CopyOnReadLinkedListTest.java
copy
server/src/{main/java/org/apache/iotdb/db/utils/EncodingInferenceUtils.java =>
test/java/org/apache/iotdb/db/utils/EncodingInferenceUtilsTest.java} (53%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/MemUtilsTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/SchemaUtilsTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/SerializeUtilsTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/datastructure/BinaryTVListTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/datastructure/BooleanTVListTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/datastructure/DoubleTVListTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/datastructure/FloatTVListTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/datastructure/IntTVListTest.java
