This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch metric_ssl
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9ebd69a568e function works
new d9e9e7c77ce dev
new 12069b0dd65 finish config
add d29e45cad29 Pipe: Fix unnecessary client shutdown logic and reduce
handshake waiting time (#16341)
add 6fb776cae12 Pipe: Restore RPC thread name after Pipe receiver exit
(#16344)
add cfb244b877d Add comments in docker-compose for startup hang (#16342)
add a1cf26093e1 Fix show regions compressionRatio issue (#16343)
add 164b58140a2 Pipe IT: Moved rate-limiter in zstd-test to non-tested
pipe to avoid blocking potential failure (#16347)
add 7466e2ce1f0 Concurrently querying and writing to the memtable may
cause the query results out of order (#16328)
add 0b74d2b923b Pipe: Checked the enable_auto_create_schema in database
auto creation (#16354)
add 62f65d1c655 [AINode] Fix log file compressing name (#16358)
add d9075a6b1be Fix potential NPE in Unseq List (#16359)
add f5c0e8af466 Try to make IoTDBTableAggregationNonStream2IT more stable
(#16361)
add 31fa71e2e02 Upgrade netty and reactor (#16362)
add 5b0800920e2 Changed the default MQTT handler size to 1/2 number of
processors & Fixed some default parameters when core number is 1 (#16363)
add a2bbb5104b8 Fix that compression ratio is not transferred during
region migration (#16352)
add 51da71f73bd Pipe: Fix epoch status metric (#16355)
add 2ff8310ca2e Avoided "table not exist" related NPEs (#16357)
add 47e02c889e7 Pipe: Fix lost transfer time metric & Support transfer
time tracking for RawTablet events converted from InsertNode/TsFile events
(#16364)
add b918b3b7caf Update RetryUtils.java (#16368)
add 333986442bc [AINode] Refactor the dependencies to IoTDB (#16369)
add 7377aaa4360 [AINode] Fix maven verify bug (#16373)
add 9765ec84892 Pipe: Show "CONFIG_REGION" string instead of MIN_VALUE in
PipeTableResp (#16372)
add dd18e71678c Optimize ttl deletion in fast compaction performer (#16367)
new 7979b1f765f Merge branch 'master' of github.com:apache/iotdb into
metric_ssl
new ffe9cd964e7 finish config
new 9add7d4898a remove switch
The 5 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:
.github/workflows/cluster-it-1c1d1a.yml | 4 +-
LICENSE-binary | 22 +++---
.../main/DockerCompose/docker-compose-ainode.yml | 9 ++-
.../docker-compose-cluster-1c1d1a.yml | 15 +++-
.../DockerCompose/docker-compose-cluster-1c2d.yml | 21 +++++
.../DockerCompose/docker-compose-host-3c3d.yml | 14 ++++
.../DockerCompose/docker-compose-standalone.yml | 9 ++-
... IoTDBRegionMigrateWithCompressionRatioIT.java} | 51 +++++++++---
.../enhanced/IoTDBPipeSinkCompressionIT.java | 6 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 2 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 18 ++---
iotdb-client/client-py/pom.xml | 3 +
iotdb-core/ainode/.gitignore | 12 ++-
iotdb-core/ainode/iotdb/__init__.py | 17 ----
iotdb-core/ainode/iotdb/ainode/core/constant.py | 2 +-
iotdb-core/ainode/iotdb/ainode/core/log.py | 1 +
iotdb-core/ainode/poetry.lock | 69 +---------------
iotdb-core/ainode/pom.xml | 36 +++++----
iotdb-core/ainode/pyproject.toml | 14 +++-
.../response/pipe/task/PipeTableResp.java | 14 +++-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../dataregion/DataExecutionVisitor.java | 4 +-
.../runtime/TableNotExistsRuntimeException.java | 36 ---------
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 4 +
.../common/tablet/PipeRawTabletInsertionEvent.java | 19 +++++
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +
.../overview/PipeDataNodeSinglePipeMetrics.java | 34 ++++++++
.../protocol/thrift/IoTDBDataNodeReceiver.java | 3 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 15 ++--
.../sink/protocol/writeback/WriteBackSink.java | 3 +-
.../dataregion/realtime/epoch/TsFileEpoch.java | 13 +++-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 3 -
.../analyze/cache/schema/DataNodeTTLCache.java | 2 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 7 ++
.../execution/config/metadata/ShowRegionTask.java | 6 +-
.../relational/analyzer/StatementAnalyzer.java | 9 +--
.../relational/metadata/TableMetadataImpl.java | 4 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 4 -
.../fetcher/TableHeaderSchemaValidator.java | 4 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 4 +-
.../plan/relational/sql/parser/AstBuilder.java | 16 ++--
.../db/schemaengine/table/DataNodeTableCache.java | 15 +++-
.../db/storageengine/dataregion/DataRegion.java | 22 +++++-
.../performer/impl/FastCompactionPerformer.java | 11 +--
.../compaction/execute/utils/CompactionUtils.java | 16 +++-
.../execute/utils/MultiTsFileDeviceIterator.java | 16 +---
.../executor/fast/SeriesCompactionExecutor.java | 6 +-
.../utils/writer/AbstractCompactionWriter.java | 11 +++
.../estimator/AbstractCompactionEstimator.java | 4 +
.../RepairUnsortedFileCompactionEstimator.java | 5 ++
.../impl/NewSizeTieredCompactionSelector.java | 2 +-
.../selector/impl/SettleSelectorImpl.java | 2 +-
.../dataregion/flush/CompressionRatio.java | 19 ++++-
.../memtable/AlignedReadOnlyMemChunk.java | 32 +++-----
.../dataregion/memtable/ReadOnlyMemChunk.java | 20 ++---
.../dataregion/snapshot/SnapshotLoader.java | 42 +++++++++-
.../dataregion/snapshot/SnapshotTaker.java | 27 +++++++
.../db/storageengine/load/LoadTsFileManager.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 5 +-
.../datastructure/MemPointIteratorFactory.java | 91 +++++++++++++++++-----
.../MergeSortMultiAlignedTVListIterator.java | 2 +
.../MergeSortMultiTVListIterator.java | 2 +
.../datastructure/MultiAlignedTVListIterator.java | 6 +-
.../utils/datastructure/MultiTVListIterator.java | 22 +++++-
.../OrderedMultiAlignedTVListIterator.java | 2 +
.../datastructure/OrderedMultiTVListIterator.java | 2 +
.../iotdb/db/utils/datastructure/TVList.java | 9 +--
.../memtable/AlignedTVListIteratorTest.java | 8 +-
.../memtable/NonAlignedTVListIteratorTest.java | 8 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 8 ++
.../apache/iotdb/metrics/config/MetricConfig.java | 8 +-
.../metrics/config/MetricConfigDescriptor.java | 13 ++++
.../reporter/prometheus/PrometheusReporter.java | 2 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 10 +++
.../org/apache/iotdb/commons/utils/RetryUtils.java | 3 +-
pom.xml | 6 +-
77 files changed, 649 insertions(+), 349 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/{IoTDBRegionMigrateWithLastEmptyDeletionIT.java
=> IoTDBRegionMigrateWithCompressionRatioIT.java} (63%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/runtime/TableNotExistsRuntimeException.java