This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch fix_flush_error_due_to_compressionRatio in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cfcd24563ea8ced467393b68d21ec07d3fa4eb3f Merge: 5945a607835 ec63dc17220 Author: HTHou <[email protected]> AuthorDate: Wed Jul 17 11:08:36 2024 +0800 Merge branch 'master' of github.com:apache/iotdb into fix_flush_error_due_to_compressionRatio .github/workflows/multi-language-client.yml | 19 +- docker/src/main/DockerCompose/do-docker-build.sh | 4 +- docker/src/main/Dockerfile-0.10.1 | 39 ---- docker/src/main/Dockerfile-0.11.4 | 41 ---- docker/src/main/Dockerfile-0.12.6-cluster | 53 ----- docker/src/main/Dockerfile-0.12.6-node | 45 ---- docker/src/main/Dockerfile-0.13.0-cluster | 53 ----- docker/src/main/Dockerfile-0.13.3-node | 45 ---- .../src/main/Dockerfile-0.13.3-node-multi-platform | 45 ---- docker/src/main/Dockerfile-0.8.1 | 40 ---- docker/src/main/Dockerfile-0.9.1 | 41 ---- docker/src/main/Dockerfile-0.9.1-jre8 | 41 ---- docker/src/main/Dockerfile-1.0.0-confignode | 2 +- docker/src/main/Dockerfile-1.0.0-datanode | 2 +- docker/src/main/Dockerfile-1.0.0-standalone | 2 +- docker/src/main/Dockerfile-1c1d | 2 +- .../it/env/cluster/config/MppCommonConfig.java | 6 + .../env/cluster/config/MppSharedCommonConfig.java | 7 + .../it/env/remote/config/RemoteCommonConfig.java | 5 + .../org/apache/iotdb/itbase/env/CommonConfig.java | 2 + .../db/it/fill/IoTDBFillWithNewDataTypeIT.java | 145 ++++++++++++ .../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 3 +- .../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 3 +- .../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 56 ++++- iotdb-client/client-cpp/pom.xml | 28 ++- iotdb-client/client-py/pom.xml | 7 + .../rpc/subscription/config/ConsumerConstant.java | 3 +- .../consumer/SubscriptionConsumer.java | 2 +- .../consumer/SubscriptionPushConsumer.java | 6 +- .../manager/load/balancer/RegionBalancer.java | 7 +- ...artiteGraphReplicationRegionGroupAllocator.java | 256 +++++++++++++++++++++ .../subscription/SubscriptionCoordinator.java | 6 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +- .../pipeconsensus/PipeConsensusReceiver.java | 2 +- .../execution/load/LoadTsFileManager.java | 26 +-- .../operator/process/AbstractIntoOperator.java | 12 + .../plan/planner/OperatorTreeGenerator.java | 20 +- .../plan/statement/literal/BooleanLiteral.java | 4 +- .../plan/statement/literal/DoubleLiteral.java | 3 +- .../plan/statement/literal/Literal.java | 4 + .../plan/statement/literal/LongLiteral.java | 26 ++- .../plan/statement/literal/StringLiteral.java | 21 +- .../db/storageengine/dataregion/DataRegion.java | 3 + .../execute/utils/reader/PointPriorityReader.java | 12 +- .../dataregion/flush/CompressionRatio.java | 8 +- .../dataregion/wal/io/WALMetaData.java | 65 +++--- .../rescon/disk/strategy/SequenceStrategy.java | 24 +- .../agent/SubscriptionBrokerAgent.java | 28 ++- .../agent/SubscriptionConsumerAgent.java | 12 +- .../subscription/agent/SubscriptionTopicAgent.java | 10 +- .../db/subscription/broker/SubscriptionBroker.java | 89 ++++--- .../broker/SubscriptionPrefetchingQueue.java | 67 ++++-- .../broker/SubscriptionPrefetchingTabletQueue.java | 15 +- .../broker/SubscriptionPrefetchingTsFileQueue.java | 175 ++++++++------ .../db/subscription/event/SubscriptionEvent.java | 18 +- .../batch/SubscriptionPipeTabletEventBatch.java | 2 +- .../batch/SubscriptionPipeTsFileEventBatch.java | 2 +- .../receiver/SubscriptionReceiverV1.java | 90 +++++--- .../org/apache/iotdb/db/utils/CommonUtils.java | 39 ++-- .../dataregion/wal/io/WALFileTest.java | 15 ++ .../conf/iotdb-system.properties.template | 2 +- .../org/apache/iotdb/commons/utils/IOUtils.java | 32 +++ .../apache/iotdb/commons/utils/JVMCommonUtils.java | 30 ++- pom.xml | 12 +- 64 files changed, 1137 insertions(+), 749 deletions(-)
