This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch consensus_module_refactor
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f5ddf384397 build success
add 44d6bec0f39 Pipe IT: Changed IoTDBPipeDemoIT timeout to 10 mins to
allow pipe-internal retries when unstable cases occuring (#10867)
add 16a9f3fe760 Bump
com.googlecode.maven-download-plugin:download-maven-plugin (#10747)
add 89645c6889f Delete useless airline, concurrent-200 and jaxb-runtime
dependencies (#10866)
add 3e9ddc77c86 Pipe IT: fix the usage of Awaitility.awit (#10869)
add b445540475a [IOTDB-6116] Disassociate the IoTConsensus retry logic
from the forkjoinPool (#10872)
add 679c495b043 [RatisConsensus] Unify read timeout to Thrift connection
timeout (#10876)
add 9acb3594a18 Fix Region migrate bug (#10862)
add 80f9a80e50f [IOTDB-6118] Pipe: Support transfer data through air gap
(IoTDBAirGapConnector) (#10853)
add 0a90c45486d Pipe IT: Stablelized pipe IT by prohibiting exceptions
from assertEqual function (#10881)
add 0b28f31379d fix dataMigrationExample error (#10886)
add 6bef0b0b232 fix: Hopefully fixed the build of the cpp-example on
windows systems (#10891)
add 709e7ef8694 Upgrade guava to avoid vulnerability issue (#10892)
add 052ff28cf89 Override existing jar instead of deleting it when
registering UDF
add 97e083efcec [IOTDB-6115] Fix Limit & Offset push down doesn't take
effect while there exist null value
add a45248d4959 Rename iotdb-thrift module to iotdb-thrift-datanode
(#10884)
add 6a669f8d809 Merge remote-tracking branch 'origin' into
consensus_module_refactor
No new revisions were added by this update.
Summary of changes:
CONTRIBUTING.md | 2 +-
LICENSE-binary | 6 +-
example/client-cpp-example/src/CMakeLists.txt | 10 +-
.../src/main/java/org/apache/iotdb/SSLClient.java | 2 +-
.../org/apache/iotdb/DataMigrationExample.java | 3 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 1 +
.../IoTDBAutoRegionGroupExtensionIT2.java | 160 +++++++++++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 84 +++---
...TDBPipeDemoIT.java => IoTDBPipeDataSyncIT.java} | 34 +--
...leDemoIT.java => IoTDBPipeSingleEnvDemoIT.java} | 2 +-
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-py/pom.xml | 2 +-
.../manager/consensus/ConsensusManager.java | 11 +
.../region/GreedyRegionGroupAllocator.java | 41 ++-
.../load/cache/node/DataNodeHeartbeatCache.java | 4 +-
.../load/cache/region/RegionHeartbeatSample.java | 5 +
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/RegionGroup.java | 11 +
.../procedure/env/ConfigNodeProcedureEnv.java | 11 +
.../procedure/env/DataNodeRemoveHandler.java | 7 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 17 ++
.../consensus/iot/IoTConsensusServerImpl.java | 8 +
.../consensus/iot/client/DispatchLogHandler.java | 52 ++--
.../consensus/iot/logdispatcher/LogDispatcher.java | 4 +
.../iotdb/consensus/ratis/RatisConsensus.java | 7 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 +-
iotdb-core/datanode/pom.xml | 14 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 +-
.../db/consensus/DataRegionConsensusImpl.java | 7 +
.../db/consensus/SchemaRegionConsensusImpl.java | 7 +
.../db/pipe/agent/receiver/PipeReceiverAgent.java | 70 ++---
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 6 +-
.../config/constant/PipeConnectorConstant.java | 4 +
.../payload/airgap/AirGapOneByteResponse.java | 7 +-
.../airgap/AirGapPseudoTPipeTransferRequest.java | 7 +-
.../request/PipeTransferFilePieceReq.java | 22 +-
.../evolvable/request/PipeTransferFileSealReq.java | 22 +-
.../request/PipeTransferHandshakeReq.java | 20 +-
.../request/PipeTransferInsertNodeReq.java | 24 +-
.../evolvable/request/PipeTransferTabletReq.java | 111 ++++----
...TDBThriftConnector.java => IoTDBConnector.java} | 6 +-
...sion.java => IoTDBConnectorRequestVersion.java} | 6 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 315 ++++++++++++++++++++-
.../thrift/async/IoTDBThriftAsyncConnector.java | 9 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 33 ++-
.../pipe/receiver/airgap/IoTDBAirGapReceiver.java | 180 +++++++++++-
.../receiver/airgap/IoTDBAirGapReceiverAgent.java | 97 +++++++
...iver.java => IoTDBLegacyPipeReceiverAgent.java} | 20 +-
.../pipe/receiver/thrift/IoTDBThriftReceiver.java | 4 +-
.../thrift/IoTDBThriftReceiverAgent.java} | 38 +--
.../receiver/thrift/IoTDBThriftReceiverV1.java | 22 +-
.../connector/PipeConnectorSubtaskManager.java | 4 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 14 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 24 +-
.../operator/source/AlignedSeriesScanOperator.java | 9 +-
.../operator/source/AlignedSeriesScanUtil.java | 67 ++++-
.../db/queryengine/plan/analyze/Analysis.java | 12 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 1 +
.../db/queryengine/plan/parser/ASTVisitor.java | 8 +
.../plan/planner/LogicalPlanBuilder.java | 10 +-
.../plan/planner/LogicalPlanVisitor.java | 6 +-
.../plan/planner/OperatorTreeGenerator.java | 3 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 1 +
.../plan/node/source/AlignedSeriesScanNode.java | 37 ++-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/statement/crud/QueryStatement.java | 12 +
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../memtable/AlignedReadOnlyMemChunk.java | 12 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 13 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 11 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 8 +-
.../read/reader/chunk/MemAlignedPageReader.java | 31 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 16 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 19 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 43 ---
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 21 +-
.../operator/AlignedSeriesScanOperatorTest.java | 15 +-
.../execution/operator/OperatorMemoryTest.java | 3 +-
.../plan/plan/QueryLogicalPlanUtil.java | 5 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 2 +-
iotdb-core/mlnode/pom.xml | 2 +-
.../resources/conf/iotdb-common.properties | 7 +
.../iotdb/commons/concurrent/ThreadName.java | 8 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 19 ++
.../iotdb/commons/conf/CommonDescriptor.java | 11 +
.../commons/executable/ExecutableManager.java | 11 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 20 ++
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 2 +
...yncConnector.java => IoTDBAirGapConnector.java} | 6 +-
.../connector/IoTDBLegacyPipeConnector.java | 54 +---
.../builtin/connector/IoTDBThriftConnector.java | 54 +---
...ipeConnector.java => PlaceholderConnector.java} | 12 +-
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../read/TsFileAlignedSeriesReaderIterator.java | 2 +-
.../read/reader/chunk/AlignedChunkReader.java | 22 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 29 +-
.../read/reader/series/FileSeriesReader.java | 2 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 1 +
.../tsfile/write/TsFileIntegrityCheckingTool.java | 3 +-
iotdb-protocol/pom.xml | 2 +-
.../{thrift => thrift-datanode}/README.md | 0
iotdb-protocol/{thrift => thrift-datanode}/pom.xml | 4 +-
.../{thrift => thrift-datanode}/rpc-changelist.md | 0
.../src/main/thrift/client.thrift | 0
.../src/main/thrift/datanode.thrift | 0
pom.xml | 35 +--
107 files changed, 1630 insertions(+), 665 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBAutoRegionGroupExtensionIT2.java
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/{IoTDBPipeDemoIT.java
=> IoTDBPipeDataSyncIT.java} (81%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/{IoTDBPipeSingleDemoIT.java
=> IoTDBPipeSingleEnvDemoIT.java} (98%)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/configuration/PipeRuntimeConfiguration.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapOneByteResponse.java
(79%)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/configuration/PipeRuntimeConfiguration.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapPseudoTPipeTransferRequest.java
(80%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/{thrift/IoTDBThriftConnector.java
=> IoTDBConnector.java} (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/{thrift/IoTDBThriftConnectorRequestVersion.java
=> IoTDBConnectorRequestVersion.java} (85%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/airgap/IoTDBAirGapReceiverAgent.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/legacy/{IoTDBLegacyPipeReceiver.java
=> IoTDBLegacyPipeReceiverAgent.java} (96%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver/PipeReceiverAgent.java
=> receiver/thrift/IoTDBThriftReceiverAgent.java} (68%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftSyncConnector.java
=> IoTDBAirGapConnector.java} (88%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBLegacyPipeConnector.java
=> PlaceholderConnector.java} (86%)
rename iotdb-protocol/{thrift => thrift-datanode}/README.md (100%)
rename iotdb-protocol/{thrift => thrift-datanode}/pom.xml (96%)
rename iotdb-protocol/{thrift => thrift-datanode}/rpc-changelist.md (100%)
rename iotdb-protocol/{thrift =>
thrift-datanode}/src/main/thrift/client.thrift (100%)
rename iotdb-protocol/{thrift =>
thrift-datanode}/src/main/thrift/datanode.thrift (100%)
