This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a change to branch remove_swtich_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5eb7694245c Fix TypeService review feedback and serialization
compatibility
add 2a654e66745 Fix deleteDirectoryIfExists when root Path is not exist
(#18593)
add 6343e1fe7a0 Restrict COPY TO export paths (#18573)
add 47844ddc737 Optimize aligned memtable encoding for null values (#18610)
add 6c2b747ede6 [Pipe] Fix batch and async resource lifecycle leaks
(#18582)
add c2ead3be72f Fix Java client time column access throwing
ArrayIndexOutOfBoundsException (#17407) (#17408)
add 6a3c8d667f0 [Load] Preserve invalid device path failures during tablet
conversion (#18614)
add 865a88afd91 Merge branch 'master' into remove_swtich_type
No new revisions were added by this update.
Summary of changes:
.../query/recent/copyto/IoTDBCopyToTsFileIT.java | 86 ++++
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 90 ++++
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 10 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 5 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 19 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 9 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 3 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 9 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 2 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 28 ++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 36 ++
...n.java => LoadAnalyzeInvalidPathException.java} | 5 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 513 +++++++++++++++-----
.../TsFileInsertionEventParserMemoryManager.java | 14 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 123 +++--
.../resource/tsfile/PipeTsFilePublicResource.java | 125 ++---
.../resource/tsfile/PipeTsFileResourceManager.java | 72 ++-
.../evolvable/batch/PipeTabletEventBatch.java | 105 +++-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 86 +++-
.../batch/PipeTabletEventTsFileBatch.java | 110 +++--
.../batch/PipeTransferBatchReqBuilder.java | 95 +++-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 13 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 12 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 531 +++++++++++++++------
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../handler/PipeTransferTrackableHandler.java | 94 +++-
.../async/handler/PipeTransferTsFileHandler.java | 161 ++++---
.../thrift/sync/IoTDBDataRegionSyncSink.java | 13 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 41 ++
.../builder/PipeTableModelTsFileBuilderV2.java | 45 ++
.../util/builder/PipeTreeModelTsFileBuilder.java | 31 ++
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 38 ++
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 10 +
.../db/queryengine/common/MPPQueryContext.java | 9 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 4 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 20 +-
.../queryengine/plan/execution/QueryExecution.java | 18 +-
.../ConcatDeviceAndBindSchemaForHavingVisitor.java | 16 +-
.../relational/analyzer/StatementAnalyzer.java | 16 +
.../spill/AbstractDeviceEntryMaterializer.java | 5 +-
.../spill/DeviceEntrySortedMaterializer.java | 4 +-
.../metadata/spill/DeviceEntrySpillManager.java | 5 +
.../memtable/AlignedWritableMemChunk.java | 244 ++++++++++
.../load/LoadTsFilePathUtils.java} | 47 +-
.../converter/LoadTreeTsFileTabletIterator.java | 26 +-
.../db/utils/datastructure/AlignedTVList.java | 49 ++
.../db/utils/datastructure/BackAlignedTVList.java | 1 +
.../db/utils/datastructure/QuickAlignedTVList.java | 1 +
.../db/utils/datastructure/TimAlignedTVList.java | 3 +-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 19 +
.../pipe/event/TsFileInsertionEventParserTest.java | 62 +++
.../memory/PipeMemoryManagerResizeTest.java | 54 +++
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 3 +
.../batch/PipeTabletEventTsFileBatchTest.java | 1 +
.../batch/PipeTransferBatchReqBuilderTest.java | 110 +++++
.../handler/PipeTransferTrackableHandlerTest.java | 140 ++++++
.../PipeTransferTsFileHandlerCleanupTest.java | 23 +-
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 16 +-
.../spill/DeviceEntryMaterializerTest.java | 16 +-
.../dataregion/memtable/MemTableFlushTaskTest.java | 190 ++++++++
.../load/converter/LoadTsFileInvalidPathTest.java | 195 ++++++++
.../db/utils/datastructure/AlignedTVListTest.java | 32 ++
.../conf/iotdb-system.properties.template | 12 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 27 ++
.../apache/iotdb/commons/utils/FileUtilsTest.java | 12 +
66 files changed, 3293 insertions(+), 625 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/load/{LoadAnalyzeMissingSchemaException.java
=> LoadAnalyzeInvalidPathException.java} (80%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{schemaengine/schemaregion/read/resp/info/impl/ShowSchemaResult.java
=> storageengine/load/LoadTsFilePathUtils.java} (50%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeTransferBatchReqBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileInvalidPathTest.java
