This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a change to branch kyy
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 484bde7 fix sonar
add 44c9e49 [IOTDB-759] Refactor MNode by removing InternalMNode (#1345)
add 63d2ca2 add audit log (#1373)
add 7a4efd7 Merge branch 'master' into cluster_premerge2
add b574234 Merge branch 'cluster_premerge2' into cluster_new
add 9fb5b7d fix
add 69c9e14 add log and fix NonPartitionedDataPlan
add ac56578 [IOTDB-722] support three consistency levels: strong, mid and
weak
add 90a4bfe [IOTDB-722] add some tests
add abf0cbc Merge pull request #1380 from neuyilan/cluster_new_IOTDB-722
add decd8a3 fix all invalidate urls that contains /#/Document (#1383)
add b4e0981 [IOTDB-761]cherry-picked from v0.10: flink-tsfile-connecto
and flink-example dependency conflict: "Some Enforcer rules have failed. Look
above for specific messages explaining why the rule failed" (#1365)
add 9a07a1b Merge branch 'master' into cluster_new
add 4df949c add cluster inserttablet
add d8fe5bc Merge pull request #1385 from
LebronAl/cluster_new_add_cluster_inserttablet
add b147838 add comment
add e42bbfe Fix spark tsfile master (#1389)
add 209c66c Add force stop storage engine interface (#1289)
add 5fe7fd4 use pom.xml's version as IoTDB server and CLI's version
(#1363)
add 29728c0 [IOTDB-777]Missing dot between deviceId and sensorId in
chunkMetadataCache
add 856e7d2 add slides
add c89b02e change construct
add a7dd34b anchor link the documentation navigation of the readme.
add 6febf2d 国语版
add c4f3f20 fix the iindentation of both languages readme
add b39a23d add partialInsert for insertTablets (#1395)
add ccc627a make SessionDataSetWrapper (#1398)
add 0c8c700 Merge branch 'master' into cluster_premerge2
add e8229c9 Merge branch 'cluster_premerge2' into cluster_new
add 9b730c7 fix tablet serialization
add edd555a fix boolean batch serialization (#1403)
add bab16bf Merge branch 'master' into cluster_new
add 8ea91ee fix conflict
No new revisions were added by this update.
Summary of changes:
README.md | 48 +++--
README_ZH.md | 50 +++--
cli/pom.xml | 6 +
.../resources/conf/iotdb-cluster.properties | 8 +
.../java/org/apache/iotdb/cluster/ClientMain.java | 6 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 22 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 5 +
.../iotdb/cluster/config/ConsistencyLevel.java | 69 ++++++
...ception.java => CheckConsistencyException.java} | 14 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 31 ++-
.../iotdb/cluster/log/applier/DataLogApplier.java | 7 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 194 +++++++++++++----
.../iotdb/cluster/query/ClusterPlanRouter.java | 3 +-
.../query/last/ClusterLastQueryExecutor.java | 17 +-
.../iotdb/cluster/server/DataClusterServer.java | 9 +-
.../cluster/server/member/DataGroupMember.java | 189 ++++++++++------
.../cluster/server/member/MetaGroupMember.java | 237 +++++++++++++++++----
.../iotdb/cluster/server/member/RaftMember.java | 44 +++-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 22 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 4 +-
.../cluster/log/applier/DataLogApplierTest.java | 17 +-
.../iotdb/cluster/server/member/MemberTest.java | 126 ++++++++++-
docs/Community/Materials.md | 12 ++
docs/SystemDesign/Connector/Spark-TsFile.md | 22 +-
docs/UserGuide/Client/Status Codes.md | 2 +
.../DML Data Manipulation Language.md | 4 +-
.../System Tools/Monitor and Log Tools.md | 2 +-
docs/zh/SystemDesign/Connector/Spark-TsFile.md | 16 ++
docs/zh/UserGuide/Client/Status Codes.md | 2 +
example/flink/pom.xml | 8 +
example/rocketmq/readme.md | 2 +-
flink-tsfile-connector/pom.xml | 23 ++
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 11 +-
pom.xml | 6 +
server/pom.xml | 6 +
server/src/assembly/resources/conf/logback.xml | 21 ++
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 1 -
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 7 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 30 ++-
.../iotdb/db/engine/cache/ChunkMetadataCache.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 6 +-
.../iotdb/db/engine/merge/task/MergeTask.java | 11 +-
.../engine/storagegroup/StorageGroupProcessor.java | 40 +++-
.../db/engine/storagegroup/TsFileProcessor.java | 12 ++
...cessorException.java => ShutdownException.java} | 21 +-
.../org/apache/iotdb/db/metadata/MManager.java | 17 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 32 +--
.../apache/iotdb/db/metadata/MetadataConstant.java | 11 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 135 ------------
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 137 ++++++++++--
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 77 ++++++-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 22 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 132 +++++++-----
.../db/qp/physical/crud/InsertTabletPlan.java | 136 +++++++++---
.../java/org/apache/iotdb/db/service/IService.java | 3 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 8 +
.../apache/iotdb/db/service/RegisterManager.java | 15 ++
.../org/apache/iotdb/db/service/TSServiceImpl.java | 34 ++-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 3 +
.../writelog/manager/MultiFileLogNodeManager.java | 57 ++---
.../iotdb/db/writelog/node/WriteLogNode.java | 1 +
...BRecoverIT.java => IoTDBRecoverUnclosedIT.java} | 87 ++------
.../iotdb/db/integration/IoTDBRestartIT.java | 148 ++++++++++++-
.../iotdb/db/metadata/MManagerImproveTest.java | 5 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 40 ++--
.../apache/iotdb/db/utils/EnvironmentUtils.java | 10 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 37 ++++
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 ++
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
.../iotdb/session/pool/SessionDataSetWrapper.java | 9 +-
.../java/org/apache/iotdb/session/SessionUT.java | 83 +++++++-
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 13 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 21 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 12 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 14 +-
76 files changed, 1987 insertions(+), 724 deletions(-)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/config/ConsistencyLevel.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/{NoHeaderNodeException.java
=> CheckConsistencyException.java} (64%)
copy
server/src/main/java/org/apache/iotdb/db/exception/{TsFileProcessorException.java
=> ShutdownException.java} (61%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/InternalMNode.java
copy server/src/test/java/org/apache/iotdb/db/integration/{IoTDBRecoverIT.java
=> IoTDBRecoverUnclosedIT.java} (80%)
