This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch fix-log-throttling
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c58963919e4 spotless
add 5467513eaa2 Fix flaky multilevel priority queue test (#18013)
add 8ca049d8b8c Fix/unconsensus tsfile mods (#18008)
add 15dba18b1c7 Fix aggregation metric recording (#18018)
add 2fc89d07d08 C++ client: build with OpenSSL 3.x by default and bundle
the runtime … (#17987)
add 797dfa5d5cf Pipe: isolate async sink client resources by endpoint
(#18015)
add 4d05a851ef5 Limit concurrent load tsfile type conversions (#18014)
add 1d893f1d197 Support unified pipe pattern inclusion keys (#18016)
add c98bc5a0327 Use MinFolderOccupiedSpaceFirstStrategy for IoTConsensus
recv and all… (#18020)
add ced3908f07e Reduce IoTConsensus snapshot transmission memory and log
overhead (#18019)
add 5d8f3ef0e08 Merge origin/master into fix-log-throttling
No new revisions were added by this update.
Summary of changes:
.github/scripts/package-client-cpp-manylinux228.sh | 13 +
.github/workflows/client-cpp-package.yml | 18 +-
.github/workflows/multi-language-client.yml | 15 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 37 ++
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 2 -
.../it/env/remote/config/RemoteDataNodeConfig.java | 27 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 12 +
...TDBRegionMigrateWithDeletionMultiDataDirIT.java | 182 ++++++
...gionMigrateWithDeletionMultiDataDirTableIT.java | 185 ++++++
.../iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java | 226 ++++++++
iotdb-client/client-cpp/CMakeLists.txt | 27 +-
iotdb-client/client-cpp/README.md | 53 +-
iotdb-client/client-cpp/README_zh.md | 8 +-
.../client-cpp/cmake/FetchBuildTools.cmake | 17 +-
iotdb-client/client-cpp/cmake/FetchOpenSSL.cmake | 58 +-
iotdb-client/client-cpp/cmake/FetchThrift.cmake | 21 +-
.../client-cpp/cmake/InstallOpenSSLRuntime.cmake | 121 ++++
iotdb-client/client-cpp/examples/CMakeLists.txt | 35 ++
iotdb-client/client-cpp/examples/README.md | 2 +-
iotdb-client/client-cpp/examples/README_zh.md | 2 +-
iotdb-client/client-cpp/pom.xml | 4 +-
.../client-cpp/src/assembly/client-cpp.xml | 2 +
.../package-metadata/third_party/DEPENDENCIES.md | 25 +-
.../assembly/package-metadata/third_party/NOTICE | 34 ++
.../third_party/licenses/LICENSE-Boost-1.0 | 23 +
iotdb-client/client-cpp/third-party/README.md | 6 +-
.../execution/operator/CommonOperatorContext.java | 15 +
.../aggregation/AggregationOperator.java | 15 +-
.../relational/aggregation/TableAggregator.java | 49 +-
.../grouped/StreamingAggregationOperator.java | 9 +-
.../builder/InMemoryHashAggregationBuilder.java | 9 +-
.../iotdb/calc/metric/QueryExecutionMetricSet.java | 15 +-
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 23 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 5 +
.../consensus/iot/IoTConsensusServerImpl.java | 143 +++--
.../iot/snapshot/SnapshotFragmentReader.java | 14 +-
.../iot/snapshot/SnapshotFragmentReaderTest.java | 97 ++++
.../iotdb/db/i18n/StorageEngineMessages.java | 4 +
.../iotdb/db/i18n/StorageEngineMessages.java | 4 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 17 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 9 +-
.../db/consensus/DataRegionConsensusImpl.java | 6 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +
.../client/IoTDBDataNodeAsyncClientManager.java | 48 +-
.../source/dataregion/IoTDBDataRegionSource.java | 4 +
.../execution/aggregation/TreeAggregator.java | 92 ++-
.../fragment/FragmentInstanceContext.java | 52 ++
.../execution/operator/OperatorContext.java | 27 +
.../operator/process/AggregationOperator.java | 25 +-
.../process/RawDataAggregationOperator.java | 129 +++--
.../operator/process/TagAggregationOperator.java | 15 +-
.../AbstractSeriesAggregationScanOperator.java | 26 +-
.../relational/AbstractAggTableScanOperator.java | 85 +--
.../dataregion/snapshot/SnapshotLoader.java | 31 +-
.../active/ActiveLoadFailedMessageHandler.java | 17 +
.../load/active/ActiveLoadTsFileLoader.java | 2 +-
...ertedInsertTabletStatementExceptionVisitor.java | 9 +-
...ertedInsertTabletStatementExceptionVisitor.java | 9 +-
.../converter/LoadTsFileDataTypeConverter.java | 112 ++++
.../db/storageengine/rescon/disk/TierManager.java | 18 +-
.../db/pipe/pattern/TreePatternPruningTest.java | 41 +-
.../sink/IoTDBDataNodeAsyncClientManagerTest.java | 57 ++
.../fragment/FragmentInstanceContextTest.java | 623 +++++++++++++++++++++
.../queue/MultilevelPriorityQueueTest.java | 13 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 98 +++-
.../active/ActiveLoadFailedMessageHandlerTest.java | 51 ++
.../load/active/ActiveLoadTsFileLoaderTest.java | 152 +++++
...atementDataTypeConvertExecutionVisitorTest.java | 19 +
.../conf/iotdb-system.properties.template | 7 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../disk/strategy/DirectoryStrategyType.java | 32 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 5 +-
.../pipe/config/constant/PipeSourceConstant.java | 2 +
.../pipe/datastructure/pattern/TreePattern.java | 179 +++---
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 11 +-
.../disk/strategy/DirectoryStrategyTypeTest.java | 63 +++
.../pattern/TreePatternParseTest.java | 83 +++
.../iotdb/commons/utils/JVMCommonUtilsTest.java | 24 +
pom.xml | 3 +
81 files changed, 3269 insertions(+), 512 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateWithDeletionMultiDataDirIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateWithDeletionMultiDataDirTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java
create mode 100644 iotdb-client/client-cpp/cmake/InstallOpenSSLRuntime.cmake
create mode 100644
iotdb-client/client-cpp/src/assembly/package-metadata/third_party/NOTICE
create mode 100644
iotdb-client/client-cpp/src/assembly/package-metadata/third_party/licenses/LICENSE-Boost-1.0
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/snapshot/SnapshotFragmentReaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceContextTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoaderTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/disk/strategy/DirectoryStrategyTypeTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/pattern/TreePatternParseTest.java
