This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch fix-pipe-ref-count-leak
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from dd4b4474a42 fix
add 7fe0ff4415c Pipe: Convert data types when data sync sink metadata does
not match integration test (#13208)
add 90f0394cbde Fix some issues of compaction (#13316)
add 600e77f74d5 Make procedure scheduler ignore successful procedure
(#13327)
add eef7902ba2f Merge branch 'master' of https://github.com/apache/iotdb
into fix-pipe-ref-count-leak
No new revisions were added by this update.
Summary of changes:
.../manual/IoTDBPipeTypeConversionISessionIT.java | 807 +++++++++++++++++++++
.../pipe/it/manual/IoTDBPipeTypeConversionIT.java | 616 ++++++++++++++++
.../iotdb/confignode/procedure/Procedure.java | 2 +-
.../confignode/procedure/ProcedureExecutor.java | 7 +-
.../scheduler/AbstractProcedureScheduler.java | 8 +
.../async/IoTDBDataRegionAsyncConnector.java | 4 +-
.../transform/converter/ValueConverter.java | 78 +-
.../statement/PipeConvertedInsertRowStatement.java | 1 +
.../PipeConvertedInsertTabletStatement.java | 1 +
.../plan/statement/crud/InsertBaseStatement.java | 17 +
.../plan/statement/crud/InsertRowStatement.java | 14 +
.../plan/statement/crud/InsertTabletStatement.java | 14 +
.../fast/FastAlignedSeriesCompactionExecutor.java | 3 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 5 +-
.../fast/element/ChunkMetadataElement.java | 8 +-
.../DefaultCompactionTaskComparatorImpl.java | 6 +-
.../estimator/AbstractCompactionEstimator.java | 6 +
.../FastCompactionInnerCompactionEstimator.java | 12 +-
.../FastCrossSpaceCompactionEstimator.java | 12 +-
.../ReadChunkInnerCompactionEstimator.java | 11 +-
.../impl/NewSizeTieredCompactionSelector.java | 36 +-
.../storageengine/dataregion/tsfile/TsFileID.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 2 +-
.../NewSizeTieredCompactionSelectorTest.java | 90 +++
24 files changed, 1691 insertions(+), 75 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeTypeConversionISessionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeTypeConversionIT.java
