You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ej...@apache.org on 2021/05/30 09:13:48 UTC

[iotdb] branch hitter_compaction_mto_master updated (cd3d8c1 -> 770b402)

This is an automated email from the ASF dual-hosted git repository.

ejttianyu pushed a change to branch hitter_compaction_mto_master
in repository https://gitbox.apache.org/repos/asf/iotdb.git.


    from cd3d8c1  finish hitter merge
     add faed0d8  Fix group by month StackOverflow bug (#3070)
     add ae77977  fix some spell mistake for iotdb-engine conf (#3077)
     add 308e39d  JDBC bug - check authority for execute batch (#3059)
     add 0452bc3  Improve openid user manual (#3062)
     add f4ed918  Fix AuthorizationIT failed caused by #3069 (#3085)
     add 5c026bc  Fix query multiple subSensors for multiple device timeout bug in cluster (#3087)
     add a6401e4  [IOTDB-1319] Trigger module: alert manager sink (#3057)
     add ce6945f  [IOTDB-1339] optimize TimeoutChangeableTSnappyFramedTransport (#3086)
     add 6aa58c1  Print too many useless logs when snapshot occurred loading one tsfile (#3095)
     add b98b453  line separator (#3097)
     add 13f846a  fix some config inconsistent (#3082)
     add 9ba36a3  [IOTDB-1306] New memory control strategy (#3060)
     add 8cb33d7  Only print last query details while debuging (#3094)
     add 8c5bef7  Fixed openid bug (#3073)
     add 06ba8b3  Fix for issue # 1804 (Opened by me) (#2278)
     add 3f55841  [IOTDB-1344] Deleting Storage Group does not clear the count of time series (#3104)
     add 17a2872  [IOTDB-1330]fix the load tsfile bug when the cross multi partition's tsfile only have one page (#3080)
     add 05bdd1c  Add TsFileSequenceReader getChunkMetadataList method return empty if path not exists (#3109)
     add 077bb3c  [IOTDB-1212] The given error message is not right when executing `select sin(non_existence) from root.sg1.d1` (#3101)
     add c17cfa2  [IOTDB-1345] AlertManagerTest: Bind Address already in use (#3110)
     add 4cabbfa  [GITHUB-3121] add maven http parameter to avoid maven downloading dependencies timeout in github actions (#3122)
     add e43aea6  Fix reduce frequent log printing. (#3114)
     add c45fa84  fix link for CSV tool
     add 126ebc0  [IOTDB-1345] reuse server in AlertManagerTest (#3124)
     add f34cfb3  [IOTDB-1355] Support updating aligned timeseries values when insert partially (#3128)
     add 925a2b4  [ISSUE-3132] Replace Bintray repository with JFrog
     add 421d35c  [IOTDB-1350]Change the log packing time from one hour to one day(#3120)
     add 6e88ad7  [IOTDB-1315] ExportCsvTool should support timestamp `yyyy-MM-dd'T'HH:mm:ss.SSSZ` (#3115)
     add ca36589  [IOTDB-1286] fix 4 C++ mem-leak points (#2976)
     add db71701  [IoTDB-1331] Add transformPath for CMManger (#3105)
     add 1594797  Update LICENCE-binary (#3140)
     add 8907772  [IOTDB-1348] Last plan not work in cluster mode (#3118)
     add e9ada63  [IOTDB-1232][IOTDB-1313] Fix lossing time precision when import csv with unsupported timestamp format (#3142)
     add 7a77b3f  [IOTDB-1316] The importCsv tool should continue inserting if a part of insertion failed (#3131)
     add f4db723  [ISSUE-3089] make it possible for storage groups to have name with hyphen (#3151)
     add 1a6118a  Fix `merge` command cannot execute compaction task bug (#3152)
     add 819b195  Add continuous compaction in level compaction strategy (#2080)
     add 19cfcd5  [IOTDB-1352][IOTDB-1353] Rafactor E2E test, add ClusterInfo thrift based API (#3143)
     add 215199f  Fix code format error
     add 7151b7d  fix cluster_info_public_port  parameter not set in cluster/src/test/resources/ (#3156)
     add d6fe7b0  [IOTDB-1366] Refactor MetadataIndex in TsFile for Vector (#3081)
     add 55d9260  [IOTDB-1266]SHOW TIMESERIES will only display 2000 timeseries (#2958)
     add e4a3e74  Increase the time of timeout in Jenkinsfile to fix website build failed (#3165)
     add 0050262  [IOTDB-1357] Compaction use append chunk merge strategy when chunk is already large (#3159)
     add 9e56152  [IOTDB-1356] Separate unseq_file_num_in_each_level from selecting candidate file in unseq compaction (#3160)
     add 470ea63  [ISSUE-3166] Privilege `CREATE_TIMESERIES` is not stated in the document (#3168)
     add 4852dad  [IOTDB-1371] Fix NPE when creating aligned timeseries and inserting with mismatched data type (#3164)
     add 0ea44c4  Update some badge in README (#3174)
     add 6907e34  [IOTDB-1378] Fix MetadataIndexTree constructs error when existing more than one chunks in vector (#3180)
     add f6e636b  support (#3172)
     add 49cd4d1  Fix align by device query locally bugs in cluster module && Fix concurrent query bugs in cluster module (#3183)
     add f7e3590  [IOTDB-1376] BatchProcessException was not correctly handled in BaseApplier (#3173)
     add 3bf4114  Cherry pick upgrade bugs fixes PR #3178 #3154 to master (#3182)
     add 517e496  [ISSUE-3116] Bug when using natural month unit in time interval in group by query (#3139)
     add 0b964a1  Implement some JDBC methods to support DataGrip (#3181)
     add 8992927  Fix import csv throw ArrayOutOfIndexError when the last value in a line is null (#3185)
     add ebf1a73  update force full merge config (#3194)
     add 49f8919  Update some out-of-date contents in README and ContributeGuide (#3196)
     add 5fe8c84  [IOTDB-1259] upgrade libthrift from 0.12.0/0.13.0 to 0.14.1 and updated related classes or files (#3163)
     add c63bf83  [ISSUE-3176] Support running IoTDB CI on JDK16 (#3177)
     add 31f077e  [IOTDB-1380] Automatically close the dataset while there is no more data (#3193)
     add 6844ac7  [IOTDB-1321] Filter RowRecord automatically if any column in it is null or all columns are null (#3153)
     add c0ee6cb  Fix an invalid link in the Zepplin-IoTDB UserGuide (#3210)
     add 725cc68  fix index out of bound when VectorTimeSeriesMetadata is not find in memory (#3208)
     add a41c855  Fix the CI issue introduced by thrift0.14 and the thrift server is not closed properly in SessionPoolTest. (#3198)
     add 222396c  add rabbitmq example module. (#3049)
     add 38ac322  Fix JDK version missspelling (#3224)
     add 53ac9d9  Fix some bugs reported by sonar (#3158)
     add 2cfa4d8  Modify the document to ensure that the official website can be successfully built (#3229)
     add 088ac59  Fix session UT (#3227)
     add 2147526  update cluster docs (#3238)
     add 48328e3  [ISSUE-3232] fix the bug of Memory Information in Windows host (#3231)
     add 076a8ac  update cluster docs (#3239)
     add c581085  Try to fix website build failed (#3243)
     add f7c61aa  Pseudo distributed no logs error (#3247)
     add bcce61b  [IOTDB-1385] Extract the super user and password to the config (#3244)
     add fee62c1  [IOTDB-1387]  Fix Without Null ALL doesn't take effect in align by device clause (#3245)
     add 44fdc04  [IOTDB-1384] Fix group by bug (#3251)
     add b303d33  Support JDBC placeholder when set sensor or device by set string (#3249)
     add 7c3d432  fix_unseq_compaction_loss_data_bug (#3256)
     add 98ba544  Modify the getAggrResult method, don't destroy polymorphism too early (#3209)
     add 95a7405  Try to fix cluster CI failed (#3257)
     add 951bf72  support  “all”  keyword when execute fill query (#3240)
     add dae1f15  [IOTDB-1022] ANTLR Grammar & Logical Operator for Arithmetic Operations and Nested Operations in SELECT Clauses (#3236)
     add aca9faa  Enable sonar-coveralls for pr from fork repos (#3263)
     add bd1d1a6  Revert "Enable sonar-coveralls for pr from fork repos (#3263)" (#3266)
     add 89d0d37  add slack invite link (#3265)
     add 8d3819f  update test and doc and fix small bug (#3281)
     add 363bda9  Fix TotalSeriesNumber in MManager counted twice when recovering (#3276)
     add beefb2e  do not select unseq files when there are unmerged old unseq files (#3273)
     add 8b1ee93  Fix typo (#3287)
     add 084c3b8  [IOTDB-3268] Add the Chinese version of TSDB-Comparison document (#3274)
     add 770b402  merge master

No new revisions were added by this update.

Summary of changes:
 .github/workflows/client-go.yml                    |   3 +
 .github/workflows/client.yml                       |  12 +-
 .github/workflows/e2e.yml                          |   3 +
 .github/workflows/main-unix.yml                    |   5 +-
 .github/workflows/main-win.yml                     |   5 +-
 .github/workflows/sonar-coveralls.yml              |   3 +
 .../ContributeGuide.md => CONTRIBUTING.md          |  63 ++-
 Code Summary.md                                    |  59 +++
 Jenkinsfile                                        |   2 +-
 LICENSE-binary                                     |   6 +-
 README.md                                          |  33 +-
 README_ZH.md                                       |  23 +-
 .../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4   | 156 ++----
 cli/pom.xml                                        |   2 +-
 .../org/apache/iotdb/tool/AbstractCsvTool.java     |  40 +-
 .../main/java/org/apache/iotdb/tool/ExportCsv.java |   2 +-
 .../main/java/org/apache/iotdb/tool/ImportCsv.java |  59 ++-
 client-cpp/src/main/CMakeLists.txt                 |   2 +-
 client-cpp/src/main/Session.cpp                    |  11 +-
 client-cpp/src/main/Session.h                      |  16 +-
 client-cpp/src/test/CMakeLists.txt                 |   2 +-
 client-py/README.md                                |   5 +-
 cluster/pom.xml                                    |  14 +-
 .../resources/conf/iotdb-cluster.properties        |   9 +-
 .../java/org/apache/iotdb/cluster/ClusterMain.java |  13 +
 .../cluster/client/async/AsyncDataClient.java      |   4 +-
 .../client/async/AsyncDataHeartbeatClient.java     |   4 +-
 .../cluster/client/async/AsyncMetaClient.java      |   4 +-
 .../client/async/AsyncMetaHeartbeatClient.java     |   4 +-
 .../iotdb/cluster/client/sync/SyncDataClient.java  |   2 +
 .../client/sync/SyncDataHeartbeatClient.java       |   2 +
 .../iotdb/cluster/client/sync/SyncMetaClient.java  |   2 +
 .../client/sync/SyncMetaHeartbeatClient.java       |   2 +
 .../apache/iotdb/cluster/config/ClusterConfig.java |  17 +-
 .../iotdb/cluster/config/ClusterDescriptor.java    |   9 +-
 .../iotdb/cluster/log/applier/BaseApplier.java     |  37 +-
 .../apache/iotdb/cluster/metadata/CMManager.java   |  47 +-
 .../cluster/query/ClusterDataQueryExecutor.java    |   5 +-
 .../cluster/query/ClusterPhysicalGenerator.java    |   8 +-
 .../apache/iotdb/cluster/query/ClusterPlanner.java |  43 +-
 .../iotdb/cluster/query/LocalQueryExecutor.java    |  58 +-
 .../cluster/query/aggregate/ClusterAggregator.java |  10 +-
 .../query/last/ClusterLastQueryExecutor.java       |   1 +
 .../cluster/query/reader/ClusterReaderFactory.java |  12 +-
 .../query/reader/mult/RemoteMultSeriesReader.java  |   7 +-
 .../iotdb/cluster/server/MetaClusterServer.java    |  27 +-
 .../server/clusterinfo/ClusterInfoServer.java      |  65 +--
 .../server/clusterinfo/ClusterInfoServerMBean.java |   6 +-
 .../server/clusterinfo/ClusterInfoServiceImpl.java |  71 +++
 .../ClusterInfoServiceThriftHandler.java           |   9 +-
 .../cluster/server/member/MetaGroupMember.java     |   4 +-
 .../cluster/utils/nodetool/ClusterMonitor.java     |   2 +
 .../utils/nodetool/ClusterMonitorMBean.java        |   2 +-
 .../cluster/client/sync/SyncDataClientTest.java    |   6 +-
 .../cluster/client/sync/SyncMetaClientTest.java    |   6 +-
 .../cluster/common/TestAsyncClientFactory.java     |   4 +-
 .../cluster/common/TestSyncClientFactory.java      |  13 +
 .../cluster/log/applier/DataLogApplierTest.java    |  35 ++
 .../cluster/log/snapshot/DataSnapshotTest.java     |  14 +
 .../cluster/log/snapshot/PullSnapshotTaskTest.java |  14 +
 .../query/ClusterPhysicalGeneratorTest.java        |  10 +-
 .../query/groupby/MergeGroupByExecutorTest.java    |  23 +-
 .../query/groupby/RemoteGroupByExecutorTest.java   |  23 +-
 .../server/clusterinfo/ClusterInfoServerTest.java  |  96 ++++
 .../clusterinfo/ClusterInfoServiceImplTest.java    |  98 ++++
 .../cluster/server/member/DataGroupMemberTest.java |  28 +-
 .../cluster/server/member/MetaGroupMemberTest.java |  20 +-
 cluster/src/test/resources/logback.xml             |   4 -
 .../resources/node1conf/iotdb-cluster.properties   |   1 +
 .../src/test/resources/node1conf}/logback.xml      |  48 +-
 .../resources/node2conf/iotdb-cluster.properties   |   1 +
 .../src/test/resources/node2conf}/logback.xml      |  48 +-
 .../resources/node3conf/iotdb-cluster.properties   |   1 +
 .../src/test/resources/node3conf}/logback.xml      |  48 +-
 compile-tools/pom.xml                              |   8 +-
 compile-tools/thrift/pom.xml                       |   2 +-
 docs/Development/ContributeGuide.md                |  62 ++-
 docs/UserGuide/API/Programming-Java-Native-API.md  |  98 ++++
 .../Administration-Management/Administration.md    |   7 +-
 docs/UserGuide/Advanced-Features/Alerting.md       | 385 ++++++++++++++
 docs/UserGuide/Advanced-Features/Triggers.md       | 112 ++++
 docs/UserGuide/CLI/Command-Line-Interface.md       |  69 ++-
 docs/UserGuide/Cluster/Cluster-Setup-Example.md    |  37 +-
 docs/UserGuide/Cluster/Cluster-Setup.md            |  11 +-
 docs/UserGuide/Comparison/TSDB-Comparison.md       | 135 ++---
 .../Data-Concept/Data-Model-and-Terminology.md     |   4 +-
 .../Ecosystem Integration/Zeppelin-IoTDB.md        |   4 +-
 .../DDL-Data-Definition-Language.md                |   2 +-
 .../DML-Data-Manipulation-Language.md              |  14 +
 docs/zh/Development/ContributeGuide.md             |  26 +-
 .../UserGuide/API/Programming-Java-Native-API.md   |  95 ++++
 .../Administration-Management/Administration.md    |   5 +-
 docs/zh/UserGuide/Advanced-Features/Alerting.md    | 385 ++++++++++++++
 docs/zh/UserGuide/Advanced-Features/Triggers.md    | 110 ++++
 docs/zh/UserGuide/CLI/Command-Line-Interface.md    |  75 ++-
 docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md |  37 +-
 docs/zh/UserGuide/Cluster/Cluster-Setup.md         |  11 +-
 docs/zh/UserGuide/Comparison/TSDB-Comparison.md    | 403 ++++++++++++++
 .../Data-Concept/Data-Model-and-Terminology.md     |   4 +-
 .../Ecosystem Integration/Zeppelin-IoTDB.md        |   4 +-
 .../DDL-Data-Definition-Language.md                |   2 +-
 .../DML-Data-Manipulation-Language.md              |  14 +
 example/hadoop/pom.xml                             |   3 +-
 example/pom.xml                                    |   6 +
 example/{pulsar => rabbitmq}/pom.xml               |  20 +-
 example/rabbitmq/readme.md                         |  63 +++
 .../java/org/apache/iotdb/rabbitmq}/Constant.java  |  27 +-
 .../iotdb/rabbitmq/RabbitMQChannelUtils.java       |  50 ++
 .../apache/iotdb/rabbitmq/RabbitMQConsumer.java    | 132 +++++
 .../apache/iotdb/rabbitmq/RabbitMQProducer.java    |  49 ++
 example/trigger/pom.xml                            |  66 ++-
 .../org/apache/iotdb/trigger/AlertingExample.java  | 107 ++++
 .../apache/iotdb/tsfile/TsFileSequenceRead.java    |   5 +
 example/udf/pom.xml                                |  68 ++-
 hadoop/pom.xml                                     |   2 +-
 hive-connector/pom.xml                             |   5 +-
 jdbc/src/main/feature/feature.xml                  |   2 +-
 .../org/apache/iotdb/jdbc/IoTDBConnection.java     |   9 +-
 .../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java     |   9 +-
 .../apache/iotdb/jdbc/IoTDBPreparedStatement.java  |   2 +-
 .../java/org/apache/iotdb/jdbc/IoTDBStatement.java |  38 +-
 .../iotdb/jdbc/IoTDBPreparedStatementTest.java     |  42 +-
 pom.xml                                            |  25 +-
 server/pom.xml                                     |   6 +
 .../resources/conf/iotdb-engine.properties         |  33 +-
 server/src/assembly/resources/conf/iotdb-env.bat   |  12 +-
 server/src/assembly/resources/conf/logback.xml     |  24 +-
 .../org/apache/iotdb/db/auth/AuthorityChecker.java |   3 +-
 .../db/auth/authorizer/LocalFileAuthorizer.java    |   3 +-
 .../iotdb/db/auth/authorizer/OpenIdAuthorizer.java |   3 +-
 .../apache/iotdb/db/auth/entity/PrivilegeType.java |   1 +
 .../iotdb/db/auth/user/BasicUserManager.java       |  10 +-
 .../org/apache/iotdb/db/concurrent/ThreadName.java |   3 +-
 .../java/org/apache/iotdb/db/conf/IoTDBConfig.java |  60 ++-
 .../org/apache/iotdb/db/conf/IoTDBConfigCheck.java |  28 +-
 .../org/apache/iotdb/db/conf/IoTDBConstant.java    |   2 -
 .../org/apache/iotdb/db/conf/IoTDBDescriptor.java  |  49 +-
 .../org/apache/iotdb/db/engine/StorageEngine.java  |  41 +-
 .../db/engine/cache/TimeSeriesMetadataCache.java   | 123 ++++-
 .../db/engine/compaction/TsFileManagement.java     |  23 +-
 .../level/LevelCompactionTsFileManagement.java     |  57 +-
 .../engine/compaction/utils/CompactionUtils.java   |  81 ++-
 .../iotdb/db/engine/flush/MemTableFlushTask.java   |  20 +-
 .../iotdb/db/engine/memtable/AbstractMemTable.java |  11 +
 .../apache/iotdb/db/engine/memtable/IMemTable.java |   4 +
 .../db/engine/merge/manage/MergeResource.java      |   2 +-
 .../merge/selector/MaxFileMergeFileSelector.java   |   9 +-
 .../iotdb/db/engine/merge/task/MergeFileTask.java  |   8 +-
 .../db/engine/merge/task/MergeMultiChunkTask.java  |  14 +-
 .../db/engine/storagegroup/StorageGroupInfo.java   |   6 +-
 .../engine/storagegroup/StorageGroupProcessor.java |  73 +--
 .../db/engine/storagegroup/TsFileProcessor.java    |  54 +-
 .../engine/storagegroup/TsFileProcessorInfo.java   |   6 +-
 .../db/engine/storagegroup/TsFileResource.java     |  26 +-
 .../storagegroup/timeindex/DeviceTimeIndex.java    |  18 -
 .../storagegroup/timeindex/FileTimeIndex.java      |   5 -
 .../engine/storagegroup/timeindex/ITimeIndex.java  |   8 -
 .../org/apache/iotdb/db/metadata/MManager.java     |  98 +++-
 .../org/apache/iotdb/db/metadata/PartialPath.java  |  29 +-
 .../org/apache/iotdb/db/metadata/mnode/MNode.java  |   4 +
 .../iotdb/db/metrics/server/ServerArgument.java    |  12 +-
 .../main/java/org/apache/iotdb/db/qp/Planner.java  | 186 ++-----
 .../apache/iotdb/db/qp/executor/PlanExecutor.java  |  15 +-
 .../org/apache/iotdb/db/qp/logical/Operator.java   |   1 -
 .../db/qp/logical/crud/DeleteDataOperator.java     |  17 +-
 .../iotdb/db/qp/logical/crud/InsertOperator.java   |  15 +-
 .../iotdb/db/qp/logical/crud/QueryOperator.java    |  66 ++-
 .../iotdb/db/qp/logical/crud/SFWOperator.java      |  98 ----
 .../iotdb/db/qp/logical/crud/SelectOperator.java   | 118 +++--
 .../db/qp/logical/sys/CreateIndexOperator.java     |  17 +-
 .../iotdb/db/qp/logical/sys/DropIndexOperator.java |  18 +-
 .../physical/BatchPlan.java}                       |  41 +-
 .../iotdb/db/qp/physical/crud/AggregationPlan.java |   6 +-
 .../db/qp/physical/crud/AlignByDevicePlan.java     |   6 +
 .../db/qp/physical/crud/InsertMultiTabletPlan.java |  39 +-
 .../physical/crud/InsertRowsOfOneDevicePlan.java   |  33 +-
 .../iotdb/db/qp/physical/crud/InsertRowsPlan.java  |  39 +-
 .../iotdb/db/qp/physical/crud/LastQueryPlan.java   |  30 +-
 .../iotdb/db/qp/physical/crud/QueryPlan.java       |  46 +-
 .../db/qp/physical/crud/RawDataQueryPlan.java      |  67 +++
 .../apache/iotdb/db/qp/physical/crud/UDFPlan.java  |   4 +-
 .../apache/iotdb/db/qp/physical/crud/UDTFPlan.java |  83 ++-
 .../qp/physical/sys/CreateMultiTimeSeriesPlan.java |  39 +-
 .../apache/iotdb/db/qp/physical/sys/ShowPlan.java  |   1 -
 .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java    | 586 ++++++++++++---------
 .../iotdb/db/qp/strategy/LogicalChecker.java       | 108 ++++
 .../iotdb/db/qp/strategy/LogicalGenerator.java     |  63 ++-
 .../iotdb/db/qp/strategy/PhysicalGenerator.java    | 208 +++-----
 .../qp/strategy/optimizer/ConcatPathOptimizer.java | 397 +++-----------
 .../qp/strategy/optimizer/ILogicalOptimizer.java   |   2 +-
 .../qp/strategy/optimizer/RemoveNotOptimizer.java  |   7 +-
 .../apache/iotdb/db/qp/utils/DatetimeUtils.java    |  33 +-
 .../apache/iotdb/db/qp/utils/WildcardsRemover.java | 160 ++++++
 .../db/query/dataset/AlignByDeviceDataSet.java     |   3 +
 .../dataset/RawQueryDataSetWithoutValueFilter.java |  79 ++-
 .../apache/iotdb/db/query/dataset/ShowDataSet.java |  12 +-
 .../apache/iotdb/db/query/dataset/UDTFDataSet.java |   2 +-
 .../dataset/groupby/LocalGroupByExecutor.java      |   3 +
 .../iotdb/db/query/executor/LastQueryExecutor.java |  53 +-
 .../iotdb/db/query/executor/QueryRouter.java       |   6 +-
 .../db/query/executor/fill/LastPointReader.java    |  51 +-
 .../iotdb/db/query/expression/Expression.java      |  31 +-
 .../iotdb/db/query/expression/ResultColumn.java    | 139 +++++
 .../expression/binary/AdditionExpression.java      |  18 +-
 .../query/expression/binary/BinaryExpression.java  | 118 +++++
 .../expression/binary/DivisionExpression.java      |  18 +-
 .../query/expression/binary/ModuloExpression.java  |  18 +-
 .../binary/MultiplicationExpression.java           |  18 +-
 .../expression/binary/SubtractionExpression.java   |  18 +-
 .../query/expression/unary/FunctionExpression.java | 232 ++++++++
 .../db/query/expression/unary/MinusExpression.java |  78 +++
 .../query/expression/unary/TimeSeriesOperand.java  |  82 +++
 .../chunk/metadata/DiskChunkMetadataLoader.java    |   2 +-
 .../query/reader/series/SeriesAggregateReader.java |   2 +-
 .../reader/series/SeriesRawDataBatchReader.java    |   4 +-
 .../iotdb/db/query/reader/series/SeriesReader.java |  13 +-
 .../reader/series/SeriesReaderByTimestamp.java     |   2 +-
 .../query/reader/series/SeriesReaderFactory.java   |  94 ----
 .../db/query/reader/series/VectorSeriesReader.java | 144 -----
 .../db/query/udf/core/context/UDFContext.java      | 142 -----
 .../db/query/udf/core/executor/UDTFExecutor.java   |  17 +-
 .../query/udf/service/UDFRegistrationService.java  |   6 +-
 .../org/apache/iotdb/db/rescon/SystemInfo.java     | 230 ++++----
 .../apache/iotdb/db/service/MetricsService.java    |   3 +
 .../org/apache/iotdb/db/service/ServiceType.java   |   5 +-
 .../org/apache/iotdb/db/service/StartupChecks.java |   2 +-
 .../org/apache/iotdb/db/service/TSServiceImpl.java |  61 +--
 .../alertmanager/AlertManagerConfiguration.java    |  20 +-
 .../db/sink/alertmanager/AlertManagerEvent.java    | 123 +++++
 .../db/sink/alertmanager/AlertManagerHandler.java  |  83 +++
 .../apache/iotdb/db/sync/conf/SyncConstant.java    |   5 +-
 .../iotdb/db/sync/sender/transfer/SyncClient.java  |  27 +-
 .../apache/iotdb/db/tools/TsFileRewriteTool.java   |  15 +-
 .../db/tools/upgrade/TsFileOnlineUpgradeTool.java  |  16 +
 .../java/org/apache/iotdb/db/utils/AuthUtils.java  |   2 -
 .../org/apache/iotdb/db/utils/FileLoaderUtils.java |  94 +++-
 .../java/org/apache/iotdb/db/utils/MergeUtils.java |   4 +-
 .../apache/iotdb/db/utils/QueryDataSetUtils.java   |  20 +-
 .../org/apache/iotdb/db/utils/SchemaUtils.java     |   2 +-
 .../iotdb/db/utils/datastructure/TVList.java       |  31 +-
 .../iotdb/db/utils/datastructure/VectorTVList.java |  63 ++-
 .../apache/iotdb/db/auth/AuthorityCheckerTest.java |   2 -
 .../auth/authorizer/LocalFileAuthorizerTest.java   |  10 +-
 .../db/auth/user/LocalFileUserManagerTest.java     |   4 +-
 .../db/engine/compaction/CompactionChunkTest.java  |   4 +-
 .../compaction/LevelCompactionCacheTest.java       |   3 +-
 .../engine/compaction/LevelCompactionLogTest.java  |   3 +-
 .../compaction/LevelCompactionMergeTest.java       |  83 ++-
 .../compaction/LevelCompactionMoreDataTest.java    |   3 +-
 .../NoCompactionTsFileManagementTest.java          |   4 +-
 .../engine/merge/MaxFileMergeFileSelectorTest.java |  73 +++
 .../iotdb/db/engine/merge/MergeTaskTest.java       |  86 ++-
 .../apache/iotdb/db/engine/merge/MergeTest.java    |   9 +-
 .../engine/storagegroup/TsFileProcessorTest.java   |  12 +-
 .../db/integration/IOTDBInsertAlignedValuesIT.java |  78 ++-
 .../iotdb/db/integration/IoTDBGroupByMonthIT.java  |  99 +++-
 .../iotdb/db/integration/IoTDBGroupByUnseqIT.java  | 136 +++++
 ...oTDBLoadExternalTsFileWithTimePartitionIT.java} |  44 +-
 .../iotdb/db/integration/IoTDBSimpleQueryIT.java   |  36 ++
 .../iotdb/db/integration/IoTDBUDFManagementIT.java |  10 +-
 .../integration/IoTDBUDTFAlignByTimeQueryIT.java   |  16 +
 .../db/integration/IoTDBUDTFHybridQueryIT.java     |   3 +-
 .../db/integration/IoTDBWithoutAllNullIT.java      | 264 ++++++++++
 .../db/integration/IoTDBWithoutAnyNullIT.java      | 221 ++++++++
 .../db/integration/auth/IoTDBAuthorizationIT.java  | 108 +++-
 .../iotdb/db/metadata/MManagerBasicTest.java       | 299 +++++++++++
 .../org/apache/iotdb/db/metadata/MTreeTest.java    |   1 +
 .../iotdb/db/qp/logical/IndexLogicalPlanTest.java  |  48 +-
 .../iotdb/db/qp/logical/LogicalPlanSmallTest.java  |  88 ++--
 .../db/qp/utils/DatetimeQueryDataSetUtilsTest.java |  28 +
 .../query/dataset/UDTFAlignByTimeDataSetTest.java  |  18 +-
 .../org/apache/iotdb/db/script/EnvScriptIT.java    |   6 +-
 .../org/apache/iotdb/db/sink/AlertManagerTest.java | 328 ++++++++++++
 .../apache/iotdb/db/sink/LocalIoTDBSinkTest.java   |   3 +-
 .../apache/iotdb/db/utils/EnvironmentUtils.java    |  12 +-
 .../iotdb/db/utils/TsFileRewriteToolTest.java      |  57 ++
 .../iotdb/rpc/AutoScalingBufferReadTransport.java  |  13 +
 .../iotdb/rpc/AutoScalingBufferWriteTransport.java |  15 +
 .../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java |  20 +-
 .../org/apache/iotdb/rpc/RpcTransportFactory.java  |  13 +-
 .../main/java/org/apache/iotdb/rpc/RpcUtils.java   |   4 +-
 .../rpc/TCompressedElasticFramedTransport.java     |   2 +-
 ...OpenTransport.java => TConfigurationConst.java} |  28 +-
 .../apache/iotdb/rpc/TElasticFramedTransport.java  |  20 +-
 .../iotdb/rpc/TNonblockingSocketWrapper.java       |  60 +++
 .../java/org/apache/iotdb/rpc/TSocketWrapper.java  |  68 +++
 .../rpc/TimeoutChangeableTFastFramedTransport.java |   8 +-
 .../TimeoutChangeableTSnappyFramedTransport.java   |  20 +-
 .../apache/iotdb/session/SessionConnection.java    |  13 +-
 .../apache/iotdb/session/IoTDBSessionSimpleIT.java |  81 +++
 .../java/org/apache/iotdb/session/SessionUT.java   |   2 +-
 .../apache/iotdb/session/pool/SessionPoolTest.java | 117 ++--
 .../src/test/resources/logback.xml                 |   3 +-
 site/src/main/.vuepress/config.js                  |  10 +-
 spark-tsfile/pom.xml                               |   2 +-
 .../test/java/org/apache/iotdb/db/sql/Cases.java   | 223 ++++++++
 .../java/org/apache/iotdb/db/sql/ClusterIT.java    | 116 ++--
 .../java/org/apache/iotdb/db/sql/SingleNodeIT.java |  50 +-
 .../iotdb/db/sql/node1/OneNodeClusterIT.java       |  54 ++
 .../AbstractThreeNodeClusterIT.java}               |  63 +--
 .../iotdb/db/sql/nodes3/ThreeNodeCluster1IT.java   |  10 +-
 .../iotdb/db/sql/nodes3/ThreeNodeCluster2IT.java   |  16 +-
 .../AbstractFiveNodeClusterIT.java}                |  89 ++--
 .../iotdb/db/sql/nodes5/FiveNodeCluster1IT.java    |  10 +-
 .../iotdb/db/sql/nodes5/FiveNodeCluster2IT.java    |  15 +-
 .../iotdb/db/sql/nodes5/FiveNodeCluster4IT.java    |  15 +-
 .../test/resources/1node/iotdb-cluster.properties  |   2 +-
 thrift-cluster/src/main/thrift/cluster.thrift      |  52 +-
 thrift-sync/pom.xml                                |   5 -
 .../tsfile/common/constant/TsFileConstant.java     |   3 +
 .../iotdb/tsfile/file/metadata/ChunkMetadata.java  |  16 +
 .../iotdb/tsfile/file/metadata/IChunkMetadata.java |   6 +
 .../tsfile/file/metadata/ITimeSeriesMetadata.java  |   3 +
 .../file/metadata/MetadataIndexConstructor.java    |  54 +-
 .../tsfile/file/metadata/MetadataIndexNode.java    |   2 +-
 .../tsfile/file/metadata/TimeseriesMetadata.java   |  20 +-
 .../tsfile/file/metadata/VectorChunkMetadata.java  |  24 +
 .../file/metadata/VectorTimeSeriesMetadata.java    |  16 +
 .../iotdb/tsfile/read/TsFileSequenceReader.java    |  97 +++-
 .../apache/iotdb/tsfile/read/common/RowRecord.java |  43 +-
 .../tsfile/read/filter/GroupByMonthFilter.java     |  17 +-
 .../tsfile/read/query/dataset/QueryDataSet.java    |  33 +-
 .../org/apache/iotdb/tsfile/utils/PublicBAOS.java  |   1 +
 .../tsfile/v2/file/metadata/TsFileMetadataV2.java  |   9 +-
 .../tsfile/v2/read/TsFileSequenceReaderForV2.java  |  22 +-
 .../iotdb/tsfile/write/chunk/TimeChunkWriter.java  |   3 +-
 .../iotdb/tsfile/write/chunk/ValueChunkWriter.java |   3 +-
 .../iotdb/tsfile/write/writer/TsFileIOWriter.java  | 121 +++--
 .../zeppelin/iotdb/IoTDBInterpreterTest.java       |  27 +-
 329 files changed, 10544 insertions(+), 3527 deletions(-)
 copy docs/Development/ContributeGuide.md => CONTRIBUTING.md (74%)
 create mode 100644 Code Summary.md
 copy server/src/main/java/org/apache/iotdb/db/service/RPCService.java => cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServer.java (55%)
 copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java (89%)
 create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImpl.java
 copy server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerThriftHandler.java => cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceThriftHandler.java (84%)
 create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerTest.java
 create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImplTest.java
 copy {server/src/assembly/resources/conf => cluster/src/test/resources/node1conf}/logback.xml (85%)
 copy {server/src/assembly/resources/conf => cluster/src/test/resources/node2conf}/logback.xml (85%)
 copy {server/src/assembly/resources/conf => cluster/src/test/resources/node3conf}/logback.xml (85%)
 create mode 100644 docs/UserGuide/Advanced-Features/Alerting.md
 create mode 100644 docs/zh/UserGuide/Advanced-Features/Alerting.md
 create mode 100644 docs/zh/UserGuide/Comparison/TSDB-Comparison.md
 copy example/{pulsar => rabbitmq}/pom.xml (81%)
 create mode 100644 example/rabbitmq/readme.md
 copy example/{rocketmq/src/main/java/org/apache/iotdb/rocketmq => rabbitmq/src/main/java/org/apache/iotdb/rabbitmq}/Constant.java (75%)
 create mode 100644 example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQChannelUtils.java
 create mode 100644 example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQConsumer.java
 create mode 100644 example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQProducer.java
 create mode 100644 example/trigger/src/main/java/org/apache/iotdb/trigger/AlertingExample.java
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SFWOperator.java
 copy server/src/main/java/org/apache/iotdb/db/{exception/query/QueryTimeoutRuntimeException.java => qp/physical/BatchPlan.java} (55%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalChecker.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/utils/WildcardsRemover.java
 rename cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterConcatPathOptimizer.java => server/src/main/java/org/apache/iotdb/db/query/expression/Expression.java (54%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/ResultColumn.java
 copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java => server/src/main/java/org/apache/iotdb/db/query/expression/binary/AdditionExpression.java (70%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/binary/BinaryExpression.java
 copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java => server/src/main/java/org/apache/iotdb/db/query/expression/binary/DivisionExpression.java (70%)
 copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java => server/src/main/java/org/apache/iotdb/db/query/expression/binary/ModuloExpression.java (70%)
 copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java => server/src/main/java/org/apache/iotdb/db/query/expression/binary/MultiplicationExpression.java (70%)
 copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java => server/src/main/java/org/apache/iotdb/db/query/expression/binary/SubtractionExpression.java (70%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/unary/FunctionExpression.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/unary/MinusExpression.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/unary/TimeSeriesOperand.java
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReaderFactory.java
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/VectorSeriesReader.java
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/context/UDFContext.java
 copy grafana/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java => server/src/main/java/org/apache/iotdb/db/sink/alertmanager/AlertManagerConfiguration.java (71%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/sink/alertmanager/AlertManagerEvent.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/sink/alertmanager/AlertManagerHandler.java
 create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByUnseqIT.java
 rename server/src/test/java/org/apache/iotdb/db/integration/{IoTDBLoadExternalTsfileWithTimePartitionIT.java => IoTDBLoadExternalTsFileWithTimePartitionIT.java} (82%)
 create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBWithoutAllNullIT.java
 create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBWithoutAnyNullIT.java
 create mode 100644 server/src/test/java/org/apache/iotdb/db/sink/AlertManagerTest.java
 copy service-rpc/src/main/java/org/apache/iotdb/rpc/{NonOpenTransport.java => TConfigurationConst.java} (68%)
 create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TNonblockingSocketWrapper.java
 create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TSocketWrapper.java
 copy {hive-connector => session}/src/test/resources/logback.xml (94%)
 create mode 100644 testcontainer/src/test/java/org/apache/iotdb/db/sql/Cases.java
 create mode 100644 testcontainer/src/test/java/org/apache/iotdb/db/sql/node1/OneNodeClusterIT.java
 copy testcontainer/src/test/java/org/apache/iotdb/db/sql/{ClusterIT.java => nodes3/AbstractThreeNodeClusterIT.java} (58%)
 copy server/src/main/java/org/apache/iotdb/db/engine/merge/selector/MergeFileStrategy.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes3/ThreeNodeCluster1IT.java (83%)
 copy server/src/main/java/org/apache/iotdb/db/exception/UDFRegistrationException.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes3/ThreeNodeCluster2IT.java (68%)
 copy testcontainer/src/test/java/org/apache/iotdb/db/sql/{ClusterIT.java => nodes5/AbstractFiveNodeClusterIT.java} (54%)
 copy server/src/main/java/org/apache/iotdb/db/engine/merge/selector/MergeFileStrategy.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster1IT.java (82%)
 copy server/src/main/java/org/apache/iotdb/db/exception/LoadFileException.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster2IT.java (67%)
 copy server/src/main/java/org/apache/iotdb/db/exception/LoadFileException.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster4IT.java (66%)