This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch rc/2.0.8
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fffdf15e8d5 Pipe: Enabled retry locally for air gap receiver &
temporary unavailable exception (#17188)
new 4b6da6c5d69 Fix process of restore external-service instance #17194
new 0b77989cf37 Fix incorrect time slice calculation in
AbstractDefaultAggTableScanOperator (#17195)
new 0c8912d25a0 Fix race condition in SharedTsBlockQueue async listener
causing NPE in MemoryPool.free() (#17196)
new 6297b77defe Fixed concurrency issues caused by write and flush sorting
during query execution (#17193)
new 65f4affa4d6 Fix: Adding the time column is prohibited. (#17215)
new 6951a0c3c12 Fix external service ClassLoader context handling and
dependency scope (#17202)
new 434db0737ff Fix incorrect early termination in descending scan of
unpackOneFakeMemChunkMetaData (#17283)
new 2800c7791ca fix redundant operations in compaction (#17239)
new 97f7333d05f Fix incorrect measurement schema during compaction (#17297)
new bf25167753c [AINode] Fix call inference error (#17308)
new 0011eb7b6d9 fix: pick deletion event for historical resend (#17329)
The 11 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:
distribution/pom.xml | 1 -
external-service-impl/rest/pom.xml | 1 -
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 23 ++
.../it/schema/IoTDBTableWithDefinedTimeIT.java | 22 ++
iotdb-core/datanode/pom.xml | 4 -
.../pipeconsensus/PipeConsensusAsyncSink.java | 10 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 12 +
.../execution/exchange/SharedTsBlockQueue.java | 34 +-
.../execution/operator/source/SeriesScanUtil.java | 64 ++--
.../AbstractDefaultAggTableScanOperator.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 3 +
.../view/visitor/TransformToExpressionVisitor.java | 21 +-
.../ExternalServiceManagementService.java | 71 ++--
.../performer/impl/FastCompactionPerformer.java | 22 +-
.../impl/ReadChunkCompactionPerformer.java | 67 +++-
.../execute/utils/CompactionSeriesContext.java | 13 +
.../compaction/execute/utils/CompactionUtils.java | 40 ++-
.../execute/utils/MultiTsFileDeviceIterator.java | 319 +++++++++++------
...edReadChunkAlignedSeriesCompactionExecutor.java | 10 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 18 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 11 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 126 ++++++-
.../dataregion/flush/MemTableFlushTask.java | 1 +
.../memtable/AbstractWritableMemChunk.java | 43 ++-
.../memtable/AlignedWritableMemChunk.java | 94 +++--
.../dataregion/memtable/IWritableMemChunk.java | 2 +
.../dataregion/memtable/WritableMemChunk.java | 38 +--
.../db/utils/datastructure/AlignedTVList.java | 12 +
.../iotdb/db/utils/datastructure/BinaryTVList.java | 9 +
.../db/utils/datastructure/BooleanTVList.java | 9 +
.../iotdb/db/utils/datastructure/DoubleTVList.java | 9 +
.../iotdb/db/utils/datastructure/FloatTVList.java | 9 +
.../iotdb/db/utils/datastructure/IntTVList.java | 9 +
.../iotdb/db/utils/datastructure/LongTVList.java | 9 +
.../iotdb/db/utils/datastructure/TVList.java | 2 +
.../execution/exchange/SharedTsBlockQueueTest.java | 82 ++++-
.../plan/analyze/FakeSchemaFetcherImpl.java | 4 +-
.../compaction/AbstractCompactionTest.java | 28 ++
.../compaction/CompactionDataTypeAlterTest.java | 377 ---------------------
...ctionDataTypeNotMatchAlterableDataTypeTest.java | 221 ------------
.../AbstractCompactionAlterDataTypeTest.java | 177 ++++++++++
.../CompactionDataTypeAlterTableTest.java | 241 +++++++++++++
.../alterDataType/CompactionDataTypeAlterTest.java | 230 +++++++++++++
...ctionDataTypeNotMatchAlterableDataTypeTest.java | 163 +++++++++
.../CompactionDataTypeNotMatchTest.java | 152 +++++----
.../TableModelCompactionWithTTLTest.java | 25 +-
.../utils/CompactionFakeSchemaFetcherImpl.java} | 22 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 48 +++
.../iotdb/commons/externalservice/ServiceInfo.java | 9 +
.../iotdb/commons/model/ModelInformation.java | 66 +---
.../org/apache/iotdb/commons/model/ModelType.java | 26 --
.../apache/iotdb/commons/schema/table/TsTable.java | 3 +-
52 files changed, 1908 insertions(+), 1106 deletions(-)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionDataTypeAlterTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionDataTypeNotMatchAlterableDataTypeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/alterDataType/AbstractCompactionAlterDataTypeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/alterDataType/CompactionDataTypeAlterTableTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/alterDataType/CompactionDataTypeAlterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/alterDataType/CompactionDataTypeNotMatchAlterableDataTypeTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{
=> alterDataType}/CompactionDataTypeNotMatchTest.java (58%)
copy
iotdb-core/datanode/src/{main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/schedule/constant/CompactionType.java
=>
test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionFakeSchemaFetcherImpl.java}
(62%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelType.java
