This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch xingtanzjr/fix_schema_fetch
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d2ebc57132 add comments
add 3c78969fea Revert "[IOTDB-3390] Serialize ConfigNode expansion
(#6256)" (#6266)
add 9da5ad5281 [IOTDB-3463] IT framework supports read and compare from
multi data nodes (#6271)
add a93728770f IOTDB-3481 Optimize Log Print (#6273)
add c4b22f26ac [IOTDB-3477] Send two phase message to ConfigNode when
starting DataNode (#6269)
add babb62a355 [IOTDB-3416] Abstract interface of ConfigTask Execution for
standalone IoTDB (#6260)
add d7cf590774 [IOTDB-3384] fix run length tsblock serde (#6270)
new f56314d85a Merge branch 'master' into xingtanzjr/fix_schema_fetch
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/cluster-it.yml | 14 +-
.../resources/conf/iotdb-confignode.properties | 6 -
...lientPool.java => AsyncDataNodeClientPool.java} | 12 +-
...ientPool.java => SyncConfigNodeClientPool.java} | 55 +-
...ClientPool.java => SyncDataNodeClientPool.java} | 12 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 28 +-
.../confignode/conf/ConfigNodeDescriptor.java | 9 -
.../confignode/conf/ConfigNodeStartupCheck.java | 100 +-
.../consensus/request/ConfigRequest.java | 6 +-
.../consensus/request/ConfigRequestType.java | 2 +-
...rConfigNodeReq.java => ApplyConfigNodeReq.java} | 12 +-
.../iotdb/confignode/manager/ConfigManager.java | 97 +-
.../iotdb/confignode/manager/ConsensusManager.java | 38 +-
.../apache/iotdb/confignode/manager/Manager.java | 8 +
.../iotdb/confignode/manager/NodeManager.java | 190 ++-
.../iotdb/confignode/manager/PartitionManager.java | 4 +-
.../confignode/manager/PermissionManager.java | 4 +-
.../iotdb/confignode/manager/UDFManager.java | 6 +-
.../iotdb/confignode/manager/load/LoadManager.java | 6 +-
.../iotdb/confignode/persistence/NodeInfo.java | 12 +-
.../executor/ConfigRequestExecutor.java | 6 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 6 +-
.../iotdb/confignode/service/ConfigNode.java | 10 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 23 +-
.../consensus/request/ConfigRequestSerDeTest.java | 10 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 5 +-
integration-test/README.md | 27 +-
.../org/apache/iotdb/it/env/ClusterEnvBase.java | 111 +-
.../java/org/apache/iotdb/it/env/ConfigNode.java | 15 +-
.../java/org/apache/iotdb/it/env/DataNode.java | 13 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +
.../itbase/runtime/ClusterResultSetMetaData.java | 239 ++++
.../itbase/runtime/ClusterTestConnection.java | 333 ++++++
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 1230 ++++++++++++++++++++
.../iotdb/itbase/runtime/ClusterTestStatement.java | 297 +++++
.../itbase/runtime/InconsistentDataException.java | 11 +-
.../iotdb/itbase/runtime/NodeConnection.java | 85 ++
.../itbase/runtime/ParallelRequestDelegate.java | 60 +
.../iotdb/itbase/runtime/RequestDelegate.java | 86 ++
.../iotdb/itbase/runtime/RequestThreadPool.java | 32 +-
.../itbase/runtime/SerialRequestDelegate.java | 34 +-
metrics/pom.xml | 41 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 22 +
.../apache/iotdb/db/auth/AuthorizerManager.java | 19 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 64 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 9 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 20 +-
...ConfigNodeClient.java => ConfigNodeClient.java} | 78 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 10 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 74 +-
.../execution/datatransfer/DataBlockManager.java | 108 +-
.../execution/datatransfer/LocalSinkHandle.java | 8 +-
.../execution/datatransfer/LocalSourceHandle.java | 46 +-
.../db/mpp/execution/datatransfer/SinkHandle.java | 36 +-
.../mpp/execution/datatransfer/SourceHandle.java | 134 +--
.../execution/schedule/AbstractDriverThread.java | 13 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 4 +-
.../mpp/execution/schedule/DriverTaskThread.java | 71 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 8 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 25 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 36 +-
.../db/mpp/plan/execution/QueryExecution.java | 24 +-
.../mpp/plan/execution/config/AuthorizerTask.java | 67 +-
.../mpp/plan/execution/config/ConfigExecution.java | 27 +-
.../execution/config/CountStorageGroupTask.java | 52 +-
.../plan/execution/config/CreateFunctionTask.java | 75 +-
.../execution/config/DeleteStorageGroupTask.java | 70 +-
.../plan/execution/config/DropFunctionTask.java | 66 +-
.../db/mpp/plan/execution/config/FlushTask.java | 42 +-
.../db/mpp/plan/execution/config/IConfigTask.java | 7 +-
.../plan/execution/config/SetStorageGroupTask.java | 68 +-
.../db/mpp/plan/execution/config/SetTTLTask.java | 58 +-
.../mpp/plan/execution/config/ShowClusterTask.java | 66 +-
.../plan/execution/config/ShowFunctionsTask.java | 7 +-
.../execution/config/ShowStorageGroupTask.java | 65 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 86 +-
.../config/executor/ClusterConfigTaskExecutor.java | 328 ++++++
.../config/executor/IConfigTaskExecutor.java | 61 +
.../executor/StandsloneConfigTaskExecutor.java | 265 +++++
.../db/mpp/plan/scheduler/ClusterScheduler.java | 12 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 26 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 83 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 41 +-
.../db/mpp/execution/ConfigExecutionTest.java | 7 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 7 +-
.../src/main/thrift/confignode.thrift | 54 +-
.../block/column/BinaryArrayColumnEncoder.java | 5 +-
.../block/column/ByteArrayColumnEncoder.java | 5 +-
.../read/common/block/column/ColumnEncoder.java | 9 +-
.../common/block/column/ColumnEncoderFactory.java | 3 +-
.../read/common/block/column/ColumnEncoding.java | 6 +-
.../block/column/Int32ArrayColumnEncoder.java | 8 +-
.../block/column/Int64ArrayColumnEncoder.java | 21 +-
.../block/column/RunLengthColumnEncoder.java | 54 +
.../block/column/RunLengthEncodedColumn.java | 2 +-
.../read/common/block/column/TsBlockSerde.java | 19 +-
.../common/block/BinaryArrayColumnEncoderTest.java | 8 +-
.../common/block/ByteArrayColumnEncoderTest.java | 9 +-
.../common/block/Int32ArrayColumnEncoderTest.java | 15 +-
.../common/block/Int64ArrayColumnEncoderTest.java | 17 +-
...erTest.java => RunLengthColumnEncoderTest.java} | 75 +-
101 files changed, 4349 insertions(+), 1653 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/{AsyncConfigNodeToDataNodeClientPool.java
=> AsyncDataNodeClientPool.java} (96%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/{SyncConfigNodeToConfigNodeClientPool.java
=> SyncConfigNodeClientPool.java} (65%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/{SyncConfigNodeToDataNodeClientPool.java
=> SyncDataNodeClientPool.java} (94%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{RegisterConfigNodeReq.java
=> ApplyConfigNodeReq.java} (85%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterResultSetMetaData.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestConnection.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestStatement.java
copy jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBURLException.java =>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/InconsistentDataException.java
(74%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/NodeConnection.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ParallelRequestDelegate.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestDelegate.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/SignalBatchData.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestThreadPool.java
(55%)
copy
server/src/main/java/org/apache/iotdb/db/query/externalsort/ExternalSortJob.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/SerialRequestDelegate.java
(54%)
rename
server/src/main/java/org/apache/iotdb/db/client/{DataNodeToConfigNodeClient.java
=> ConfigNodeClient.java} (89%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/IConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandsloneConfigTaskExecutor.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/RunLengthColumnEncoder.java
copy
tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/{BinaryArrayColumnEncoderTest.java
=> RunLengthColumnEncoderTest.java} (53%)
