This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch fix-cn-rpc-processor-block
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 6a28e285819 Update ClientPoolProperty.java
omit 44e8909f969 Revert "Update AbstractThriftServiceThread.java"
omit 3190f10d3ea Update AbstractThriftServiceThread.java
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)
add db0c69a8715 Fixed the potential NPE in clear all cache on local
(#16378)
add 2bec9c70eca Disable the last cache for some last-related tests
temporarily
add b422e9a5c59 Fix CN pipe procedures restore dead lock (#16324)
add 8106d97db49 Revert "Fix CN pipe procedures restore dead lock (#16324)"
(#16384)
add ff20bbf315d Metric connection security enhanced (#16379)
add 71603e5fd4d Fix read lock not release when unexpected exception
occurred. (#16385)
add 32bb39ae308 [AINode] Renew python dependencies (#16380)
add 699c90eff9d Load: add the function of transferring too many time
partitions of files to tablets and fixed the problem that the data written to
tablets is more than expected. (#16320)
add 87bd830fc28 Pipe: Set placeholder for required pipeMetaList &
Prevented the empty progress report when shutdown (#16388)
add e9994aa6511 Update LICENSE and remove useless code (#16389)
add 3d8522a0cb2 Add dropwizard related modification to LICENSE
add ba2c3a853aa Add some classes modified from trino to LICENSE file
(#16393)
add 1d7e82dfff8 Fixed the potential problem in DataNodeDevicePathCache &
Pipe: Reduced the logs in "PipeReceiverStatusHandler" (#16397)
add a1fe2418260 Pipe: Avoided the OOM risks by replacing the progressive
cheating factor with policy change (#16398)
add fd514200640 Finish
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6a28e285819)
\
N -- N -- N refs/heads/fix-cn-rpc-processor-block (fd514200640)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d1a.yml | 4 +-
LICENSE | 35 +-
LICENSE-binary | 22 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +-
... IoTDBRegionMigrateWithCompressionRatioIT.java} | 51 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 5 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 2 +-
.../it/query/recent/IoTDBTableAggregation2IT.java | 1 +
.../it/query/recent/IoTDBTableAggregationIT.java | 18 +-
.../recent/IoTDBTableAggregationNonStream2IT.java | 1 +
.../apache/iotdb/cli/IoTDBSyntaxHighlighter.java | 80 --
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 | 856 +++++++--------------
iotdb-core/ainode/pom.xml | 36 +-
iotdb-core/ainode/pyproject.toml | 74 +-
.../response/pipe/task/PipeTableResp.java | 14 +-
.../runtime/PipeRuntimeCoordinator.java | 2 +-
.../runtime/heartbeat/PipeHeartbeat.java | 4 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 3 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 36 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 16 +-
.../dataregion/DataExecutionVisitor.java | 4 +-
.../runtime/TableNotExistsRuntimeException.java | 36 -
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 5 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 4 +
.../common/tablet/PipeRawTabletInsertionEvent.java | 19 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +
...ileInsertionEventTableParserTabletIterator.java | 25 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 34 +
.../downsampling/PartialPathLastObjectCache.java | 60 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 3 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 78 +-
.../sink/protocol/writeback/WriteBackSink.java | 3 +-
.../dataregion/realtime/epoch/TsFileEpoch.java | 13 +-
.../protocol/client/DataNodeClientPoolFactory.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 3 -
.../cache/schema/DataNodeDevicePathCache.java | 2 +-
.../analyze/cache/schema/DataNodeTTLCache.java | 2 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 7 +
.../planner/plan/node/write/InsertTabletNode.java | 4 +-
.../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 +-
.../plan/statement/crud/InsertTabletStatement.java | 18 +-
.../db/schemaengine/table/DataNodeTableCache.java | 15 +-
.../db/service/DataNodeInternalRPCService.java | 14 +-
.../db/storageengine/dataregion/DataRegion.java | 28 +-
.../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 +-
.../converter/LoadTsFileDataTypeConverter.java | 11 +-
.../load/splitter/TsFileSplitter.java | 21 +
.../event/cache/SubscriptionPollResponseCache.java | 54 +-
.../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 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 3 +
.../memtable/AlignedTVListIteratorTest.java | 8 +-
.../memtable/NonAlignedTVListIteratorTest.java | 8 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 8 +
iotdb-core/metrics/interface/pom.xml | 4 +
.../apache/iotdb/metrics/config/MetricConfig.java | 54 +-
.../metrics/config/MetricConfigDescriptor.java | 13 +
.../reporter/iotdb/IoTDBSessionReporter.java | 22 +-
.../reporter/prometheus/PrometheusReporter.java | 63 +-
.../java/org/apache/iotdb/metrics/type/Timer.java | 16 +-
.../client/property/ClientPoolProperty.java | 18 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 2 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 55 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 3 +-
pom.xml | 6 +-
97 files changed, 1326 insertions(+), 1122 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-client/cli/src/main/java/org/apache/iotdb/cli/IoTDBSyntaxHighlighter.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/runtime/TableNotExistsRuntimeException.java
