This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch addIT
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7eb8257f53 replace delete timeseries
add cd75c50c38 add more tests
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)
add 16314af65a Add data Deletion IT and Insert IT for aligned time series
(#6259)
add b943041909 Merge branch 'master' into addIT
No new revisions were added by this update.
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 +-
integration-test/import-control.xml | 23 +-
.../org/apache/iotdb/it/env/ClusterEnvBase.java | 111 +-
.../org/apache/iotdb/it/env/ClusterEnvConfig.java | 11 +
.../java/org/apache/iotdb/it/env/ConfigNode.java | 16 +-
.../java/org/apache/iotdb/it/env/DataNode.java | 14 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 16 +
.../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 +-
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 8 +-
.../IoTDBAggregationWithoutValueFilterIT.java | 408 ---
...ggregationWithoutValueFilterWithDeletionIT.java | 16 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 2758 +++++++++++++++++++-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 113 +
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 114 +
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 71 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 286 ++
...2IT.java => IoTDBLastQueryWithDeletion2IT.java} | 11 +-
...heIT.java => IoTDBLastQueryWithDeletionIT.java} | 272 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 16 +-
...BLastQueryWithoutLastCacheWithDeletion2IT.java} | 17 +-
...DBLastQueryWithoutLastCacheWithDeletionIT.java} | 24 +-
...RawQueryWithoutValueFilterWithDeletion2IT.java} | 26 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 404 ++-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 16 +
.../integration/aligned/IoTDBAlignByDevice2IT.java | 67 -
.../integration/aligned/IoTDBAlignByDeviceIT.java | 1623 ------------
.../IoTDBGroupByQueryWithoutValueFilter2IT.java | 65 -
.../IoTDBGroupByQueryWithoutValueFilterIT.java | 1128 --------
.../aligned/IoTDBInsertAlignedValuesIT.java | 391 ---
.../aligned/IoTDBLastQueryWithDeletion2IT.java | 80 -
.../aligned/IoTDBLastQueryWithDeletionIT.java | 379 ---
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 85 -
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 383 ---
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 83 -
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 +-
130 files changed, 8122 insertions(+), 6776 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%)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAggregationWithoutValueFilterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBAggregationWithoutValueFilterWithDeletion2IT.java
=> IoTDBLastQueryWithDeletion2IT.java} (92%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCacheIT.java
=> IoTDBLastQueryWithDeletionIT.java} (51%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBAggregationWithoutValueFilterWithDeletion2IT.java
=> IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java} (87%)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBAggregationWithoutValueFilterWithDeletion2IT.java
=> IoTDBLastQueryWithoutLastCacheWithDeletionIT.java} (81%)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBAggregationWithoutValueFilter2IT.java
=> IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java} (72%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
(52%)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDevice2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDeviceIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBInsertAlignedValuesIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
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%)
