This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch test_wal_sync_pr
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a08741e9e7 fix multileader consensus test(part) && fix index in
logDisPatcher. (#6497)
add f3ce57b260 Delete searched files version (#6500)
No new revisions were added by this update.
Summary of changes:
client-cpp/README.md | 2 +-
client-cpp/pom.xml | 4 +-
client-cpp/src/main/Session.cpp | 4 +-
client-cpp/src/main/Session.h | 8 +-
client-py/iotdb/Session.py | 4 +-
client-py/iotdb/utils/IoTDBRpcDataSet.py | 2 +-
.../resources/conf/iotdb-confignode.properties | 40 +++++---
.../iotdb/confignode/conf/ConfigNodeConfig.java | 34 +++++--
.../confignode/conf/ConfigNodeDescriptor.java | 26 +++--
.../confignode/conf/ConfigNodeStartupCheck.java | 10 +-
.../confignode/manager/ClusterSchemaManager.java | 21 +++-
.../iotdb/confignode/manager/ConfigManager.java | 14 +++
.../service/thrift/ConfigNodeRPCService.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 4 +-
.../iotdb/confignode/cli/TemporaryClientDemo.java | 8 +-
.../confignode1conf/iotdb-confignode.properties | 2 +-
.../confignode2conf/iotdb-confignode.properties | 2 +-
.../confignode3conf/iotdb-confignode.properties | 2 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 2 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 12 ++-
docs/UserGuide/Cluster/Cluster-Setup.md | 4 +-
.../Reference/ConfigNode-Config-Manual.md | 4 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 4 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 8 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 4 +-
.../Reference/ConfigNode-Config-Manual.md | 4 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 4 +-
example/client-cpp-example/README.md | 2 +-
grafana-plugin/pkg/plugin/plugin.go | 4 +-
grafana-plugin/src/ConfigEditor.tsx | 1 +
grafana-plugin/src/QueryEditor.tsx | 52 +++++-----
grafana-plugin/src/datasource.ts | 2 +-
grafana-plugin/src/types.ts | 4 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 2 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 2 +-
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 6 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 16 +--
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 7 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 6 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 4 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 13 +--
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 4 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 4 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 4 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 4 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 2 +-
.../async/AsyncConfigNodeIServiceClient.java | 4 +-
.../async/AsyncDataNodeInternalServiceClient.java | 4 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 4 +-
.../sync/SyncDataNodeInternalServiceClient.java | 4 +-
.../iotdb/commons/client/ClientManagerTest.java | 4 +-
.../client/mock/MockInternalRPCService.java | 8 +-
.../resources/conf/iotdb-datanode.properties | 17 +++-
.../apache/iotdb/db/client/ConfigNodeClient.java | 9 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 +++-
.../db/consensus/DataRegionConsensusImpl.java | 93 ++++++++---------
.../db/consensus/SchemaRegionConsensusImpl.java | 50 ++++-----
.../db/mpp/execution/schedule/DriverScheduler.java | 12 ++-
...{InternalService.java => ClientRPCService.java} | 22 ++--
...erviceMBean.java => ClientRPCServiceMBean.java} | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 14 ++-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 6 +-
.../org/apache/iotdb/db/service/RPCService.java | 2 +-
.../db/service/thrift/ProcessorWithMetrics.java | 4 +-
...erviceImpl.java => DataNodeRPCServiceImpl.java} | 45 +++++----
...ServiceImpl.java => DataNodeTSServiceImpl.java} | 6 +-
.../db/service/thrift/impl/TSIEventHandler.java | 4 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 14 +--
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 7 +-
.../java/org/apache/iotdb/db/wal/io/WALWriter.java | 13 +++
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 112 +++++++++++++++------
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 22 ++--
.../schedule/DefaultDriverSchedulerTest.java | 5 +-
...ImplTest.java => ClientRPCServiceImplTest.java} | 18 ++--
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 28 +++---
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 6 +-
.../datanode1conf/iotdb-datanode.properties | 2 +-
.../datanode2conf/iotdb-datanode.properties | 2 +-
.../datanode3conf/iotdb-datanode.properties | 2 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 8 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 6 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 8 +-
.../org/apache/iotdb/rpc/SynchronizedHandler.java | 6 +-
.../apache/iotdb/session/SessionConnection.java | 10 +-
.../org/apache/iotdb/session/SessionDataSet.java | 6 +-
.../src/main/thrift/confignode.thrift | 6 +-
.../src/main/thrift/{rpc.thrift => client.thrift} | 2 +-
.../main/thrift/{mpp.thrift => datanode.thrift} | 8 +-
91 files changed, 615 insertions(+), 409 deletions(-)
rename server/src/main/java/org/apache/iotdb/db/service/{InternalService.java
=> ClientRPCService.java} (82%)
rename
server/src/main/java/org/apache/iotdb/db/service/{InternalServiceMBean.java =>
ClientRPCServiceMBean.java} (95%)
rename
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/{InternalServiceImpl.java
=> DataNodeRPCServiceImpl.java} (95%)
rename
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/{DataNodeTSIServiceImpl.java
=> DataNodeTSServiceImpl.java} (99%)
rename
server/src/test/java/org/apache/iotdb/db/service/{InternalServiceImplTest.java
=> ClientRPCServiceImplTest.java} (95%)
rename thrift/src/main/thrift/{rpc.thrift => client.thrift} (99%)
rename thrift/src/main/thrift/{mpp.thrift => datanode.thrift} (97%)
