This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch fix_topk_1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 211f55847e2 fix unsupported data type in topk
add deec0fb2aa4 Cherry pick commit c5eacf from master (#14255)
add da9b0dc27c1 Pipe IT: Modify the forwarding-pipe-requests configuration
of Double Living IT (#14240) (#14260)
add f7768590e97 [to dev/1.3] Enhance repair data file scan util (#14254)
add 64b43e79201 fix bug (#14247)
add 28d436b2551 [To dev/1.3] Fix back-quote remove of Select-Into query
when query is not for raw data (#14274)
add 3f325e120b7 [to dev/1.3] Some configuration items may be commented out
when merging old version configuration files (#14249)
add 7bc541d296e Add avg file size in DefaultCompactionTaskComparatorImpl
(#14270) (#14295)
add 4f70660d067 Pipe: Introduce restart strategy to control resources'
memory only used by pipe hardlinked files & Pipe: fix too many warn logs from
findAllStuckPipes() (#14279) (#14287) (#14297)
add 26c4cca80db Pipe: fix the issues of excessive stale PipeEventCommitter
logs and missing PipeDataNodeRemainingEventAndTimeMetrics (#14284) (#14298)
add 858a8caecac Pipe: Enhanced the pipe transferred create timeseries
logic to allow merging tags / attributes (#14261) (#14302)
add 75b30407702 Common Config & Pipe IT: Fixed the bug that
dn-connection-timeout and cn-connection-timeout are mixed (#14275) (#14303)
add c7b4204f746 Fix procedure framework data race (#14309)
add 50801f86114 Pipe: Fix potential NPE from
WALEntryHandler#getInsertNodeViaCacheIfPossible & Improve performance for pipe
slightly (#14312) (#14316)
add 8f13c739033 bump tsfile to 1.1.0-241205-SNAPSHOT (#14318)
add 26faf24a8b2 Pipe: Added the CreateMultiTimeSeries with merge logic and
disabled timeSeries existence check at SchemaExecutionVisitor for plans
transferred by pipe (#14317) (#14320)
add aee5008047b Merge branch 'dev/1.3' into fix_topk_1.3
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 4 +-
.../env/cluster/config/MppSharedCommonConfig.java | 6 +-
.../it/env/remote/config/RemoteCommonConfig.java | 2 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 49 +++
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 4 +-
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 55 +++-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 4 +-
.../IoTDBPipeConnectorCompressionIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 6 +-
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 12 +-
.../pipe/it/autocreate/IoTDBPipeWithLoadIT.java | 4 +-
.../pipe/it/manual/AbstractPipeDualManualIT.java | 4 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 4 +-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 4 +-
.../pipe/it/manual/IoTDBPipePermissionIT.java | 4 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 2 +-
.../it/dual/AbstractSubscriptionDualIT.java | 4 +-
.../it/triple/AbstractSubscriptionTripleIT.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../manager/consensus/ConsensusManager.java | 6 +-
.../manager/node/ClusterNodeStartUtils.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../confignode/procedure/ProcedureExecutor.java | 109 ++++---
.../procedure/impl/node/AbstractNodeProcedure.java | 5 +-
.../iotdb/confignode/service/ConfigNode.java | 2 +-
.../schemaregion/SchemaExecutionVisitor.java | 138 +++++----
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 23 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 2 +-
.../dataregion/IoTDBDataRegionExtractor.java | 2 +
.../PipeRealtimeDataRegionHybridExtractor.java | 4 +-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 14 +
.../db/pipe/resource/memory/PipeMemoryManager.java | 4 +
.../pipe/resource/tsfile/PipeTsFileResource.java | 4 +
.../resource/tsfile/PipeTsFileResourceManager.java | 19 ++
.../execution/executor/RegionWriteExecutor.java | 264 ++++++++--------
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 16 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 7 +-
.../db/storageengine/dataregion/DataRegion.java | 3 -
.../CompactionStatisticsCheckFailedException.java | 87 ++++++
.../execute/task/InnerSpaceCompactionTask.java | 4 +
.../task/RepairUnsortedFileCompactionTask.java | 4 +-
.../compaction/repair/RepairDataFileScanUtil.java | 339 +++++++++++++++------
.../repair/RepairTimePartitionScanTask.java | 4 +-
.../DefaultCompactionTaskComparatorImpl.java | 12 +-
.../dataregion/tsfile/TsFileManager.java | 11 +-
.../dataregion/wal/utils/WALEntryHandler.java | 5 +-
.../compaction/CompactionTaskComparatorTest.java | 25 +-
.../cross/InsertionCrossSpaceCompactionTest.java | 32 ++
.../repair/RepairDataFileScanUtilTest.java | 124 +++++++-
.../iotdb/db/utils/ConfigurationFileUtilsTest.java | 80 +++++
.../iotdb/commons/client/ClientPoolFactory.java | 22 +-
.../client/request/TestConnectionUtils.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 21 +-
.../iotdb/commons/conf/CommonDescriptor.java | 8 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 2 +-
.../task/progress/PipeEventCommitManager.java | 26 +-
pom.xml | 2 +-
63 files changed, 1193 insertions(+), 449 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/CompactionStatisticsCheckFailedException.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/ConfigurationFileUtilsTest.java
