This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch auth in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit abe117461dc7503159e94cd46c949928f1dc154b Merge: e1de60e268b d1c0cf9050c Author: JackieTien97 <[email protected]> AuthorDate: Sat Sep 2 08:35:13 2023 +0800 Merge remote-tracking branch 'origin/master' into auth .github/workflows/client-python.yml | 3 + .gitignore | 9 +- .../iotdb/it/env/cluster/env/AbstractEnv.java | 40 +++++-- .../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 27 ----- .../it/cluster/IoTDBClusterRestartIT.java | 29 ++++- .../confignode/it/utils/ConfigNodeTestUtils.java | 7 -- iotdb-client/client-py/.gitignore | 2 + iotdb-client/client-py/SessionPoolExample.py | 21 ++-- iotdb-client/client-py/iotdb/IoTDBContainer.py | 9 +- iotdb-client/client-py/iotdb/SessionPool.py | 60 +++++++--- iotdb-client/client-py/pom.xml | 62 +++++++++- iotdb-client/client-py/release.sh | 19 +-- iotdb-client/client-py/requirements_dev.txt | 2 +- iotdb-client/client-py/{ => resources}/setup.py | 2 +- iotdb-client/client-py/tests/test_session.py | 60 +++++----- iotdb-client/client-py/tests/test_session_pool.py | 33 +++++- .../client/sync/SyncConfigNodeClientPool.java | 3 - .../confignode/conf/SystemPropertiesUtils.java | 4 +- .../statemachine/ConfigRegionStateMachine.java | 56 ++++----- .../iotdb/confignode/manager/ConfigManager.java | 23 ---- .../apache/iotdb/confignode/manager/IManager.java | 3 - .../manager/consensus/ConsensusManager.java | 25 ++-- .../iotdb/confignode/manager/cq/CQManager.java | 9 -- .../iotdb/confignode/service/ConfigNode.java | 54 ++------- .../thrift/ConfigNodeRPCServiceProcessor.java | 11 -- .../org/apache/iotdb/consensus/IStateMachine.java | 5 + .../apache/iotdb/consensus/config/RatisConfig.java | 48 +++++++- .../ratis/ApplicationStateMachineProxy.java | 5 + .../apache/iotdb/consensus/ratis/utils/Utils.java | 3 + .../simple/SimpleConsensusServerImpl.java | 1 + .../apache/iotdb/consensus/iot/ReplicateTest.java | 129 ++++++++++++--------- .../assembly/resources/conf/logback-datanode.xml | 40 +++---- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 3 +- .../config/constant/PipeConnectorConstant.java | 4 +- .../db/pipe/connector/protocol/IoTDBConnector.java | 7 +- .../protocol/airgap/IoTDBAirGapConnector.java | 4 +- .../thrift/async/IoTDBThriftAsyncConnector.java | 4 +- .../thrift/sync/IoTDBThriftSyncConnector.java | 4 +- .../apache/iotdb/db/pipe/event/EnrichedEvent.java | 9 +- .../common/tablet/PipeRawTabletInsertionEvent.java | 2 +- .../common/tsfile/PipeTsFileInsertionEvent.java | 5 + .../realtime/epoch/TsFileEpochManager.java | 6 +- .../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +- .../db/protocol/rest/utils/InsertRowDataUtils.java | 105 +++++++++++++++++ .../rest/v1/handler/RequestValidationHandler.java | 12 ++ .../v1/handler/StatementConstructionHandler.java | 60 +++++++++- .../protocol/rest/v1/impl/RestApiServiceImpl.java | 47 ++++++++ .../rest/v2/handler/RequestValidationHandler.java | 12 ++ .../v2/handler/StatementConstructionHandler.java | 61 +++++++++- .../protocol/rest/v2/impl/RestApiServiceImpl.java | 47 ++++++++ .../impl/DataNodeInternalRPCServiceImpl.java | 4 + .../analyze/schema/ClusterSchemaFetchExecutor.java | 14 ++- .../dataregion/memtable/TsFileProcessor.java | 3 +- .../storageengine/dataregion/wal/node/WALNode.java | 25 ++-- .../src/test/resources/datanode1conf/logback.xml | 40 +++---- .../src/test/resources/datanode2conf/logback.xml | 40 +++---- .../src/test/resources/datanode3conf/logback.xml | 40 +++---- .../openapi/src/main/openapi3/iotdb_rest_v1.yaml | 52 +++++++++ .../openapi/src/main/openapi3/iotdb_rest_v2.yaml | 52 +++++++++ .../src/main/thrift/confignode.thrift | 14 --- 60 files changed, 1029 insertions(+), 460 deletions(-)
