This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch bump_ratis_cp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 3614fa598c8 bump
add 6e419f476df [To dev/1.3] Bump ratis to 3.1.2-a862328-SNAPSHOT
add 524a01634e2 [To dev/1.3] Bump h2-mvstore to 2.3.232 & Bump
jackson-databind to 2.16.2 (#14473)
add 4fe2353a98e Pipe: Do not stop runtime agent when removing datanode
(#14474) (#14475)
add 88141431a84 Pipe: Added permission check for config receiver (#14418)
(#14456)
add d0dbd738cbc Subscription: allow generate subsequent events with the
same tablet batch to avoid large message & improve poll logic to avoid
unnecessary nack (#14452) (#14476)
add e12b7350151 Load: Fix Memory Allocation and Release Mismatch in
LoadTsFileDataCacheMemoryBlock (#14375) (#14466)
add 4288ba0a40f fix checkNonAlignedDeviceSeries (#14462)
add df3fabf5232 [To Dev/1.3]Encountering empty tablets during batch export
of tsfile does not affect subsequent export tasks (#14463)
add bc966a68991 [to dev/1.3] Allow hot reloading compaction from disabled
status (#14470) (#14480)
add a64b844702f [To dev/1.3] Fix setting illegal
default_storage_group_level does not report an error (#14483)
add 0a004693899 [To dev/1.3] Pipe: Fixed the issue where partial writing
caused the measurement to be null and caused the memory estimator to throw NPE
(#14391) (#14488)
add a8940b691ab Pipe: Fix infinite loop when thread is interrupted in
invoking PipeMemoryBlock#close & Avoid throwing new InterruptedException in
conditions that can be self-restoring (#14471) (#14486)
add c665cb723bf Pipe: Fixed the bug that auth plan with system privileges
can not be transferred (#14492)
add db2b9d959e8 fix compaction task comparator & fix the conflicts between
inner compaction selection conditions (#14496)
add b8affeb2ba4 [To dev/1.3] Fix error in template + sort + offset + limit
+ align by device
add ffaf1d2e44d [to dev/1.3] apply new configurations in memory before
update file (#14501)
add 2afddd04c85 [To dev/1.3] Support us and ns timePrecision in udf-library
add f3ce409dced fix: docker replace conf sh (#14518) (#14520)
add 234efb3e87e reduce useless loops (#14523)
add 8d0ccd9034c [To dev/1.3] Fix load data region snapshot miss some
writing metrics (#14533)
add cc39bae839a [to dev/1.3] Add lock for insert separator to wal (#14482)
add 0577479ee81 add Content-Type in prometheus reporter (#14507) (#14539)
add fa756cf622f Subscription: fix NPE when building consumer with missing
id & add more checker for topic operations using session (#14493) (#14515)
add ccb3276dd5b Subscription: improve `createTopic` API with nullable
properties or when if not exists cond is set (#14516) (#14543)
add f99557f86bd [remove datanode] Remove LoadScore sort to fix
RegionPriority order (#14527) (#14541)
add 86a1b59d831 [to dev/1.3][region migration] Make peer list correct when
IoTConsensus & IoTConsensusV2 & Ratis starting (#14535)
add 719931b6b7b [to dev/1.3] Compaction task can not stopped when abort
compaction (#14547)
add e57973894e4 [To dev/1.3] Add the used memory calculation for
DescPriorityMergeReader which is missed before (#14549)
add 0b74512e211 [region migration] Log optimization (#14536) (#14545)
add 0d265805f7a [IoTConsensus] Refine IoTConsensus Configuration logs
(#14542) (#14555)
add 739d62566e1 Load: detect region replica set changes due to Region
Migration (#14553)
add c87d6dfb54c Fixed the issue of NPE caused by unexpected exceptions
thrown during the use of AsyncClient. (#14556) (#14563)
add b83a32f6a91 [To dev/1.3] Print current trusted_uri_pattern is error msg
add ec573a61e80 [to dev/1.3] Compaction Read Metric and rate limit are
bypassed due to parent class modification (#14565)
add f2b5893b74d [To dev/1.3] Fix that config changes rejected by DN will
be written to CN's config… (#14552)
add 3f980257195 [to dev/1.3] Fix the issue that the cache key used for
queries may conflict (#14561)
add 729f527e46c [To Dev/1.3]fix: UDAFPatternMatch add validate (#14574)
add 06d6bbee65c [To dev/1.3] Detect singular frame lengths in
TElasticFramedTransport (#14572)
add 1bada4aee72 Pipe: Ensure the idempotency of the historical activation
batch (#14566) (#14580)
add fc9b77ac46b [To dev/1.3] Fix RatisConsensus client==null exception
when stopping datanode #14583
add a896d9251f7 Pipe: Fixed the NPE for pipe heartbeat when there are
nodes shutting down (#14584) (#14593)
add 2de80ba47b2 Revert "Fix that config changes rejected by DN will be
written to CN's config (#14551)" (#14590)
add 3b14f299870 Pipe: Fixed the NPE of schema sync in historical transfer
(#14586)
add 35b8a00d1b8 [To dev/1.3] Bump logback from 1.3.14 to 1.3.15 (#14599)
add 8bf9e97e173 Pipe: fix the problems that unable to start when cannot
parse reboot times (#14594) (#14601)
add 78b29c03fc1 Load: remove unnecessary flushes in writer to avoid
generating bad tsfile (#14602) (#14609)
add 5cf6534f6ea Pipe IT: Retry CI tests if pipe-api download fails & Cache
Maven packages in workflows (#14608)
add 8bef94666f7 Load: Support auto data type conversion when data type
mismatch detected during analysis stage (#14529) (#14619)
add dab079765dc [to dev/1.3] Add compaction selection cached device time
index size metric (#14592)
add 2910e107969 Pipe: Fix the problem that the Pipe indicator is
inaccurate and negative (#14627) (#14633)
add 8aa109b1a4b Pipe IT: Extend IoTDBPipeTypeConversionIT retry time
(#14628) (#14636)
add 2d752b0ad41 Pipe IT: Save IT operation logs to the cluster-logs
directory (#14637) (#14638)
add 5ef4ea1b937 Load: Convert TsFiles into Tablets when the target regions
are unavailable (#14626) (#14642)
add 79da22a7c96 Load: Consider isGeneratedByPipe mark when executing
tsfile-tablet conversion in analysis stage (#14651) (#14652)
add 1685031ab13 Pipe & Load: Retry when a file operation causes an
exception (#14598) (#14655)
add c9d7fe9bcbc Reduced the error log cause by batch activate template
when some devices are already activated (#14661) (#14665)
add 14d3528ae84 Use DataNodeDevicePathCache when insert by sql (#14666)
add ff13ec70640 Compaction task memory is incorrect when
compaction_max_aligned_series_num_in_one_batch <= 0 (#14603) (#14639)
add a8d21d8223d Modify the condition to skip compaction schdule after
insertion compaction task selection (#14644) (#14663)
add ac1dacb5c07 Pipe: report linked tsfile size & Subscription: decrease
reference count for other enriched events & add logging to observe possible
stuck situations (#14668) (#14671)
add adb9bd2e48e Clone value array when insert non aligned tablet with null
(#14643) (#14679)
add 37429ecce0b Implement mem control for schema snapshot parser (#14156)
(#14682)
add fbe70759892 Load: Add a new configuration to enable datatype
conversion when converting into Tablets & Refactor LoadAnalyzeException.
(#14646) (#14674)
add b24fb5b0bef Pipe: Fix NPE caused by forced type conversion and fix
IoTDBipipeTypeConversionISessionIT of table model (#14667) (#14670)
add 48a29c116ff Pipe: strict check for synonym pipe parameters to avoid
ambiguity (#14694) (#14700)
add fef75dcb1fb Subscription: fix method in tablet batch to support
multiple tsfile in the same batch (#14715) (#14716)
add 804998bdf82 [to dev/1.3] The time range of device in resource file may
be larger than the actual time range in tsfile (#14726)
add 0e34bb9f6bb [to dev/1.3] Extend Region & Remove Region & Reconstruct
Region (cp 14634) (#14720)
add abd3bbbebfd Pipe: Optimize receiver insertion statements' success
status judgment (#14672) (#14727)
add 11621442767 Pipe: Fix the incorrect use of iterators in Load File
(#14718) (#14728)
add 3c5b2e49878 Pipe: Fix HA issues caused by exceptions not handled in
handshake (IoTDBAirGapConnector / IoTDBSyncClientManager) (#14706) (#14730)
add b8fa0b6448f Refactor procedure framework (simplified
StateMachineProcedure, and some other things) (#14683) (#14741)
add ec84ae16bd5 Fix createView NPE issue when region migration #14746
(#14747)
add a1d37a4f4ff Adjust default wal_throttle_threshold_in_byte and
region_migration_speed_limit_bytes_per_second (#14653) (#14756)
add abc67edf76d [to dev/1.3] Extract "merge" method for SearchNode (#14757)
add ffb60b0b25a Fix region reconstruction IT (#14753) (#14758)
add 632026c8ecd [To dev/1.3] Let the DataPartitionTable be automatically
cleanable (#14737) (#14759)
add 1c1fa79dd32 [To dev/1.3][remove datanode] Add Remove DataNode SQL
#14761
add 99e4df44ab7 Region group status refactor (#14738) (#14760)
add 5581213a89e [To dev/1.3] Pipe / Load: Enable validation skip for load
tsFile (#14774) (#14776)
add 0657aff5a93 [To dev/1.3] Pipe: Introduce periodic verification for
username and password on receiver side (#14764) (#14790)
add 0eefb7f1615 [To dev/1.3] Fix null measurement name issue in
insertTablet (#14800)
add 051c0686925 [To Dev/1.3] [AINode] fix missing dependency in wheel file
add 0ddd7d704ac Bump net.minidev:json-smart from 2.5.0 to 2.5.2
add acd5d1a68cf Fixed the bug that internalCreate(Multi)TimeSeries may
write empty device when measurements are all trimmed (#14827) (#14829)
add 62c25934bc2 Check time precision for negative timestamps (#14828)
(#14832)
add 0097a85ef50 Enhance getLatestRegionRouteMap log for debugging #14830
(#14842)
add 2441b9f48a0 [To dev/1.3] Do not pritn host and port when failed to
connect through CLI (#14845)
add f5b729d0687 Pipe: incorporate batch data into
TsFileInsertionEventScanParser memory control & Subscription: close data
container in tsfile event & bind memory block for tablet response & generate
empty tablet as initial response & offer subsequent tablet response before ack
& expose prefetch and backdoor configs & best-effort disorder control (#14752)
(#14849)
add 84b2fd93b9f Pipe: avoid event accumulation in the stale sink pending
queue & promptly clean up closed processor subtasks & close parser when
releasing phantom reference of tsfile event (#14820) (#14835)
add b3593232fbb Pipe: Default parameters adjustment for pipe threads and
pipeStuckRestartMinIntervalMs (#14819) (#14838)
add 8ebfcb99883 Load: convert to insert tablet on region replica set
changes (#14717) (#14833)
add b49e617f2fa [To dev/1.3][remove confignode] Add Remove ConfigNode SQL
(#14854)
add 37c312d5c15 Delete remove-confignode.sh and remove-datanode.sh (#14855)
add c3515826f6d Metric: Add pipe linked tsfile size and count metric
(#14768) (#14852)
add fbd86ec34f9 Subscription: fix nack tablet response & periodically
report the state of prefetching queue & improve logs for subscription providers
(#14822) (#14836)
add 1b444270a75 Pipe: Fix the problem that the receiver constructs
InsertStatement causing the MeasurementShcema to not be correctly set to null
(NPE) (#14831) (#14858)
add 946fcbc2d3b Pipe: adjust default pipeRealTimeQueuePollHistoryThreshold
to reduce retransmission upon frequent rebooting (#14860)
add 34fcaff6b72 Remove JDBC sensitive information output (#14857) (#14863)
add 32ca7ade147 Pipe: Introduce timely flush options & Execute flush after
pipe watchdog restarts & Log degrade reasons for debugging (#14865) (#14869)
add 75f35ff7f26 Pipe: Implement force forwarding feature where the Pipe
sender can force the receiver to forward the received event (#14847) (#14875)
add 30baecbaa43 [To dev/1.3] Fix reload4j vulnerability issue (#14877)
add ee503f3cc5a Add SSL support to Python client (#14864)
add 6a004b22ed8 Pipe: Fixed the DataNode startup failure caused by Pipe
plugin loading (#14816) (#14881)
add 21cee67f806 [To dev/1.3][remove datanode] Delete the SQL of removing
multiple datanodes at the same time (#14879)
add f0fa1fd801a Subscription: fix consumer infinite pulling event & fully
managed tsfile parsing process & increase the reference count for subscribed
parsed raw tablet event & disrupt parsing requests through the introduction of
randomness & disable prefetch by default (#14856) (#14886)
add 120ad4ce0e5 Pipe: bind memory block for PipeTransferTsFileHandler and
PipeInsertNodeTabletInsertionEvent & unify the memory threshold judgment for
tablet and tsfile block & close data container when internally decrease
reference count of PipeTsFileInsertionEvent (#14873) (#14887)
add eb46fc3f985 Pipe: Reduce degrade log from
PipeRealtimeDataRegionHybridExtractor (#14888) (#14891)
add d64044290eb Pipe: Fixed the bug that delete timeSeries / logicalView
cannot be transferred (#14867) (#14889)
add 029e0e246f5 Fix the incorrect configuration of the JAVA_HOME
environment variable in script." (#14893) (#14896)
add f260cf5b478 Add Date and Float data IT (#14895)
add 8741dfb1512 Fixed the bug that procedure rollback may generate NPE &&
some of the rollback steps may not be / be extra executed (#14871) (#14872)
add f9efb9b8112 Pipe: fix threshold judgment for tablet and tsfile memory
block & Subscription: close data container for current PipeTsFileInsertionEvent
in batch (#14901) (#14902)
add b27c74d2039 Pipe: Avoid stuck in insertion process because failed to
allocate memory (#14899) (#14907)
add 416e923ecfd Subscription: close memory block for previous tsfile
response (#14909) (#14914)
add c01d6b9f0fb [To dev/1.3] Add connection_time_out_in_ms for Python SDK
(#14919)
add a377463095e Reject inserting invalid timestamp string (#14913) (#14920)
add 86bbd3e30af Initialize WALNode when DataRegion is created for iotv1
and iotv2 (#14918) (#14921)
add b622ace6410 [to dev/1.3] IoTConsensus no longer stores the peer list
locally on the DataNode (#14900)
add 820ed079bc7 [to dev/1.3] Fix IT names & Fix region operation related
IT (#14925)
add 9d2a98b70f2 [to dev/1.3] [RTO/RPO] Unify retry logic on
SessionConnection (#14927)
add 4466cac1cae [to dev/1.3] Improve authority control of cluster
management (cp 14924) (#14931)
add 74eb6841b23 Subscription: avoid null pointer exception when get
current response due to concurrent operations (#14926) (#14932)
add ff64e9e2c9b Load: Add mods file metrics count (#14930) (#14944)
add f3aeb69766f Fix class name of RPCServiceMBean #14940 (#14945)
new d4927cd01a3 [RATISCONSENSUS] Bump ratis version to 3.1.3 (#14709)
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 (3614fa598c8)
\
N -- N -- N refs/heads/bump_ratis_cp (d4927cd01a3)
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.
The 1 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:
.github/workflows/pipe-it-2cluster.yml | 300 ++++-
.github/workflows/todos-check.yml | 54 +
.../main/DockerCompose/replace-conf-from-env.sh | 33 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 5 +
.../it/env/cluster/config/MppCommonConfig.java | 18 +
.../env/cluster/config/MppSharedCommonConfig.java | 21 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 48 +
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 5 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 12 +
.../it/env/cluster/node/ConfigNodeWrapper.java | 5 +
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 5 +
.../it/env/remote/config/RemoteCommonConfig.java | 10 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 11 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 6 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 8 +
.../{AbstractScript.java => AbstractScriptIT.java} | 2 +-
.../apache/iotdb/cli/it/StartClientScriptIT.java | 6 +-
....java => IoTDBAutoRegionGroupExtension2IT.java} | 4 +-
.../partition/IoTDBPartitionTableAutoCleanIT.java | 135 +++
...IoTDBRegionMigrateDataNodeCrashITFramework.java | 3 +-
...oTDBRegionOperationReliabilityITFramework.java} | 246 ++--
.../pass/IoTDBRegionMigrateClusterCrashIT.java | 4 +-
.../pass/IoTDBRegionMigrateConfigNodeCrashIT.java | 5 +-
.../pass/IoTDBRegionMigrateNormalIT.java | 4 +-
.../pass/IoTDBRegionMigrateOtherIT.java | 4 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 173 +++
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 149 +++
.../IoTDBRegionMigrateDataNodeCrashIT.java | 4 +-
...nMigrateOriginalCrashWhenDeleteLocalPeerIT.java | 6 +-
.../IoTDBRemoveConfigNodeITFramework.java | 199 ++++
.../IoTDBRemoveConfigNodeNormalIT.java} | 14 +-
.../IoTDBRemoveDataNodeITFramework.java | 98 +-
.../IoTDBRemoveDataNodeNormalIT.java | 15 +-
.../confignode/it/removedatanode/SQLModel.java} | 8 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 45 +
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 7 +
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 1 +
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 71 ++
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 59 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 38 +
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 3 +-
.../IoTDBAlignByDeviceWithTemplateIT.java | 28 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 83 ++
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 2 -
.../org/apache/iotdb/db/it/utils/TestUtils.java | 65 ++
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 51 +
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 95 ++
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 72 ++
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 16 +-
.../iotdb/pipe/it/manual/IoTDBPipeInclusionIT.java | 12 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 12 +-
.../pipe/it/manual/IoTDBPipePermissionIT.java | 70 +-
.../pipe/it/manual/IoTDBPipeTypeConversionIT.java | 2 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 42 +
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 36 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 69 ++
.../param/IoTDBTestParamPullConsumerIT.java | 8 +-
.../param/IoTDBTestParamPushConsumerIT.java | 8 +-
.../regression/param/IoTDBTestParamTopicIT.java | 13 +-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 4 +-
.../apache/iotdb/tools/it/ExportSchemaTestIT.java | 4 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 8 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 4 +-
.../apache/iotdb/tools/it/ImportSchemaTestIT.java | 4 +-
.../java/org/apache/iotdb/util/MagicUtils.java | 61 +
.../src/test/resources/logback-test.xml | 2 +-
.../parameter/PipeParameterValidator.java | 42 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 4 +-
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 31 +-
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 12 +-
.../iotdb/tool/tsfile/ImportTsFileLocally.java | 8 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 8 +
iotdb-client/client-py/iotdb/Session.py | 59 +-
iotdb-client/client-py/iotdb/SessionPool.py | 15 +-
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 3 -
.../apache/iotdb/rpc/TElasticFramedTransport.java | 15 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 6 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 33 +-
.../subscription/payload/poll/TabletsPayload.java | 11 +-
.../iotdb/rpc/TElasticFramedTransportTest.java | 71 ++
.../java/org/apache/iotdb/session/Session.java | 6 +
.../apache/iotdb/session/SessionConnection.java | 1195 ++++++--------------
.../session/subscription/SubscriptionSession.java | 17 +-
.../consumer/SubscriptionConsumer.java | 32 +-
.../consumer/SubscriptionProviders.java | 48 +-
.../consumer/SubscriptionPullConsumer.java | 7 +-
.../consumer/SubscriptionPushConsumer.java | 3 +-
.../payload/SubscriptionFileHandler.java | 24 +-
.../session/subscription/util/IdentifierUtils.java | 10 +-
.../org/apache/iotdb/session/util/RetryUtils.java | 37 +-
.../ainode/iotdb/ainode/model/model_factory.py | 2 -
iotdb-core/ainode/pyproject.toml | 12 +-
iotdb-core/ainode/resources/conf/ainode-env.sh | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 26 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 16 +
iotdb-core/confignode/pom.xml | 6 +
.../assembly/resources/sbin/remove-confignode.bat | 135 ---
.../assembly/resources/sbin/remove-confignode.sh | 69 --
.../iotdb/confignode/conf/ConfigNodeConfig.java | 9 +
.../confignode/conf/ConfigNodeDescriptor.java | 18 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 5 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../partition/AutoCleanPartitionTablePlan.java | 99 ++
.../pipe/payload/PipeDeleteLogicalViewPlan.java | 5 +-
.../pipe/payload/PipeDeleteTimeSeriesPlan.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 46 +-
.../apache/iotdb/confignode/manager/IManager.java | 9 +
.../iotdb/confignode/manager/ProcedureManager.java | 476 ++++++--
.../iotdb/confignode/manager/TTLManager.java | 11 +
.../iotdb/confignode/manager/load/LoadManager.java | 9 -
.../manager/load/balancer/RouteBalancer.java | 7 +-
.../router/priority/GreedyPriorityBalancer.java | 42 +-
.../router/priority/IPriorityBalancer.java | 5 +-
.../router/priority/LeaderPriorityBalancer.java | 21 +-
.../confignode/manager/load/cache/LoadCache.java | 29 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 3 +-
.../load/cache/region/RegionGroupCache.java | 39 +-
.../iotdb/confignode/manager/node/NodeManager.java | 8 +-
.../manager/partition/PartitionManager.java | 13 +-
.../manager/partition/RegionGroupStatus.java | 25 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 8 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 6 +
.../protocol/IoTDBConfigRegionConnector.java | 8 +-
.../runtime/PipeRuntimeCoordinator.java | 4 +-
.../runtime/heartbeat/PipeHeartbeat.java | 8 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 3 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 12 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 119 ++
.../iotdb/confignode/persistence/TTLInfo.java | 16 +
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../partition/DatabasePartitionTable.java | 10 +
.../persistence/partition/PartitionInfo.java | 19 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 12 +-
.../confignode/procedure/InternalProcedure.java | 5 -
.../procedure/PartitionTableAutoCleaner.java | 81 ++
.../iotdb/confignode/procedure/Procedure.java | 78 --
.../confignode/procedure/ProcedureExecutor.java | 115 +-
.../procedure/env/RegionMaintainHandler.java | 40 +-
.../procedure/impl/StateMachineProcedure.java | 186 ++-
.../impl/region/AddRegionPeerProcedure.java | 88 +-
.../impl/region/ReconstructRegionProcedure.java | 209 ++++
.../impl/region/RegionMigrateProcedure.java | 69 +-
.../impl/region/RegionOperationProcedure.java} | 33 +-
.../impl/region/RemoveRegionPeerProcedure.java | 62 +-
.../impl/schema/AlterLogicalViewProcedure.java | 112 +-
.../procedure/impl/sync/StartPipeProcedure.java | 6 -
...itionState.java => ReconstructRegionState.java} | 8 +-
.../procedure/store/ProcedureFactory.java | 5 +
.../confignode/procedure/store/ProcedureType.java | 5 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 18 +
.../confignode/conf/ConfigNodePropertiesTest.java | 50 +
.../request/ConfigPhysicalPlanSerDeTest.java | 19 +
.../confignode/manager/load/LoadManagerTest.java | 12 +-
.../router/priority/GreedyPriorityTest.java | 13 +-
.../priority/LeaderPriorityBalancerTest.java | 65 +-
.../manager/load/cache/RegionGroupCacheTest.java | 132 ++-
.../confignode/procedure/entity/IncProcedure.java | 5 -
.../confignode/procedure/entity/NoopProcedure.java | 5 -
.../procedure/entity/SimpleLockProcedure.java | 5 -
.../procedure/entity/SleepProcedure.java | 5 -
.../procedure/entity/StuckProcedure.java | 5 -
.../org/apache/iotdb/consensus/IConsensus.java | 21 +-
.../org/apache/iotdb/consensus/common/Peer.java | 13 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 115 +-
.../consensus/iot/IoTConsensusServerImpl.java | 255 +----
.../consensus/iot/logdispatcher/LogDispatcher.java | 9 +-
.../service/IoTConsensusRPCServiceProcessor.java | 15 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 142 ++-
.../apache/iotdb/consensus/ratis/RatisClient.java | 6 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 101 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 1 +
.../iotdb/consensus/simple/SimpleConsensus.java | 12 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 67 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 82 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 -
iotdb-core/datanode/pom.xml | 6 +
.../assembly/resources/sbin/remove-datanode.bat | 148 ---
.../src/assembly/resources/sbin/remove-datanode.sh | 91 --
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 9 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 50 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 238 ++--
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 18 +-
.../dataregion/DataExecutionVisitor.java | 3 +
.../dataregion/DataRegionStateMachine.java | 143 +--
.../schemaregion/SchemaExecutionVisitor.java | 18 +-
...nlyException.java => LoadAnalyzeException.java} | 11 +-
....java => LoadAnalyzeTypeMismatchException.java} | 9 +-
.../db/exception/VerifyMetadataException.java | 38 -
.../{ => load}/LoadEmptyFileException.java | 2 +-
.../db/exception/{ => load}/LoadFileException.java | 2 +-
.../{ => load}/LoadReadOnlyException.java | 2 +-
.../LoadRuntimeOutOfMemoryException.java | 2 +-
.../{ => load}/PartitionViolationException.java | 2 +-
.../load/RegionReplicaSetChangedException.java} | 25 +-
.../exception/sql/StatementAnalyzeException.java | 4 +
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 3 +-
.../agent/runtime/SimpleProgressIndexAssigner.java | 36 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 59 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 12 +-
.../agent/task/connection/PipeEventCollector.java | 11 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 9 +-
.../subtask/connector/PipeConnectorSubtask.java | 2 +-
.../PipeRealtimePriorityBlockingQueue.java | 2 +
.../subtask/processor/PipeProcessorSubtask.java | 5 +-
.../processor/PipeProcessorSubtaskWorker.java | 11 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 16 +-
.../client/IoTDBDataNodeSyncClientManager.java | 8 +-
.../batch/PipeTabletEventTsFileBatch.java | 3 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 6 +
.../async/IoTDBDataRegionAsyncConnector.java | 19 +-
.../handler/PipeTransferTrackableHandler.java | 33 +-
.../async/handler/PipeTransferTsFileHandler.java | 79 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 8 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 7 +-
.../consensus/ConsensusPipeDataNodeDispatcher.java | 11 +
.../schema/PipeSchemaRegionSnapshotEvent.java | 6 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 39 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 83 +-
.../scan/TsFileInsertionScanDataContainer.java | 19 +
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 6 +
.../PipeRealtimeDataRegionHybridExtractor.java | 136 ++-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 20 +-
.../iotdb/db/pipe/metric/PipeResourceMetrics.java | 34 +
.../protocol/legacy/loader/DeletionLoader.java | 2 +-
.../protocol/legacy/loader/TsFileLoader.java | 3 +-
.../pipeconsensus/PipeConsensusReceiver.java | 31 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 77 +-
.../statement/PipeConvertedInsertRowStatement.java | 30 +-
.../PipeConvertedInsertTabletStatement.java | 52 +-
.../visitor/PipePlanToStatementVisitor.java | 8 +-
...peStatementDataTypeConvertExecutionVisitor.java | 3 +-
.../visitor/PipeStatementExceptionVisitor.java | 2 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 3 +
.../db/pipe/resource/memory/PipeMemoryBlock.java | 14 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 137 ++-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 48 +
.../resource/tsfile/PipeTsFileResourceManager.java | 20 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 24 +-
.../db/protocol/rest/impl/PingApiServiceImpl.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 10 +-
.../thrift/impl/DataNodeRegionManager.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 44 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 17 +-
.../plan/analyze/LoadTsFileAnalyzer.java | 78 +-
.../plan/analyze/TemplatedAggregationAnalyze.java | 6 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 7 +-
.../analyze/cache/partition/PartitionCache.java | 7 +-
.../plan/execution/config/ConfigTaskVisitor.java | 54 +-
.../config/executor/ClusterConfigTaskExecutor.java | 199 +++-
.../config/executor/IConfigTaskExecutor.java | 19 +-
...teRegionTask.java => RemoveConfigNodeTask.java} | 12 +-
...rateRegionTask.java => RemoveDataNodeTask.java} | 12 +-
.../ExtendRegionTask.java} | 14 +-
.../metadata/{ => region}/MigrateRegionTask.java | 4 +-
.../ReconstructRegionTask.java} | 14 +-
.../RemoveRegionTask.java} | 14 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 61 +-
.../plan/planner/LocalExecutionPlanner.java | 9 +
.../plan/node/load/LoadTsFilePieceNode.java | 6 +-
.../metedata/write/view/AlterLogicalViewNode.java | 47 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 24 +
.../plan/node/pipe/PipeEnrichedInsertNode.java | 5 +
.../ContinuousSameSearchIndexSeparatorNode.java | 6 +
.../planner/plan/node/write/DeleteDataNode.java | 36 +
.../plan/node/write/InsertMultiTabletsNode.java | 5 +
.../plan/planner/plan/node/write/InsertNode.java | 22 +
.../planner/plan/node/write/InsertRowNode.java | 12 +
.../planner/plan/node/write/InsertRowsNode.java | 15 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 5 +
.../planner/plan/node/write/InsertTabletNode.java | 11 +
.../plan/planner/plan/node/write/SearchNode.java | 4 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 195 +++-
.../db/queryengine/plan/statement/Statement.java | 6 +-
.../plan/statement/StatementVisitor.java | 28 +-
.../plan/statement/crud/InsertBaseStatement.java | 6 +-
.../plan/statement/crud/InsertRowStatement.java | 18 +-
.../plan/statement/crud/LoadTsFileStatement.java | 80 +-
.../metadata/CountTimeSlotListStatement.java | 7 +
.../statement/metadata/GetRegionIdStatement.java | 7 +
.../metadata/GetSeriesSlotListStatement.java | 7 +
.../metadata/GetTimeSlotListStatement.java | 7 +
.../RemoveConfigNodeStatement.java} | 32 +-
...Statement.java => RemoveDataNodeStatement.java} | 37 +-
.../statement/metadata/ShowClusterIdStatement.java | 7 +
.../statement/metadata/ShowClusterStatement.java | 9 +-
.../metadata/ShowConfigNodesStatement.java | 4 +-
.../statement/metadata/ShowDataNodesStatement.java | 4 +-
.../statement/metadata/ShowRegionStatement.java | 4 +-
.../metadata/model/ShowAINodesStatement.java | 7 +
.../ExtendRegionStatement.java} | 44 +-
.../{ => region}/MigrateRegionStatement.java | 9 +-
.../ReconstructRegionStatement.java} | 42 +-
.../RemoveRegionStatement.java} | 44 +-
.../plan/statement/sys/KillQueryStatement.java | 9 +-
.../plan/statement/sys/ShowQueriesStatement.java | 9 +-
.../statement/sys/TestConnectionStatement.java | 3 +-
.../schemaengine/schemaregion/utils/MetaUtils.java | 9 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 93 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 22 +-
.../{RPCService.java => ExternalRPCService.java} | 6 +-
...viceMBean.java => ExternalRPCServiceMBean.java} | 2 +-
.../db/service/metrics/CompactionMetrics.java | 24 +
.../db/service/metrics/file/TsFileMetrics.java | 49 +-
.../iotdb/db/storageengine/StorageEngine.java | 73 +-
.../db/storageengine/buffer/BloomFilterCache.java | 28 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 27 +-
.../buffer/TimeSeriesMetadataCache.java | 56 +-
.../db/storageengine/dataregion/DataRegion.java | 171 +--
...a => CompactionSourceFileDeletedException.java} | 7 +-
.../performer/impl/FastCompactionPerformer.java | 15 +
.../execute/task/InnerSpaceCompactionTask.java | 15 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 7 +-
.../compaction/io/CompactionTsFileReader.java | 14 +-
.../compaction/repair/RepairDataFileScanUtil.java | 32 +-
.../schedule/CompactionScheduleContext.java | 42 +-
.../compaction/schedule/CompactionScheduler.java | 60 +-
.../compaction/schedule/CompactionTaskManager.java | 15 +-
.../compaction/schedule/CompactionWorker.java | 7 +-
.../compaction/schedule/TTLScheduleTask.java | 4 +-
.../DefaultCompactionTaskComparatorImpl.java | 16 +-
.../estimator/AbstractCrossSpaceEstimator.java | 7 +-
.../estimator/AbstractInnerSpaceEstimator.java | 8 +-
.../estimator/CompactionEstimateUtils.java | 35 +-
.../FastCompactionInnerCompactionEstimator.java | 16 +-
.../FastCrossSpaceCompactionEstimator.java | 17 +-
...eQueryMemMeasurement.java => MetadataInfo.java} | 30 +-
.../ReadChunkInnerCompactionEstimator.java | 15 +-
.../impl/NewSizeTieredCompactionSelector.java | 2 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 46 +-
.../utils/CrossSpaceCompactionCandidate.java | 4 +-
.../selector/utils/TsFileResourceCandidate.java | 76 +-
.../reader/common/CachedPriorityMergeReader.java | 97 --
.../reader/common/DescPriorityMergeReader.java | 16 +-
.../read/reader/common/PriorityMergeReader.java | 22 +-
.../dataregion/tsfile/TsFileResource.java | 36 +-
.../tsfile/timeindex/DeviceTimeIndex.java | 2 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 2 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 2 +-
.../wal/allocation/FirstCreateStrategy.java | 1 +
.../storageengine/dataregion/wal/node/WALNode.java | 8 +-
.../db/storageengine/load/LoadTsFileManager.java | 24 +-
.../load/active/ActiveLoadDirScanner.java | 27 +-
.../load/active/ActiveLoadTsFileLoader.java | 17 +-
.../load/config/LoadTsFileConfigurator.java | 53 +-
.../LoadConvertedInsertTabletStatement.java} | 38 +-
...ertedInsertTabletStatementExceptionVisitor.java | 51 +
...vertedInsertTabletStatementTSStatusVisitor.java | 65 ++
...eeStatementDataTypeConvertExecutionVisitor.java | 135 +++
.../converter/LoadTsFileDataTypeConverter.java | 90 ++
.../memory/LoadTsFileAnalyzeSchemaMemoryBlock.java | 12 +-
.../memory/LoadTsFileDataCacheMemoryBlock.java | 40 +-
.../load/memory/LoadTsFileMemoryManager.java | 12 +-
.../load/metrics/LoadTsFileCostMetricsSet.java | 13 +-
.../load/splitter/TsFileSplitter.java | 40 +-
.../rescon/memory/TsFileResourceManager.java | 2 +-
.../db/subscription/broker/SubscriptionBroker.java | 104 +-
.../broker/SubscriptionPrefetchingQueue.java | 66 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 96 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 14 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 14 +-
.../db/subscription/broker/SubscriptionStates.java | 30 +-
.../db/subscription/event/SubscriptionEvent.java | 87 +-
.../event/batch/SubscriptionPipeEventBatch.java | 30 -
.../batch/SubscriptionPipeTabletEventBatch.java | 155 ++-
.../SubscriptionPipeTabletIterationSnapshot.java | 62 +
.../batch/SubscriptionPipeTsFileEventBatch.java | 15 -
.../cache/CachedSubscriptionPollResponse.java | 5 +
.../event/cache/SubscriptionPollResponseCache.java | 11 +
.../event/pipe/SubscriptionPipeEmptyEvent.java | 4 +-
.../pipe/SubscriptionPipeTabletBatchEvents.java | 45 +-
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 8 +-
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 8 +-
.../SubscriptionEventExtendableResponse.java | 7 +-
.../event/response/SubscriptionEventResponse.java | 3 +-
.../response/SubscriptionEventSingleResponse.java | 1 +
.../response/SubscriptionEventTabletResponse.java | 232 +++-
.../response/SubscriptionEventTsFileResponse.java | 41 +-
.../receiver/SubscriptionReceiverV1.java | 2 +-
.../db/tools/schema/SRStatementGenerator.java | 28 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 24 +-
.../iotdb/db/utils/TimestampPrecisionUtils.java | 4 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 6 +-
.../db/utils/datastructure/BooleanTVList.java | 6 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 6 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 6 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 6 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 6 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 4 +-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 107 ++
.../dataregion/DataRegionStateMachineTest.java | 4 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 9 +-
.../db/protocol/rest/IoTDBRestServiceTest.java | 6 +-
.../iotdb/db/storageengine/StorageEngineTest.java | 2 +
.../storageengine/buffer/BloomFilterCacheTest.java | 29 +-
.../storageengine/dataregion/DataRegionTest.java | 24 +-
.../BatchedCompactionWithTsFileSplitterTest.java | 15 +-
.../compaction/CompactionTaskComparatorTest.java | 2 +-
.../compaction/CompactionWorkerTest.java | 33 +
.../cross/CrossSpaceCompactionSelectorTest.java | 102 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 4 +-
.../cross/InsertionCrossSpaceCompactionTest.java | 64 +-
.../inner/InnerSequenceCompactionSpeedTest.java | 43 +
.../NewSizeTieredCompactionSelectorTest.java | 30 +
.../repair/RepairDataFileScanUtilTest.java | 2 +-
.../repair/RepairUnsortedFileCompactionTest.java | 52 +
.../compaction/utils/CompactionCheckerUtils.java | 32 +-
.../utils/CompactionTaskMemCostEstimatorTest.java | 48 +
...SeriesReader.java => AscFakedSeriesReader.java} | 28 +-
.../read/reader/common/DescFakedSeriesReader.java} | 42 +-
.../reader/common/PriorityMergeReaderTest.java | 113 +-
.../reader/common/PriorityMergeReaderTest2.java | 59 -
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 14 +
.../db/utils/TimestampPrecisionUtilsTest.java | 10 +
.../datanode/src/test/resources/logback-test.xml | 2 +-
.../metrics/config/MetricConfigDescriptor.java | 6 +-
.../reporter/prometheus/PrometheusReporter.java | 5 +-
.../conf/iotdb-system.properties.template | 21 +-
.../src/assembly/resources/sbin/health_check.bat | 2 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 6 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 8 +-
.../apache/iotdb/commons/client/ThriftClient.java | 17 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 142 ++-
.../iotdb/commons/conf/CommonDescriptor.java | 94 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 22 +-
.../TrimProperties.java} | 55 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 7 +-
.../commons/executable/ExecutableManager.java | 6 +
.../commons/partition/DataPartitionTable.java | 12 +
.../commons/partition/SeriesPartitionTable.java | 16 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 52 +-
.../task/connection/BlockingPendingQueue.java | 14 +
.../iotdb/commons/pipe/config/PipeConfig.java | 24 +-
.../config/constant/PipeConnectorConstant.java | 9 +
...emConstant.java => PipeRPCMessageConstant.java} | 11 +-
.../pipe/connector/client/IoTDBClientManager.java | 10 +-
.../connector/client/IoTDBSyncClientManager.java | 42 +-
.../common/PipeTransferHandshakeConstant.java | 2 +
.../connector/protocol/IoTDBAirGapConnector.java | 10 +-
.../pipe/connector/protocol/IoTDBConnector.java | 26 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 8 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 32 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 7 +-
.../snapshot/PipeSnapshotResourceManager.java | 9 +-
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 27 +
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../subscription/config/SubscriptionConfig.java | 47 +-
.../commons/subscription/meta/topic/TopicMeta.java | 4 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 22 +
.../utils/{TestOnly.java => RetryUtils.java} | 38 +-
.../iotdb/commons/utils/TimePartitionUtils.java | 13 +
.../src/main/thrift/confignode.thrift | 23 +-
.../iotdb/library/dprofile/UDAFIntegral.java | 41 +-
.../iotdb/library/dprofile/UDTFResample.java | 6 +-
.../iotdb/library/dquality/UDTFCompleteness.java | 3 +-
.../iotdb/library/dquality/UDTFConsistency.java | 2 +-
.../iotdb/library/dquality/UDTFTimeliness.java | 3 +-
.../iotdb/library/dquality/UDTFValidity.java | 3 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 47 +-
.../library/drepair/util/TimestampInterval.java | 22 +-
.../library/drepair/util/TimestampRepair.java | 2 +-
.../apache/iotdb/library/frequency/UDTFIFFT.java | 7 +-
.../iotdb/library/match/PatternExecutor.java | 2 +-
.../iotdb/library/match/UDAFPatternMatch.java | 62 +-
.../library/series/UDTFConsecutiveSequences.java | 5 +-
.../library/series/UDTFConsecutiveWindows.java | 11 +-
.../java/org/apache/iotdb/library/util/Util.java | 90 +-
.../org/apache/iotdb/library/UDAFPatternTest.java | 70 ++
pom.xml | 23 +-
473 files changed, 10977 insertions(+), 5496 deletions(-)
create mode 100644 .github/workflows/todos-check.yml
rename
integration-test/src/test/java/org/apache/iotdb/cli/it/{AbstractScript.java =>
AbstractScriptIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBAutoRegionGroupExtensionIT2.java
=> IoTDBAutoRegionGroupExtension2IT.java} (98%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionTableAutoCleanIT.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/{IoTDBRegionMigrateReliabilityITFramework.java
=> IoTDBRegionOperationReliabilityITFramework.java} (77%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionReconstructForIoTV1IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/removeconfignode/IoTDBRemoveConfigNodeITFramework.java
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/{removedatanode/IoTDBRemoveDataNodeNormalIT.java
=> removeconfignode/IoTDBRemoveConfigNodeNormalIT.java} (76%)
copy
integration-test/src/{main/java/org/apache/iotdb/itbase/category/MultiClusterIT2SubscriptionRegressionConsumer.java
=> test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java} (87%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/util/MagicUtils.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TElasticFramedTransportTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeType.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/RetryUtils.java
(59%)
delete mode 100644
iotdb-core/confignode/src/assembly/resources/sbin/remove-confignode.bat
delete mode 100755
iotdb-core/confignode/src/assembly/resources/sbin/remove-confignode.sh
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/partition/AutoCleanPartitionTablePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/ReconstructRegionProcedure.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RegionOperationProcedure.java}
(54%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{RegionTransitionState.java
=> ReconstructRegionState.java} (93%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodePropertiesTest.java
delete mode 100644
iotdb-core/datanode/src/assembly/resources/sbin/remove-datanode.bat
delete mode 100755
iotdb-core/datanode/src/assembly/resources/sbin/remove-datanode.sh
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{LoadReadOnlyException.java
=> LoadAnalyzeException.java} (77%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ainode/GetModelInfoException.java
=> LoadAnalyzeTypeMismatchException.java} (77%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/VerifyMetadataException.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadEmptyFileException.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadFileException.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadReadOnlyException.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadRuntimeOutOfMemoryException.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/PartitionViolationException.java (96%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/partition/RegionReplicaSetInfo.java
=>
datanode/src/main/java/org/apache/iotdb/db/exception/load/RegionReplicaSetChangedException.java}
(62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{MigrateRegionTask.java
=> RemoveConfigNodeTask.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{MigrateRegionTask.java
=> RemoveDataNodeTask.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{SetTTLTask.java
=> region/ExtendRegionTask.java} (79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{
=> region}/MigrateRegionTask.java (94%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{CreateTriggerTask.java
=> region/ReconstructRegionTask.java} (73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{SetTTLTask.java
=> region/RemoveRegionTask.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys/TestConnectionStatement.java
=> metadata/RemoveConfigNodeStatement.java} (75%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{ShowFunctionsStatement.java
=> RemoveDataNodeStatement.java} (73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{model/DropModelStatement.java
=> region/ExtendRegionStatement.java} (70%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{
=> region}/MigrateRegionStatement.java (87%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{model/DropModelStatement.java
=> region/ReconstructRegionStatement.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{model/DropModelStatement.java
=> region/RemoveRegionStatement.java} (70%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/{RPCService.java
=> ExternalRPCService.java} (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/{RPCServiceMBean.java
=> ExternalRPCServiceMBean.java} (96%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/{CompactionMemoryNotEnoughException.java
=> CompactionSourceFileDeletedException.java} (81%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/{IFileQueryMemMeasurement.java
=> MetadataInfo.java} (53%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/CachedPriorityMergeReader.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/receiver/transform/statement/PipeConvertedInsertTabletStatement.java
=> storageengine/load/converter/LoadConvertedInsertTabletStatement.java} (57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatementExceptionVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatementTSStatusVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileDataTypeConverter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletIterationSnapshot.java
create mode 100755
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/PropertiesTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/{FakedSeriesReader.java
=> AscFakedSeriesReader.java} (79%)
copy
iotdb-core/datanode/src/{main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/AlignedDescPriorityMergeReader.java
=>
test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/DescFakedSeriesReader.java}
(50%)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/PriorityMergeReaderTest2.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{udf/builtin/UDTFNonZeroCount.java
=> conf/TrimProperties.java} (54%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/{SystemConstant.java
=> PipeRPCMessageConstant.java} (73%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/{TestOnly.java
=> RetryUtils.java} (60%)
