This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch test_ratis_0623
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7b6e5c83a8 spotless
add cbc5e42d68 [IOTDB-3571] Add IT for UDTF Non Align (#6356)
add a59c4c806d [IOTDB-3349] Operator should not call child.next() twice in
one itself next call (#6203)
add 2e9cfd4bde [IOTDB-3547] AddConfigNode support procedure (#6350)
add 70f6d6fe37 [IOTDB-3467] Add IT for Nested Expressions (#6385)
add ff996f9098 [IOTDB-3484] Modify user docs about how to use udf api
(#6387)
add 074b37f5fe [IOTDB-3558] Dump node stacks if IT test request timeout
(#6382)
add 346ed83119 delete tsfiles when recovering data region (#6388)
add a3352882f1 delete file before recovery in ratis mode (#6390)
add f24722a9a6 [IOTDB-3386] Avoid the double-write problem of raftlog and
write-ahead log at the Datanode consensus layer (#6366)
add 3b1b4303be Fix DataTypeMismatchException npe (#6392)
add 0cc7887341 Fix Source Handle Bug (#6386)
add 9540c88be1 [IOTDB-3601] Fix error when query data from empty series on
new standalone iotdb (#6383)
add cb77e2ce22 Ratis Raftlog SegmentSize -> 24Mb (#6398)
add cb283d658a [IOTDB-3604] Refactor the time zone setter by using the
setClientInfo method of JDBC (#6384)
add a2436515e0 [IOTDB-3428] Linear expanse RegionGroup(simple version)
(#6325)
add 19fff1d5d7 [IOTDB-3632] Add log for snapshot taker and loader (#6401)
new ed314291fe Merge branch 'master' into test_ratis_0623
new 72ec12b7c2 revert some test changes
The 2 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:
.../confignode/client/AsyncDataNodeClientPool.java | 10 +-
.../client/SyncConfigNodeClientPool.java | 15 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 28 +-
.../consensus/request/ConfigRequest.java | 6 +-
.../consensus/request/ConfigRequestType.java | 3 +-
.../write/AdjustMaxRegionGroupCountReq.java | 89 ++
.../consensus/request/write/CreateRegionsReq.java | 28 +-
.../confignode/manager/ClusterSchemaManager.java | 147 ++-
.../iotdb/confignode/manager/ConfigManager.java | 25 +-
.../iotdb/confignode/manager/ConsensusManager.java | 78 +-
.../apache/iotdb/confignode/manager/Manager.java | 6 +-
.../iotdb/confignode/manager/NodeManager.java | 11 +-
.../iotdb/confignode/manager/PartitionManager.java | 222 ++--
.../iotdb/confignode/manager/ProcedureManager.java | 15 +-
.../iotdb/confignode/manager/load/LoadManager.java | 28 +-
.../manager/load/balancer/RegionBalancer.java | 19 +-
.../confignode/persistence/ClusterSchemaInfo.java | 171 ++-
.../executor/ConfigRequestExecutor.java | 7 +-
.../persistence/partition/PartitionInfo.java | 39 +-
.../persistence/partition/RegionGroup.java | 11 +-
.../partition/StorageGroupPartitionTable.java | 42 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 43 +-
.../procedure/impl/AddConfigNodeProcedure.java | 188 +++
.../impl/DeleteStorageGroupProcedure.java | 3 +-
...edureLockState.java => AddConfigNodeState.java} | 8 +-
.../procedure/store/ProcedureFactory.java | 9 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 17 +-
.../consensus/request/ConfigRequestSerDeTest.java | 18 +-
.../confignode/persistence/PartitionInfoTest.java | 20 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 6 +-
.../ratis/ApplicationStateMachineProxy.java | 63 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +-
docs/Download/README.md | 1 +
.../Process-Data/UDF-User-Defined-Function.md | 58 +-
docs/zh/Download/README.md | 1 +
.../Process-Data/UDF-User-Defined-Function.md | 61 +-
integration-test/pom.xml | 2 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 145 ++-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 223 ++--
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 49 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 35 +-
.../org/apache/iotdb/it/env/IoTDBTestRunner.java | 2 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 7 +-
.../iotdb/it/env/StandaloneDataNodeWrapper.java | 5 +-
.../apache/iotdb/it/env/StandaloneOnMppEnv.java | 34 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 4 +
.../itbase/runtime/InconsistentDataException.java | 2 +-
.../itbase/runtime/ParallelRequestDelegate.java | 3 +
.../iotdb/itbase/runtime/RequestDelegate.java | 5 +-
.../iotdb/db/it}/IoTDBCreateTimeseriesIT.java | 153 +--
.../apache/iotdb/db/it}/IoTDBNestedQueryIT.java | 283 ++---
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1274 ++++++++++----------
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 6 +-
.../iotdb/db/it/udf}/IoTDBUDTFNonAlignQueryIT.java | 71 +-
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 9 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 1038 ----------------
.../main/java/org/apache/iotdb/jdbc/Config.java | 3 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 23 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 12 +
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 14 +
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 12 +
.../commons/udf/service/UDFClassLoaderManager.java | 4 +-
server/src/assembly/resources/conf/logback.xml | 1 -
.../src/assembly/resources/sbin/stop-datanode.sh | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 4 +-
.../db/conf/directories/DirectoryManager.java | 6 +
.../db/consensus/DataRegionConsensusImpl.java | 9 +
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 7 +
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 6 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 25 +-
.../metadata/DataTypeMismatchException.java | 8 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 33 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 28 +-
.../execution/datatransfer/LocalSourceHandle.java | 7 +
.../mpp/execution/datatransfer/SourceHandle.java | 6 +-
.../operator/process/DeviceMergeOperator.java | 3 +
.../operator/process/DeviceViewOperator.java | 3 +
.../execution/operator/process/FilterOperator.java | 121 +-
.../process/RawDataAggregationOperator.java | 12 +-
.../operator/process/TransformOperator.java | 130 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +-
.../mpp/plan/statement/literal/BooleanLiteral.java | 8 +-
.../mpp/plan/statement/literal/DoubleLiteral.java | 6 +
.../db/mpp/plan/statement/literal/LongLiteral.java | 6 +
.../db/mpp/plan/statement/literal/NullLiteral.java | 6 +
.../mpp/transformation/api/LayerPointReader.java | 2 +-
.../db/mpp/transformation/api/LayerRowReader.java | 2 +-
.../transformation/api/LayerRowWindowReader.java | 2 +-
.../db/mpp/transformation/api/YieldableReader.java | 11 +-
.../db/mpp/transformation/api/YieldableState.java | 8 +-
.../dag/input/ConstantInputReader.java | 8 +-
.../dag/input}/IUDFInputDataSet.java | 10 +-
.../dag/input/QueryDataSetInputLayer.java | 70 +-
.../dag/input/TsBlockInputDataSet.java | 37 +-
.../MultiInputColumnIntermediateLayer.java | 355 +++++-
...InputColumnMultiReferenceIntermediateLayer.java | 142 +++
...nputColumnSingleReferenceIntermediateLayer.java | 158 ++-
.../dag/transformer/Transformer.java | 19 +
.../dag/transformer/binary/BinaryTransformer.java | 71 ++
.../transformer/binary/LogicBinaryTransformer.java | 34 +
.../transformer/multi/UDFQueryRowTransformer.java | 15 +
.../multi/UDFQueryRowWindowTransformer.java | 12 +
.../dag/transformer/multi/UDFQueryTransformer.java | 21 +-
.../dag/transformer/unary/UnaryTransformer.java | 22 +
.../mpp/transformation/dag/util/InputRowUtils.java | 2 +-
.../transformation/dag/util/LayerCacheUtils.java | 88 +-
.../tv/ElasticSerializableTVList.java | 6 +
.../dataset/RawQueryDataSetWithValueFilter.java | 1 +
.../iotdb/db/query/dataset/UDFInputDataSet.java | 1 +
.../UDFRawQueryInputDataSetWithoutValueFilter.java | 1 +
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 1 +
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 1 +
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 9 +
.../src/main/thrift/confignode.thrift | 6 +-
115 files changed, 3659 insertions(+), 2816 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/AdjustMaxRegionGroupCountReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/AddConfigNodeProcedure.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{ProcedureLockState.java
=> AddConfigNodeState.java} (90%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBCreateTimeseriesIT.java
(64%)
copy {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBNestedQueryIT.java
(71%)
copy {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it/udf}/IoTDBUDTFNonAlignQueryIT.java
(89%)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFBuiltinFunctionIT.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/timegenerator/node/Node.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/transformation/api/YieldableReader.java
(79%)
copy cluster/src/test/java/org/apache/iotdb/cluster/utils/Constants.java =>
server/src/main/java/org/apache/iotdb/db/mpp/transformation/api/YieldableState.java
(83%)
rename server/src/main/java/org/apache/iotdb/db/{query/dataset =>
mpp/transformation/dag/input}/IUDFInputDataSet.java (79%)
