You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2023/07/28 04:18:13 UTC
[iotdb] branch IOTDB-5662-1.1 updated (3cb26d6b0f3 -> 60bb0ca645b)
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch IOTDB-5662-1.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 3cb26d6b0f3 fix ci
omit 7151a81f145 fix issue and add test
add 2201b7e0905 [IOTDB-5612] [doc] Remove some functions which are not built-in from doc (#9317)
add 2a2084e4165 [To rel/1.1] change log in ShuffleSinkHandle
add b399af0e9cb [To rel/1.1] [IOTDB-5668] fix loading the tsfile which is from export-tsfile failed when the specified encoding type is different from default
add 5d535d27873 [To rel/1.1] [IOTDB-5671] Fix inode cannot be released after deletion causing waste of disk space
add d9fe7d83ee2 [To rel/1.1] [IOTDB-5519] Improve the concurrency control of DatabaseSchema (#9325)
add c7e5ba2f683 [To rel/1.1] Update markdown table style (#9332)
add 7edc34e7574 [To rel/1.1][IOTDB-5674] Remove useless log in MicrometerAutoGauge (#9335)
add 7be208e72a9 allow submitting tasks when queue is full (#9305)
add 0e006735120 [To rel/1.1] Fix CI error (#9341)
add 6f4269da35f [IOTDB-5676] Improve ConfigurationException description and analyzing of cluster parameters (#9334) (#9340)
add e3cd98ef9f9 [To rel/1.1] Fix dispatch result collection logic (#9323)
add 36317105dad [IOTDB-5682] Fix the update of nodeId in Metrics (#9344) (#9346)
add 23874ae25ad [To rel/1.1][IOTDB-5675] Metric of Schema Template (#9349)
add 80c1ec6a708 [To rel/1.1][IOTDB-5688] ShcemaFile mode lost template schema after reboot in SimpleConsensus (#9351)
add 61027728550 [IOTDB-5684] Standardize log folder of ConfigNode's Simple consensus protocol (#9353)
add 4012ecb888c [To rel/1.1][IOTDB-5685] Fix error msg of failing to create a timeseries on an existing path when ReadOnly state (#9354)
add 53976603365 [To rel/1.1][IOTDB-5651] Fix compaction UT
add e70d7ce4e73 [IOTDB-5695] Ensures backward compatibility between 1.0 and 1.1 for ConfigNode when using SimpleConsensus (#9367)
add 0595b5fe04d [To rel/1.1][IOTDB-5689] Close Isink when ISourceHandle is closed
add ba19b4cd714 [IOTDB-5368] add port check for confignode and datanode (#9270) (#9371)
add 3e6166ed85e [To rel/1.1][IOTDB-5618] Add RatisConsensus metrics in dashboard (#9369)
add 4fd07ce21df [IOTDB-5681] Fix the creation of system database used by IoTDB Internal Reporter (#9339)
add 531b80285e6 Revert "[IOTDB-5681] Fix the creation of system database used by IoTDB Internal Reporter (#9339)"
add 016225495cc [IOTDB-5681] Fix the creation of system database used by IoTDB Internal Reporter (#9339) (#9378)
add 93682ec187e [IOTDB-5697] Only record engine cost for DataRegion in Performance Overview Dashboard (#9366) (#9377)
add 8ad9a7d002a fix show queries after introduce Shuffle
add 1f605d5ba1e [To rel/1.1] Fix possible npe when closing IdentitySinkOperator
add 10f63b7e251 [To rel/1.1][IOTDB-5580] Add limitation of time and tsBlock size to MergeSortOperator (#9220)
add fe414cfab77 [IOTDB-5700] Clean temporary files created by UDF query after it finishes (#9376) (#9380)
add 71633206ca0 [To rel/1.1][IOTDB-5686] Fix devices with the same name but different alignment properties meets error in inner seq compaction
add 575a8404367 [IOTDB-5705] Replace data_region_per_processor by data_region_per_data_node (#9386) (#9393)
add ff28665e98c [To rel/1.1][IOTDB-5704] change default write parameter for wal part (#9395)
add ad9c4015246 [TO rel/1.1][IOTDB-5704] fix default comments for previously changed parameters (#9397)
add d8a34fbf070 [To rel/1.1][IOTDB-5639][compaction]Fix file not found exception in cross space compaction selector (#9255)
add 918d433cd39 [IOTDB-5701] Optimize the management of performance overview related metrics (#9381) (#9396)
add a9049c6a97d [To rel/1.1] Correct CQ example in docs (#9407)
add 96e8cb46878 Seperate disk dashboard (#9413)
add 5f036a98efe Compatible with the client parameters on DataNode (#9421)
add bef4c24b135 [To rel/1.1] [IOTDB-5715] Improve the performance of query order by time desc
add bea5a2f8ca4 remove aligned time series id in nonAligned measurement iterator (#9411)
add b52b751452d [IOTDB-5716] Wrong dependency when pipeline consumeOneByOneOperator
add 9784a6707dd [To rel/1.1][IOTDB-5720] Fix release processor fail to release memory due to writer-preferred starvation (#9422)
add 4f235f67c86 [IOTDB-5718] Fix wrong time order due to overflow in MergeSort
add 494e8662730 [IOTDB-5717] Fix incorrect result when querying with limit push-downing
add fbf2ecc5e94 [To rel/1.1] [IOTDB-5722] Fix wrong default execution branch in PlanVisitor (#9437)
add dba70f8e3d1 [IOTDB-5701] Fix typo in Performance Overview Related Metrics (#9449)
add 9d45e81b69f update RELEASE_NOTES.md (#9451)
add 5037e12f671 [To rel/1.1][IOTDB-5729] Fix RatisConsensus ResponseMessage conversion error (#9455)
add fc24ec81459 [To rel/1.1][IOTDB-5730] Fix use a hard link when loading a SchemaFile snapshot (#9461)
add 96b0d796d70 [To rel/1.1][IOTDB-5732] Add Device Schema Statistics (#9465)
add f53f0b6bab8 [To rel/1.1][IOTDB-5725] Make internal report recording measurements asynchronous (#9440)
add 57b2c0f681a [To rel/1.1][IOTDB-5121] Fix download link of Library-UDF (#9470)
add c12c44fd20a [To rel/1.1] Remove Dashboard and update docs (#9473)
add 3c515150881 [To rel/1.1][IOTDB-5687][REST Service] OpenAPI v2 interface (#9472) (#9478)
add ce038eaf62c [IOTDB-5738] Retain 2 copies of snapshot (#9474) (#9475)
add f952730833a cherry pick network metrics (#9487)
add cf12987b24f [To rel/1.1]Fix WrappedSegment extension with big name on edge case (#9484)
add b120b59d583 [To rel/1.1] Fix template type check on ClusterTemplateManager (#9493)
add a4bb9ab63ac feat(docs):site img move to alioss (#9509)
add 597b1fc9a64 [To rel/1.1] Change version number to 1.1.1-SNAPSHOT (#9512)
add 6f57dc797b7 [To Rel/1.1]Update markdown table format and benchmark link in UserGuide (#9527)
add 32b8276a43b [To rel/1.1] [ISSUE-9508] Fix the bug of UDF Median and Percentile
add 619639a0697 [To rel/1.1] Make DeviceId as KeyWords
add de4216dc3e4 [To rel/1.1][IOTDB-5755] Fix the problem that token DURATION_INTERVAL can not be used in Identifier (#9523)
add 9c9f93b1173 [To rel/1.1] Update Jenkinsfile
add 879d6b180cb [To rel/1.1][IOTDB-5719] Cluster-Wide Time Series Limit Control (#9430)
add f6b72540e68 docker deploy for v1.1.0, update docs,docker-compose files and Dockerfile (#9530)
add cf669440d8f [To rel/1.1] Fix a memory free bug and delete useless O(N^2) check in DriverContext
add 14edf20e06d [To rel/1.1] Fix Context release source NPE
add 88fc2cb70d7 [IOTDB-5756] NPE when where predicate is NotEqualExpression and one of subExpression is not exist
add c15e779a511 [To rel/1.1][IOTDB-5757] Fix Not Supported Exception when use like 's3 || false' in where even Type of s3 is Boolean
add 78ee634f17a [To rel/1.1] Adapt insert data by 0.13 client (#9545)
add f0376912b33 [IOTDB-5204 ] Add last task rather than first task to timeoutQueue
add 5834c5eb9b6 [IOTDB-5761] Open channel of ShuffleSinkHandle after the drivertask begins
add 893b79bf001 [IOTDB-5466] Refactor RaftLog disk monitor to avoid unnecessary snapshots (#9515) (#9554)
add b89cd0da07b [To rel/1.1] [IOTDB-5760] Query is blocked because of no memory
add d49f819a2bc [To rel/1.1] Rename cluster_schema_limit_level parameter name to timeseries (#9563)
add a7362fefb93 [To rel/1.1] Rename cluster_max_schema_count parameter name to cluster_schema_limit_threshold (#9576)
add 0927716edf9 [To rel/1.1] Improve ineffective check in ColumnEncoderFactory
add 1aab3aa1e48 [To rel/1.1] Fix potential NPE in SinkChannel
add 73afe2d2ab5 [To rel/1.1] Delete ISeriesMonitor interface (#9584)
add 3387424bbc6 [To rel/1.1] Fix MemoryPool free NPE
add a52d1e35786 bump ratis version to 2.5.0 (#9588)
add e1cbe761c33 [To rel/1.1] Fix Performance Overview Dashboard localScheduler record inaccurately (#9550)
add 0346f2fd71c [To rel/1.1] Fix SchemaEngine memory control concurrent bug (#9602)
add 7ccd2f8f094 [To rel/1.1][IOTDB-5766] Refactor listener of ISinkChannel to ensure that ShuffleSinkHandle is closed properly
add d404c25f7f7 [To rel/1.1][IOTDB-5726]Select the last sealed seq file for nonOverlap unseq files to compact in cross compaction (#9502)
add 9c5c1bfda9a [To rel/1.1][IOTDB-5707] Support CreateTimeSeriesUsingTemplate in Session (#9606)
add 33dc0bfcf9f [To rel/1.1] [IOTDB-5764] Fix that cannot specify alias successfully when the FROM clause contains multiple path suffixes (#9598)
add 553e8de8df7 [To rel/1.1] [IOTDB-5763] Optimize the memory estimate for INTO operations (#9599)
add ae0111a4af6 [To rel/1.1] Accelerate count all schema via schema statistic (#9609)
add 046ada8645b [To rel/1.1] Fix unexcepted error message when use raw query with Group By Tag
add 51161c0afdc [To rel/1.1] Fix Group By Tag with empty grouped timeseries
add ea17746e33a [To rel/1.1] Fix potential resource leak in Memory Pool
add e88103fe190 [IOTDB-2569]Support ZSTD Compression (#9231) (#9630)
add 90fcf39aacd [To rel/1.1] Fix time partition interval config load bug (#9634)
add 8ae80946a56 [To rel/1.1] Resolve quadratic complexity issue when flushing numerous Internal/Entity nodes in SchemaFile (#9631)
add 0fcd92a7f2e Open [To rel/1.1][IOTDB-5762][Metric] remove session metrics when close (#9625)
add c90d1047cf2 [To rel/1.1] distinguish whether an exception has occurred when releasing the QueryExecution resource
add 197890bba81 [To rel/1.1][IOTDB-5719] Move DataNode's checking of SchemaQuota above the consensus layer (#9626)
add 21338fe7741 [To rel/1.1][IOTDB-5776]Update memory estimation of cross space compaction (#9628)
add 8c31ae2b8ad [To rel/1.1][IOTDB-5691] The first level-0 tsfile too large to trigger "Unsequence InnerSpaceComapction" and "CrossSpaceCompaction" (#9504)
add b50469b39aa [To rel/1.1] Fix potential Npe of ShuffleSinkHandle
add a8e4e158646 [To rel/1.1][IOTDB-5798] Fix bug caused by acknowledgeTsBlock
add e68572aec11 [IOTDB-5762][Metric] add do nothing level(#9615) (#9632)
add 5e98877b5d6 [To rel/1.1] Add a cache to avoid initialize duplicated device id object in write process (#9647)
add 037a9bdcb20 [To rel/1.1][IOTDB-5786] Fix potential deadlock in DriverScheduler
add 177578964c3 [IOTDB-5784] Incorrect result when querying with offset push-down and time filter
add 818f8e37385 [To rel/1.1] remove check of closed state in ISink
add fb1d4266306 [To rel/1.1] Fix concurrent state change bug in QueryStateMachine
add dedc9087eb8 [To rel/1.1]Remove unecessary synchronized on decrementCnt of SinkListener
add c144e84589b [To rel/1.1][IOTDB-5820] Exception when use PIPE if sender has more than one data dir on different disks (#9699)
add 4e5f0977cf6 [To rel/1.1][IOTDB-5183] Use default snapshot installation path for confignode & schema region
add 2624c5a3660 [To rel/1.1][IOTDB-5807]Fix decompression error for aligned series in fast compaction
add 521d33b27df [To rel/1.1][IOTDB-5735] Fix result of some UDF with align by device is incorrect
add 8b980b1a7cf [IOTDB-5812] Reduce useless create of PartialPath in auth module (#9691) (#9704)
add 1096fe45908 [IOTDB-5721][To rel/1.1] Streaming query DataPartition and Schema while loading TsFile (#9697)
add b7789c66d39 [To rel/1.1] Correct ASYNC_DATANODE_IOT_CONSENSUS_CLIENT_POOL name
add 313aa143a6d [To rel/1.1][IOTDB-5815] Fix Npe when UDF spilling data to disk
add b5901698ffa [To rel/1.1] [IOTDB-5803] Improve query performance by reducing cpu consuming
add f60cf9f35f9 [To rel/1.1][IOTDB-5825]Fix error in aligned empty value chunk in fast compaction (#9720)
add 02a9b00d50d Change default multi_dir_strategy to SequenceStrategy and fix original bug (#9718) (#9726)
add 35fc9c68c92 [To rel/1.1] Sort the result of AlignedUpdateLastCacheOperator for LastQueryMergeOperator
add a8a836c49e2 [To rel/1.1] Forbid the query executor thread interrupted by other threads
add f909d676354 [To rel/1.1][IOTDB-5835] Fix wal accumulation caused by datanode restart
add 34754f1e578 [To rel/1.1][IOTDB-5832] Fix Bug: The size of readyQueue is negative incorrectly
add 7b091099e47 [To rel/1.1] [IOTDB-5828] Optimize the performance of some parts in metrics, and correcting the metrics count of temporal file size in inner space compaction (#9743)
add fb7c9592490 [To rel/1.1][IOTDB-5824] Fix show devices with * cannot display satisfied devices (#9761)
add 280193b4d12 [IOTDB-5701] Upgrade Performance Overview Metrics to Core (#9741) (#9764)
add 6d261e9aed0 [To rel/1.1][IOTDB-5831]Fix drop database won't delete totally files in disk during data insertion (#9762)
add acefedb1e7e [To rel/1.1] Add config min_cross_compaction_unseq_file_level for cross compaction (#9765)
add a2c2d45c52b [To rel/1.1][IOTDB-5840] Enhance the problem that the insertRecords interface may cause the number of threads to balloon when there are too many data regions (#9769)
add eaa7ff98cc6 [To rel/1.1] [IOTDB-5844] Fix compaction module getting stuck (#9776)
add aafc4e499c9 [To rel/1.1] [IOTDB-5774] Fix the syntax that path nodes start or end with a wildcard to fuzzy match is not supported (#9778)
add 2bc989c61df [To rel/1.1][IOTDB-5824][IOTDB-5826] Fix devices and template query with * (#9770)
add 97cbc9bc421 improve (#9772)
add e2d7638b1da update ratis version to 2.5.1 (#9786)
add b4309b72b0f use two params to distinguish fsync delay in the wal sync mode and async mode (#9787)
add c0432c294a3 [To rel/1.1][IOTDB-5831] Fix create region failure after recreate db (#9801)
add e962c185829 [To rel/1.1][IOTDB-5818][Atmos][Compaction]Cross_space compaction of Aligned timeseries is stucked (#9796)
add 5ccef6b94dd [IOTDB-5827][TO rel/1.1] Fix the description for dn_multi_dir_strategy in iotdb-datanode.properties and update corresponding user manual (#9803)
add e917076637f [To rel/1.1] Refactor compaction task metrics (#9783)
add 28d2fbb1dd6 [To rel/1.1][IOTDB-5830] Update disk usage and file num when deleting the wal node (#9813)
add f336a0ccfd2 [To rel/1.1] [IOTDB-5851] Fix Npe with limit clause
add 8c10a2f399a [To rel/1.1][IOTDB-5859]Compaction error when using Version as first sort dimension (#9818)
add a8eacc038fb Follower doesn't need to update last cache when using IoT_consensus (#9811) (#9821)
add 17d944a124d [To rel/1.1] Fix only update last cache on follower (#9828)
add ee2218a608b build device timeIndex when validating files after compaction (#9832)
add 3a7023eda65 [IOTDB-5869] Load strategy: load all files to unsequence dir (#9837)
add 7a7e07524d4 bump ratis version to 2.5.2-snapshot (#9840)
add 45fbd7e7209 [To rel/1.1][IOTDB-5859]Compaction error when using Version as first sort dimension (#9825)
add faaa1863288 [To rel/1.1][IOTDB-5871]Prevent large seq files from participating cross space compaction (#9843)
add 9e0324bba74 [To rel/1.1] [IOTDB-5846] Optimize the memory estimate for HorizontallyConcatOperator (#9845)
add 6cdc5a8dfb9 [To rel/1.1] [IOTDB-5837] Fix exception in select-into of ALIGN BY DEVICE query (#9846)
add cf4a8aaec2d [To rel/1.1][IOTDB-5880] Catch Throwable in SessionPool (#9856)
add a3896e79ffa Remove useless class cast and split hit count and request count of schema cache (#9822)
add 05a79e49abb Fix only loading one data directory when start iotdb (#9862)
add e1c83066493 [IOTDB-5721][To rel/1.1] Delete TTimePartitionSlotTransmitLimit from iotdb-common.properties (#9863)
add 331f1bf4078 [IOTDB-5872] Reduce some IoTConsensus index logs (#9844) (#9852)
add a204f29a77c [To rel/1.1][IOTDB-5852] Add some IoTConsensus and RatisConsensus properties (#9851)
add d110115951d fix not releasing read lock when fail to allocate memory for compaction task (#9872)
add ea9effa80d0 [IOTDB-5896] Fix delete aligned TEXT data in TVList NPE (#9885)
add a7168a71736 [To rel/1.1][IOTDB-5897] Fix NullPointerException in compaction (#9886)
add 30f0d1f4aa8 [IOTDB-5901][To rel/1.1] Load: load tsfile without data will throw NPE (#9894)
add d85111fa1e4 [To rel/1.1] [IOTDB-5903] Fix cannot select any inner space compaction task when there is only unsequence data (#9892)
add 197b217029e [To rel/1.1] Change cost time unit from milli to nano & merge operator metric together in one driver (#9899)
add 6af2b0f714c [IOTDB-5843] Stall write requests when system shutting down (#9819) (#9897)
add d52ff7ae776 [To rel/1.1] [IOTDB-5887] Optimize the construction performance of PathPatternTree without wildcards (#9903)
add b3a3e57a24b [DOC] Update the Grafana plugin user manual using screenshots of Grafana 9.3 version (#9913)
add 0e48a216831 IOTDB-5848] Allow ratis-client retry when gRPC IO Unavailable (#9898) (#9910)
add 70f69e4b21a [To rel/1.1][IOTDB-5888] Fix some logs didn't consider timestamp precision (#9917)
add d3963e06df7 [IoTDB-5861] Use Compartor<Binary> instead of Comparator<String> in last query sort
add 6f68ab5f16f Avoid rpc invoking for SimpleQueryTerminator when endpoint is local address
add beee59e8b7f [IOTDB-5915] Adjust the granularity of data migration example from timeseries to device (#9916) (#9949)
add db029339547 [To rel/1.1] Fix potential deadlock when freeing memory in MemoryPool
add 3a38145ef5b [IOTDB-5919]show variables add a variable timestamp_precision (#9936) (#9956)
add f3ec21e6cae [IOTDB-5929] Enable DataPartition inherit policy (#9962) (#9978)
add 43a50b1fd17 [To rel/1.1] [IOTDB-5939] Correct Flusing Task Timeout Detect Thread's timeout
add 4e5d5e361f0 Correct slow query log's time cost precision (#9983)
add 3ac3d63aeef [To rel/1.1][IOTDB-5905] Fix aligned timeseries data point lost after flushed in some scenario (#9980)
add 270f460166a [IOTDB-5927] Add up time metric (#9960) (#9989)
add c9bd1a58796 [To rel/1.1][IOTDB-5794] Filter session connection whose username is empty when using the method of sessionPool.fetchAllConnections() (#9974)
add 43aa12b388c [To rel/1.1][IOTDB-5934] Optimize cluster partition policy (#9977)
add 0fb64817ac9 [To rel/1.1] Release resource of FI after all drivers have been closed
add 6ac6e0792a6 [To rel/1.1] Release resource of FI after all drivers have been closed
add 24d860397df Fix the display milliseconds issue with the Grafana plugin (#9998)
add fab8613909d [To rel/1.1] Set default degree of parallelism back to the num of CPU cores/2
add c0f75c3a83f [IOTDB-5926] Remove Useless Rater in Timer (#9959) (#10021)
add 174ab624147 [To rel/1.1][IOTDB-5963] Make sure that TsBlock blocked on memory is added in queue before the next TsBlock returned by root operator
add 69607c44b26 [IOTDB-5969] [To rel/1.1] Add tsfile validate after compaction (#10049)
add fb01c6ab735 add default charset setting in start-datanode.bat and print default charset when starting (#10051)
add ef8b427e797 [To rel/1.1] Fix TsfileResource error after delete device in sequence working memtable (#10052)
add b2f42e475a8 [IOTDB-5819] Fix npe when booting net metrics (#9698) (#10085)
add 0a9bbdf91aa [To rel/1.1] Avoid useless query in SchemaRegion when executing show child nodes (#10144)
add 17ba8737107 [To rel/1.1] Support show timeseries of system db in tail (#10159)
add 090eaab7828 [To rel/1.1][IOTDB-5996] Fix time display of show queries
add ee1cd45e646 fix concurrent modification (#10183)
add d203b53d967 [To rel/1.1] Fix alias query failure after restarting DataNode (#10283)
add dafd53c8a85 [IOTDB-6015][IOTDB-6023] load TsFile bugs: Not checking whether the tsfile data loaded locally is in the same time partition during the loading process & LoadTsFilePieceNode error when loading tsfile with empty value chunks (#10284)
add f1fb782e76c [To rel/1.1] Fix error sql when using raw query and align by device with having clause
add d780218f362 [IOTDB-6023] Pipe: Fix load tsfile error while handling empty value chunk (#10406)
add f627c7792ad [To rel/1.1] Fix CQ does not take effect in ns time_precision
add 1cb7788f922 [To rel/1.1][IOTDB-6042] Pipe: fix CreationTime display error using non-default time_precision when executing show pipes (#10436)
add c039818bea7 [To rel/1.1] Fix not decreasing file size after ttl delete file (#10458)
add 0b925133a8b [ISSUE-10109] Fixed data column and data correspondence mismatch returned by the rest API interface (#10472)
add 2d41b16da1c [To rel/1.1] Add AND & CONTAINS & NOT & NULL & OR to IdentifierParser
add 60aa1324f19 [To rel/1.1][IOTDB-6049] Fix the issue that nested UDF functions will throw memory not enough exception
add 7d16b5b8551 [To rel/1.1] Update keywords in IdentifierParser.g4
add f465c0eff56 [To rel/1.1][IOTDB-6056] Pipe: Failed to load tsfile with empty pages (NPE occurs when loading)(#10500)
add ba2a50936ee [To rel/1.1] Change Expression priority in IoTDBSqlparser.g4
add a14f9dabd6d [To rel/1.1] Fix schema memory config initialization
add 5f84228865e [IOTDB-6051] Fixed concurrency error in IoTConsensus UT when stopping cluster (#10457) (#10501)
add 73e8cd17422 [To rel/1.2][IOTDB-6030] Improve efficiency of ConfigNode PartitionInfo takeSnapshot (#10336) (#10494)
add 08d68e96c5d [IOTDB-5971] Fix potential QUOTE problem in iotdb reporter (#10125) (#10205) (#10496)
add 697eb992205 [To rel/1.2] Fix npe exception when invalid in metric module (#10444) (#10493)
add 3d1ebc17220 [IOTDB-5993] ConfigNode leader changing causes lacking some DataPartition allocation result in the response of getOrCreateDataPartition method (#10211) (#10497)
add aa8f9aab08f [IOTDB-6000] Control the RegionGroup number of system Database (#10213) (#10498)
add c32dbd09ad7 [IOTDB-5997] Improve efficiency of ConfigNode PartitionInfo loadSnapshot (#10495)
add bb8d6ab6eb5 Fix storage engine memory config initialization (#10077) (#10092) (#10499)
add 0de5cacf5b4 [To rel/1.1] update maxBytesPerFragmentInstance in setAllocateMemoryForRead of IoTDBConfig
add 9d76a3a647c [To rel/1.1] Fix template related schema query
add 2c41e77fb9e [To rel/1.1][IOTDB-5617] Fix count timeseries group by level return NPE
add aedb3d470f0 [ISSUE-10465] Fixed rest api query isn't closed (kill query doesn't work)(#10515)
add e3e1cea4b57 Only SequenceStrategy and MaxDiskUsableSpaceFirstStrategy are allowed in cluster mode (#10164) (#10177) (#10523)
add 2be76da65d9 [IOTDB-5910][To rel/1.2] Fix compaction scheduler thread pool is not shutdown when aborting compaction (#10434) (#10524)
add 6edd8884152 [To rel/1.1][IOTDB-5916]Fix exception when file is deleted during compaction selection (#10525)
add 55c6e464a3b [To rel/1.1] update tokens in IdentifierParser
add 73b6a728dab fix (#10541)
add 8b2290d2fd0 [IOTDB-6068] Pipe: Failed to load tsfile when the first page is empty in a chunk (#10556) (#10559) (#10560)
add 70d73f55e8e [To rel/1.1]Update status code and document about SCHEMA_QUOTA_EXCEEDED
add b9e51cd07fb [IOTDB-6069] Support SessionPool in client-py
add d5d5d2dc64d [To rel/1.1] Add database limit threshold configuration and check when creating new database
add be4fe013018 Make the candidate size of seq tsfile in cross space compaction will be smaller than target_compaction_file_size * 1.5. (#10604)
add 21b1ecc9223 [IOTDB-6072] Load: workaround to CPU 100% after loading tsfile when using JDK8 runtime (#10636)
add b75a05f0ca3 [To rel/1.1] Remove multi-IP initialization in session pool of client-py (#10630)
add 229bf689f9c [To rel/1.1] Fix the issue that Drivers of query with limit clause can not be finished timely
add 4423519335d Fix the NPE issue when taking snapshot in WAL combined with Aligned Binary (#10626)
add ed7349151fd [To rel/1.1][IOTDB-6074] Ignore error message when TagManager createSnapshot
add 2a5bac3e379 [To rel/1.1][IOTDB-6076] Add duplicate checking when upsert alias
add 5a5cdddb34c [To rel/1.1]Fix error update alias in SchemaFile WrappedSegment
add af8f02ef829 [To rel/1.1] Fix potential memory leak in MemoryPool
add 9c0c0e5b259 add time partition in compaction comparator (#10664)
add 73f5f005331 fix issue and add test
add 60bb0ca645b fix ci
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 (3cb26d6b0f3)
\
N -- N -- N refs/heads/IOTDB-5662-1.1 (60bb0ca645b)
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.
No new revisions were added by this update.
Summary of changes:
.github/workflows/main-unix.yml | 4 +-
.github/workflows/main-win.yml | 4 +-
Jenkinsfile | 6 +-
LICENSE-binary | 5 +
RELEASE_NOTES.md | 73 +
antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 35 +-
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 30 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 96 +-
.../org/apache/iotdb/db/qp/sql/PathParser.g4 | 14 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 77 +-
cli/pom.xml | 2 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 10 +
client-cpp/pom.xml | 2 +-
client-cpp/src/main/Session.h | 3 +-
client-py/SessionPoolExample.py | 144 +
client-py/iotdb/SessionPool.py | 127 +
client-py/iotdb/utils/IoTDBConstants.py | 1 +
client-py/pom.xml | 2 +-
client-py/tests/test_session.py | 68 +-
client-py/tests/test_session_pool.py | 68 +
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 2 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 9 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 40 +-
.../confignode/conf/ConfigNodeDescriptor.java | 22 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 98 +-
.../confignode/conf/SystemPropertiesUtils.java | 47 +-
.../consensus/request/ConfigPhysicalPlan.java | 16 +-
.../consensus/request/auth/AuthorPlan.java | 29 +-
.../request/read/database/CountDatabasePlan.java | 2 +-
.../read/partition/GetSeriesSlotListPlan.java | 2 +-
.../read/partition/GetTimeSlotListPlan.java | 2 +-
.../request/read/region/GetRegionIdPlan.java | 2 +-
.../AdjustMaxRegionGroupNumPlan.java | 11 +-
.../DatabaseSchemaPlan.java | 2 +-
.../DeleteDatabasePlan.java | 2 +-
.../PreDeleteDatabasePlan.java | 2 +-
.../SetDataReplicationFactorPlan.java | 30 +-
.../SetSchemaReplicationFactorPlan.java | 11 +-
.../{storagegroup => database}/SetTTLPlan.java | 13 +-
.../SetTimePartitionIntervalPlan.java | 13 +-
.../statemachine/ConfigRegionStateMachine.java | 4 +-
.../iotdb/confignode/manager/ConfigManager.java | 116 +-
.../apache/iotdb/confignode/manager/IManager.java | 21 +-
.../confignode/manager/PermissionManager.java | 3 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../manager/consensus/ConsensusManager.java | 63 +-
.../confignode/manager/cq/CQScheduleTask.java | 30 +-
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../partition/GreedyPartitionAllocator.java | 36 +-
.../iotdb/confignode/manager/node/NodeManager.java | 9 +-
.../manager/partition/PartitionManager.java | 244 +-
.../manager/partition/PartitionMetrics.java | 2 +-
.../manager/{ => schema}/ClusterSchemaManager.java | 294 +-
.../schema/ClusterSchemaQuotaStatistics.java | 33 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 34 +-
.../persistence/executor/ConfigPlanExecutor.java | 62 +-
.../partition/DatabasePartitionTable.java | 23 +-
.../persistence/partition/PartitionInfo.java | 159 +-
.../persistence/schema/ClusterSchemaInfo.java | 116 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 26 +-
.../procedure/env/DataNodeRemoveHandler.java | 3 +
.../impl/schema/DeleteDatabaseProcedure.java | 92 +-
.../state/schema/DeleteStorageGroupState.java | 5 +-
.../iotdb/confignode/service/ConfigNode.java | 25 +-
.../confignode/service/ConfigNodeCommandLine.java | 7 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 53 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 26 +-
.../manager/ClusterSchemaManagerTest.java | 2 +
.../confignode/persistence/AuthorInfoTest.java | 30 +-
.../persistence/ClusterSchemaInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 2 +-
consensus/pom.xml | 4 +-
.../org/apache/iotdb/consensus/common/Utils.java | 32 -
.../iotdb/consensus/config/ConsensusConfig.java | 15 -
.../iotdb/consensus/config/IoTConsensusConfig.java | 36 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 3 +-
.../consensus/iot/IoTConsensusServerImpl.java | 28 +-
.../iot/logdispatcher/IndexController.java | 2 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 16 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 22 +
.../consensus/iot/logdispatcher/SyncStatus.java | 10 +-
.../ratis/ApplicationStateMachineProxy.java | 54 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 18 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 67 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 1 +
.../iotdb/consensus/ratis/SnapshotStorage.java | 19 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 65 +-
.../ratis/metrics/MetricRegistryManager.java | 13 +-
.../consensus/ratis/metrics/RatisMetricSet.java | 79 +-
.../ratis/metrics/RatisMetricsManager.java | 89 +
.../consensus/ratis/utils/RatisLogMonitor.java | 87 +
.../iotdb/consensus/ratis/{ => utils}/Utils.java | 36 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 26 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 2 -
.../apache/iotdb/consensus/iot/StabilityTest.java | 2 -
.../iot/logdispatcher/IndexControllerTest.java | 2 +-
.../iot/logdispatcher/SyncStatusTest.java | 10 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 2 -
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 61 +-
.../apache/iotdb/consensus/ratis/UtilsTest.java | 1 +
.../iotdb/consensus/simple/RecoveryTest.java | 2 -
distribution/pom.xml | 2 +-
.../DockerCompose/docker-compose-cluster-1c2d.yml | 22 +-
.../DockerCompose/docker-compose-cluster-3c3d.yml | 60 -
.../DockerCompose/docker-compose-host-3c3d.yml | 27 +-
.../DockerCompose/docker-compose-standalone.yml | 13 +-
docker/src/main/Dockerfile-1.0.0-confignode | 4 +-
docker/src/main/Dockerfile-1.0.0-datanode | 7 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 10 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 93 +-
docs/UserGuide/API/Programming-MQTT.md | 4 +-
.../UserGuide/API/Programming-Python-Native-API.md | 2 +-
.../API/{RestService.md => RestServiceV1.md} | 46 +-
.../API/{RestService.md => RestServiceV2.md} | 50 +-
.../Administration-Management/Administration.md | 2 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 4 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 4 +-
docs/UserGuide/Data-Concept/Compression.md | 2 +
.../Data-Concept/Data-Model-and-Terminology.md | 4 +-
docs/UserGuide/Data-Concept/Schema-Template.md | 6 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 2 +-
docs/UserGuide/Ecosystem-Integration/DBeaver.md | 16 +-
.../Ecosystem-Integration/Grafana-Connector.md | 6 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 114 +-
docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 2 +-
.../UserGuide/Ecosystem-Integration/Spark-IoTDB.md | 2 +-
.../Ecosystem-Integration/Spark-TsFile.md | 6 +-
.../Ecosystem-Integration/Writing-Data-on-HDFS.md | 2 +-
.../Ecosystem-Integration/Zeppelin-IoTDB.md | 8 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 2 +-
docs/UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
docs/UserGuide/IoTDB-Introduction/Publication.md | 2 +-
docs/UserGuide/IoTDB-Introduction/Scenario.md | 14 +-
docs/UserGuide/Maintenance-Tools/JMX-Tool.md | 4 +-
docs/UserGuide/Maintenance-Tools/Log-Tool.md | 6 +-
docs/UserGuide/Monitor-Alert/Alerting.md | 2 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 5135 ------
.../Apache-IoTDB-DataNode-Dashboard.json | 16871 -------------------
...pache-IoTDB-Performance-Overview-Dashboard.json | 4350 -----
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 324 +-
.../Operate-Metadata/Auto-Create-MetaData.md | 2 +-
docs/UserGuide/Operate-Metadata/Template.md | 6 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
docs/UserGuide/Operators-Functions/Sample.md | 6 +-
docs/UserGuide/Operators-Functions/String.md | 8 +-
.../Operators-Functions/User-Defined-Function.md | 10 +-
docs/UserGuide/Query-Data/Continuous-Query.md | 8 +-
docs/UserGuide/Query-Data/Group-By.md | 6 +-
docs/UserGuide/Query-Data/Overview.md | 2 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 24 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 59 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 151 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 16 +-
docs/UserGuide/Reference/Keywords.md | 6 +-
docs/UserGuide/Reference/Status-Codes.md | 1 +
docs/UserGuide/Reference/TSDB-Comparison.md | 16 +-
docs/UserGuide/Write-Data/REST-API.md | 2 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 10 +-
.../UserGuide/API/Programming-Java-Native-API.md | 83 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 4 +-
.../UserGuide/API/Programming-Python-Native-API.md | 2 +-
.../API/{RestService.md => RestServiceV1.md} | 46 +-
.../API/{RestService.md => RestServiceV2.md} | 50 +-
.../Administration-Management/Administration.md | 2 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 4 +-
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 2 +-
docs/zh/UserGuide/Data-Concept/Compression.md | 1 +
.../Data-Concept/Data-Model-and-Terminology.md | 4 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 2 +-
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 6 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 +-
docs/zh/UserGuide/Ecosystem-Integration/DBeaver.md | 16 +-
.../Ecosystem-Integration/Grafana-Connector.md | 6 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 117 +-
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 2 +-
.../Ecosystem-Integration/Spark-TsFile.md | 32 +-
.../Ecosystem-Integration/Writing-Data-on-HDFS.md | 2 +-
.../Ecosystem-Integration/Zeppelin-IoTDB.md | 8 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 2 +-
.../UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
.../zh/UserGuide/IoTDB-Introduction/Publication.md | 2 +-
docs/zh/UserGuide/IoTDB-Introduction/Scenario.md | 14 +-
docs/zh/UserGuide/Maintenance-Tools/JMX-Tool.md | 4 +-
docs/zh/UserGuide/Maintenance-Tools/Log-Tool.md | 6 +-
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 310 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 6 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
docs/zh/UserGuide/Operators-Functions/Overview.md | 8 +-
docs/zh/UserGuide/Operators-Functions/Sample.md | 6 +-
docs/zh/UserGuide/Operators-Functions/String.md | 8 +-
.../Operators-Functions/User-Defined-Function.md | 2 +-
docs/zh/UserGuide/Query-Data/Continuous-Query.md | 8 +-
docs/zh/UserGuide/Query-Data/Group-By.md | 6 +-
docs/zh/UserGuide/Query-Data/Overview.md | 2 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 24 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 49 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 146 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 18 +-
docs/zh/UserGuide/Reference/Keywords.md | 6 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 257 +-
docs/zh/UserGuide/Reference/TSDB-Comparison.md | 14 +-
docs/zh/UserGuide/Trigger/Implement-Trigger.md | 4 +-
docs/zh/UserGuide/Write-Data/REST-API.md | 2 +-
example/client-cpp-example/pom.xml | 2 +-
example/ext-pipe-plugin-example/pom.xml | 4 +-
example/flink/pom.xml | 2 +-
example/hadoop/pom.xml | 2 +-
example/influxdb-protocol-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 2 +-
example/pulsar/pom.xml | 2 +-
example/rabbitmq/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 8 +-
.../org/apache/iotdb/DataMigrationExample.java | 142 +-
example/trigger/pom.xml | 2 +-
example/tsfile/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
external-api/pom.xml | 2 +-
.../iotdb/external/api/ISeriesNumerMonitor.java | 46 -
external-pipe-api/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana-connector/pom.xml | 2 +-
grafana-plugin/pkg/main.go | 2 +-
.../pkg/plugin/iotdb_resource_handler.go | 26 +-
grafana-plugin/pkg/plugin/plugin.go | 236 +-
grafana-plugin/pom.xml | 2 +-
grafana-plugin/src/ConfigEditor.tsx | 50 +-
grafana-plugin/src/QueryEditor.tsx | 12 +-
grafana-plugin/src/datasource.ts | 19 +-
grafana-plugin/src/types.ts | 1 +
grafana-plugin/yarn.lock | 11545 ++++++-------
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
influxdb-protocol/pom.xml | 2 +-
integration-test/pom.xml | 2 +-
.../iotdb/it/env/cluster/MppCommonConfig.java | 24 +
.../it/env/cluster/MppSharedCommonConfig.java | 28 +
.../iotdb/it/env/remote/RemoteCommonConfig.java | 20 +
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 42 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 8 +
.../confignode/it/IoTDBClusterAuthorityIT.java | 88 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 47 +
.../it/cluster/IoTDBClusterNodeGetterIT.java | 4 +-
.../it/partition/IoTDBPartitionGetterIT.java | 6 +-
.../partition/IoTDBPartitionInheritPolicyIT.java | 26 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 6 +-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 18 +
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 5 +
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 97 +-
.../db/it/aggregation/IoTDBTagAggregationIT.java | 23 +
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 108 +
.../IoTDBOrderByWithAlignByDeviceIT.java | 54 +
.../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 17 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 31 +
.../apache/iotdb/db/it/cq/IoTDBCQExecInNsIT.java | 476 +
.../apache/iotdb/db/it/cq/IoTDBCQExecInUsIT.java | 476 +
.../db/it/last/IoTDBLastQueryLastCache2IT.java | 60 +
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 160 +
.../iotdb/db/it/query/IoTDBArithmeticIT.java | 18 +
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 3 +
.../iotdb/db/it/query/IoTDBPaginationIT.java | 59 +-
.../db/it/schema/IoTDBClusterDeviceQuotaIT.java | 16 +-
.../it/schema/IoTDBClusterMeasurementQuotaIT.java | 125 +
.../iotdb/db/it/schema/IoTDBDatabaseQuotaIT.java | 79 +
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 53 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 105 +
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 29 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 30 +
.../db/it/specialwords/IoTDBSpecialWordsIT.java | 77 +
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 500 +-
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 29 +
.../iotdb/libudf/it/dprofile/DProfileIT.java | 17 +
.../session/it/IoTDBSessionSchemaTemplateIT.java | 61 +
integration/pom.xml | 2 +-
isession/pom.xml | 2 +-
.../java/org/apache/iotdb/isession/ISession.java | 3 +
.../org/apache/iotdb/isession/SessionDataSet.java | 8 +
.../apache/iotdb/isession/pool/ISessionPool.java | 3 +
jdbc/pom.xml | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 1 +
library-udf/pom.xml | 2 +-
.../iotdb/library/dprofile/util/GKArray.java | 17 +-
metrics/dropwizard-metrics/pom.xml | 2 +-
.../type/DropwizardHistogramSnapshot.java | 14 +-
.../metrics/dropwizard/type/DropwizardTimer.java | 5 +-
metrics/interface/pom.xml | 2 +-
.../iotdb/metrics/AbstractMetricManager.java | 4 +-
.../iotdb/metrics/AbstractMetricService.java | 10 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 14 +-
.../metrics/impl/DoNothingHistogramSnapshot.java | 14 +-
.../apache/iotdb/metrics/impl/DoNothingTimer.java | 5 +-
.../iotdb/metrics/metricsets/UpTimeMetrics.java | 34 +-
.../iotdb/metrics/metricsets/disk/DiskMetrics.java | 56 +-
.../metrics/metricsets/jvm/JvmMemoryMetrics.java | 6 +-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 31 +-
.../metrics/metricsets/net/INetMetricManager.java | 58 +
.../metricsets/net/LinuxNetMetricManager.java | 197 +
.../metricsets/net/MacNetMetricManager.java | 8 +-
.../iotdb/metrics/metricsets/net/NetMetrics.java | 98 +
.../metricsets/net/WindowsNetMetricManager.java | 8 +-
.../reporter/prometheus/PrometheusReporter.java | 10 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 15 +-
.../java/org/apache/iotdb/metrics/type/Timer.java | 5 +-
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 13 +-
.../apache/iotdb/metrics/utils/MetricLevel.java | 3 +-
metrics/micrometer-metrics/pom.xml | 4 +-
.../micrometer/MicrometerMetricManager.java | 4 +-
.../micrometer/type/MicrometerAutoGauge.java | 2 -
.../micrometer/type/MicrometerHistogram.java | 2 +-
.../type/MicrometerHistogramSnapshot.java | 27 +-
.../metrics/micrometer/type/MicrometerTimer.java | 11 +-
.../type/MicrometerTimerHistogramSnapshot.java | 28 +-
metrics/pom.xml | 2 +-
mlnode/pom.xml | 2 +-
node-commons/pom.xml | 2 +-
.../resources/conf/iotdb-common.properties | 102 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 35 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 33 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 3 +-
.../iotdb/commons/auth/entity/PathPrivilege.java | 29 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 13 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 13 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 5 +-
.../iotdb/commons/auth/role/IRoleManager.java | 6 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 5 +-
.../iotdb/commons/auth/user/IUserManager.java | 6 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 27 +
.../iotdb/commons/conf/CommonDescriptor.java | 7 +
.../commons/exception/ConfigurationException.java | 27 +-
.../commons/partition/DataPartitionTable.java | 7 +-
.../commons/partition/SeriesPartitionTable.java | 24 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 15 +
.../org/apache/iotdb/commons/path/PartialPath.java | 49 +
.../apache/iotdb/commons/path/PathPatternTree.java | 34 +-
.../commons/schema/ClusterSchemaQuotaLevel.java | 16 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 122 +-
.../iotdb/commons/service/StartupChecks.java | 33 +-
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../metric/enums/PerformanceOverviewMetrics.java | 256 +-
.../iotdb/commons/sync/utils/SyncPathUtil.java | 4 +
.../BuiltinTimeSeriesGeneratingFunction.java | 10 +
.../commons/udf/service/UDFClassLoaderManager.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 96 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 10 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 8 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 12 +-
.../apache/iotdb/commons/path/PartialPathTest.java | 60 -
.../iotdb/commons/path/PathPatternTreeTest.java | 61 +-
openapi/pom.xml | 58 +-
openapi/src/main/openapi3/iotdb_rest_common.yaml | 63 +
.../{iotdb-rest.yaml => iotdb_rest_v1.yaml} | 35 +-
.../{iotdb-rest.yaml => iotdb_rest_v2.yaml} | 35 +-
pipe-api/pom.xml | 2 +-
pom.xml | 8 +-
rewrite-tsfile-tool/pom.xml | 2 +-
schema-engine-rocksdb/pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 5 +
schema-engine-tag/pom.xml | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 14 +-
.../tagSchemaRegion/TagSchemaRegionTest.java | 10 +-
server/pom.xml | 2 +-
.../resources/conf/iotdb-datanode.properties | 8 +-
.../src/assembly/resources/sbin/start-datanode.bat | 4 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 8 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 17 +-
.../apache/iotdb/db/auth/AuthorizerManager.java | 15 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 38 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 3 +-
.../apache/iotdb/db/conf/DataNodeStartupCheck.java | 69 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 255 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 317 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 5 +-
.../org/apache/iotdb/db/conf/OperationType.java | 3 +-
.../directories/strategy/SequenceStrategy.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 11 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 2 -
.../statemachine/DataRegionStateMachine.java | 6 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 19 +-
.../iotdb/db/engine/TsFileMetricManager.java | 63 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 2 +-
.../db/engine/cache/CacheHitRatioMonitor.java | 2 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 13 +-
.../compaction/constant/CompactionTaskStatus.java} | 13 +-
.../compaction/constant/CompactionTaskType.java} | 12 +-
.../exception/CompactionExceptionHandler.java | 2 +-
.../CompactionMemoryNotEnoughException.java} | 11 +-
.../performer/impl/FastCompactionPerformer.java | 30 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../impl/ReadPointCompactionPerformer.java | 24 +-
.../execute/task/AbstractCompactionTask.java | 38 +-
.../execute/task/CompactionTaskSummary.java | 18 +
.../execute/task/CrossSpaceCompactionTask.java | 85 +-
.../execute/task/InnerSpaceCompactionTask.java | 306 +-
.../compaction/execute/utils/CompactionUtils.java | 140 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 27 +-
.../fast/AlignedSeriesCompactionExecutor.java | 19 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 9 +-
.../utils/writer/AbstractCompactionWriter.java | 10 +-
.../writer/AbstractCrossCompactionWriter.java | 3 +-
.../writer/AbstractInnerCompactionWriter.java | 4 +-
.../compaction/schedule/CompactionScheduler.java | 135 +-
.../compaction/schedule/CompactionTaskManager.java | 75 +-
.../compaction/schedule/CompactionWorker.java | 3 -
.../DefaultCompactionTaskComparatorImpl.java | 14 +
.../estimator/AbstractCompactionEstimator.java | 13 +-
.../ReadPointCrossCompactionEstimator.java | 150 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 80 +-
.../impl/SizeTieredCompactionSelector.java | 29 +-
.../utils/CrossCompactionTaskResource.java | 12 +
.../utils/CrossSpaceCompactionCandidate.java | 87 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 4 +-
.../iotdb/db/engine/load/AlignedChunkData.java | 5 +-
.../iotdb/db/engine/load/LoadTsFileManager.java | 2 +-
.../iotdb/db/engine/load/TsFileSplitter.java | 13 +-
.../engine/memtable/AlignedWritableMemChunk.java | 19 +-
.../db/engine/settle/SettleRequestHandler.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 332 +-
.../db/engine/storagegroup/TsFileManager.java | 1 +
.../db/engine/storagegroup/TsFileProcessor.java | 40 +-
.../db/engine/storagegroup/TsFileResource.java | 131 +-
.../db/engine/storagegroup/TsFileResourceList.java | 62 +-
.../engine/storagegroup/TsFileResourceStatus.java | 3 +-
.../metadata/SchemaQuotaExceededException.java | 47 +
.../db/exception/query/OutOfTTLException.java | 4 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 3 +
.../db/metadata/cache/DataNodeDevicePathCache.java | 69 +
.../db/metadata/cache/DataNodeSchemaCache.java | 8 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 31 +-
.../db/metadata/metric/SchemaEngineMemMetric.java | 16 +-
.../db/metadata/metric/SchemaRegionMemMetric.java | 34 +
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 8 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 135 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 59 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 28 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 10 +-
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 2 +-
.../db/metadata/mtree/store/MemMTreeStore.java | 9 +-
.../mtree/store/StampedWriterPreferredLock.java | 21 +-
.../mtree/store/disk/cache/CacheMemoryManager.java | 118 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 2 +-
.../store/disk/schemafile/SchemaFileConfig.java | 2 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 11 +-
.../store/disk/schemafile/WrappedSegment.java | 11 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 90 +-
.../db/metadata/mtree/traverser/Traverser.java | 61 +
.../traverser/TraverserWithLimitOffsetWrapper.java | 5 +
.../mtree/traverser/basic/DatabaseTraverser.java | 5 +
.../mtree/traverser/basic/EntityTraverser.java | 8 +
.../mtree/traverser/basic/MNodeTraverser.java | 5 +
.../traverser/basic/MeasurementTraverser.java | 5 +
.../rescon/DataNodeSchemaQuotaManager.java | 92 +
.../metadata/rescon/ISchemaEngineStatistics.java | 2 +
.../metadata/rescon/ISchemaRegionStatistics.java | 6 +
.../metadata/rescon/MemSchemaEngineStatistics.java | 52 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 51 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 11 +
.../metadata/schemaregion/ISchemaRegionParams.java | 3 -
.../db/metadata/schemaregion/SchemaEngine.java | 73 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 176 +-
.../metadata/schemaregion/SchemaRegionParams.java | 12 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 311 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 22 +-
.../metadata/template/ClusterTemplateManager.java | 36 +-
.../iotdb/db/metadata/template/Template.java | 4 +
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 12 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 20 +
.../org/apache/iotdb/db/mpp/common/QueryId.java | 2 +-
.../apache/iotdb/db/mpp/common/SessionInfo.java | 14 +
.../db/mpp/common/header/ColumnHeaderConstant.java | 4 +-
.../visitor/SchemaTreeDeviceVisitor.java | 5 +
.../visitor/SchemaTreeMeasurementVisitor.java | 5 +
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 6 +
...sBlockFromClosedOrAbortedChannelException.java} | 10 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 78 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 2 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 30 +-
.../db/mpp/execution/driver/DriverContext.java | 28 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 2 +-
.../db/mpp/execution/driver/SchemaDriver.java | 2 +-
.../execution/exchange/MPPDataExchangeManager.java | 249 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 65 +-
.../db/mpp/execution/exchange/sink/ISink.java | 4 +
.../mpp/execution/exchange/sink/ISinkHandle.java | 3 +
.../execution/exchange/sink/LocalSinkChannel.java | 28 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 113 +-
.../mpp/execution/exchange/sink/SinkChannel.java | 81 +-
.../exchange/source/LocalSourceHandle.java | 2 +-
.../source/PipelineSourceHandle.java} | 31 +-
.../execution/exchange/source/SourceHandle.java | 90 +-
.../execution/executor/RegionWriteExecutor.java | 289 +-
.../fragment/FragmentInstanceContext.java | 44 +-
.../fragment/FragmentInstanceExecution.java | 25 +-
.../fragment/FragmentInstanceManager.java | 21 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 35 +-
.../iotdb/db/mpp/execution/operator/Operator.java | 10 +-
.../process/AbstractConsumeAllOperator.java | 4 +-
.../operator/process/AbstractIntoOperator.java | 71 +-
.../operator/process/AggregationOperator.java | 6 +-
.../operator/process/DeviceMergeOperator.java | 6 +-
.../operator/process/DeviceViewIntoOperator.java | 13 +-
.../operator/process/DeviceViewOperator.java | 17 +-
.../execution/operator/process/FillOperator.java | 6 +-
.../operator/process/FilterAndProjectOperator.java | 6 +-
.../execution/operator/process/IntoOperator.java | 7 +-
.../execution/operator/process/LimitOperator.java | 6 +-
.../operator/process/LinearFillOperator.java | 8 +-
.../operator/process/MergeSortOperator.java | 17 +-
.../execution/operator/process/OffsetOperator.java | 6 +-
.../process/RawDataAggregationOperator.java | 9 +-
.../operator/process/SingleDeviceViewOperator.java | 6 +-
.../process/SingleInputAggregationOperator.java | 6 +-
.../process/SlidingWindowAggregationOperator.java | 4 +-
.../execution/operator/process/SortOperator.java | 6 +-
.../operator/process/TagAggregationOperator.java | 8 +-
.../operator/process/TransformOperator.java | 29 +-
.../process/join/HorizontallyConcatOperator.java | 16 +-
.../process/join/RowBasedTimeJoinOperator.java | 13 +-
.../operator/process/join/TimeJoinOperator.java | 9 +-
.../process/join/merge/AscTimeComparator.java | 5 +
.../process/join/merge/DescTimeComparator.java | 5 +
.../process/join/merge/MergeSortComparator.java | 28 +-
.../process/join/merge/TimeComparator.java | 3 +
.../last/AbstractUpdateLastCacheOperator.java | 4 +-
.../last/AlignedUpdateLastCacheOperator.java | 2 +-
.../process/last/LastQueryCollectOperator.java | 6 +-
.../process/last/LastQueryMergeOperator.java | 12 +-
.../operator/process/last/LastQueryOperator.java | 7 +-
.../process/last/LastQuerySortOperator.java | 7 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelMergeOperator.java | 6 +-
.../schema/CountGroupByLevelScanOperator.java | 8 +-
.../operator/schema/CountMergeOperator.java | 7 +-
.../schema/NodeManageMemoryMergeOperator.java | 6 +-
.../operator/schema/NodePathsConvertOperator.java | 6 +-
.../operator/schema/NodePathsCountOperator.java | 6 +-
.../operator/schema/SchemaCountOperator.java | 29 +-
.../operator/schema/SchemaFetchMergeOperator.java | 6 +-
.../operator/schema/SchemaFetchScanOperator.java | 6 +-
.../operator/schema/SchemaQueryMergeOperator.java | 6 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 6 +-
.../operator/schema/SchemaQueryScanOperator.java | 6 +-
.../operator/schema/source/DeviceSchemaSource.java | 12 +
.../operator/schema/source/ISchemaSource.java | 4 +
.../operator/schema/source/NodeSchemaSource.java | 10 +
.../schema/source/PathsUsingTemplateSource.java | 10 +
.../schema/source/TimeSeriesSchemaSource.java | 14 +
.../operator/sink/IdentitySinkOperator.java | 35 +-
.../operator/sink/ShuffleHelperOperator.java | 39 +-
.../AbstractSeriesAggregationScanOperator.java | 6 +-
.../operator/source/AlignedSeriesScanOperator.java | 6 +-
.../operator/source/ExchangeOperator.java | 19 +-
.../operator/source/LastCacheScanOperator.java | 6 +-
.../operator/source/SeriesScanOperator.java | 6 +-
.../execution/operator/source/SeriesScanUtil.java | 36 +-
.../operator/source/ShowQueriesOperator.java | 12 +-
.../execution/schedule/AbstractDriverThread.java | 9 +
.../db/mpp/execution/schedule/DriverScheduler.java | 159 +-
.../mpp/execution/schedule/DriverTaskThread.java | 7 +-
.../schedule/queue/IndexedBlockingQueue.java | 1 +
.../multilevelqueue/MultilevelPriorityQueue.java | 4 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 18 +-
.../metric/PerformanceOverviewMetricsManager.java | 214 -
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 140 +-
.../mpp/metric/TimeSeriesMetadataCacheMetrics.java | 4 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 12 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 12 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 144 +-
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 8 -
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 42 +-
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 3 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 10 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 7 +-
.../db/mpp/plan/execution/IQueryExecution.java | 5 +-
.../db/mpp/plan/execution/QueryExecution.java | 49 +-
.../mpp/plan/execution/config/ConfigExecution.java | 5 +-
.../config/metadata/ShowVariablesTask.java | 8 +-
.../execution/config/sys/sync/ShowPipeTask.java | 3 +-
.../plan/expression/multi/FunctionExpression.java | 40 +-
.../visitor/ColumnTransformerVisitor.java | 2 +-
.../visitor/IntermediateLayerVisitor.java | 4 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 36 +-
.../db/mpp/plan/parser/StatementGenerator.java | 110 +-
.../plan/planner/LocalExecutionPlanContext.java | 4 +
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 48 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 19 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 32 +-
.../db/mpp/plan/planner/PipelineDriverFactory.java | 15 +-
.../planner/distribution/DistributionPlanner.java | 21 +
.../plan/planner/distribution/SourceRewriter.java | 133 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 191 +-
.../plan/node/load/LoadSingleTsFileNode.java | 71 +-
.../planner/plan/node/load/LoadTsFileNode.java | 16 +-
.../metedata/read/LevelTimeSeriesCountNode.java | 34 +-
.../node/metedata/write/ActivateTemplateNode.java | 2 +-
...iesNode.java => BatchActivateTemplateNode.java} | 76 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 6 +-
.../write/InternalCreateMultiTimeSeriesNode.java | 1 +
.../plan/node/metedata/write/MeasurementGroup.java | 36 +-
.../source/AlignedSeriesAggregationScanNode.java | 50 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +
.../node/source/SeriesAggregationScanNode.java | 50 +-
.../node/source/SeriesAggregationSourceNode.java | 49 +-
.../planner/plan/node/source/SeriesScanNode.java | 4 +
.../plan/planner/plan/node/write/InsertNode.java | 9 +
.../planner/plan/parameter/SeriesScanOptions.java | 5 +-
.../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 106 +-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 35 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 4 +-
.../scheduler/FixedRateFragInsStateTracker.java | 21 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 78 +-
.../plan/scheduler/IFragInstanceStateTracker.java | 4 +-
.../db/mpp/plan/scheduler/IQueryTerminator.java | 2 +-
.../iotdb/db/mpp/plan/scheduler/IScheduler.java | 2 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 81 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 20 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 209 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 4 +-
.../db/mpp/plan/statement/StatementVisitor.java | 6 +
.../statement/component/GroupByTimeComponent.java | 17 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 26 +-
...nt.java => BatchActivateTemplateStatement.java} | 33 +-
.../template/DropSchemaTemplateStatement.java | 13 +-
.../db/mpp/transformation/api/YieldableReader.java | 6 +-
.../dag/builder/EvaluationDAGBuilder.java | 4 +-
.../binary/CompareNonEqualColumnTransformer.java | 2 +-
.../binary/LogicBinaryColumnTransformer.java | 4 +-
.../transformation/dag/input/IUDFInputDataSet.java | 2 +-
.../dag/input/QueryDataSetInputLayer.java | 9 +-
.../dag/input/TsBlockInputDataSet.java | 2 +-
.../intermediate/ConstantIntermediateLayer.java | 3 +-
.../dag/intermediate/IntermediateLayer.java | 4 +-
.../MultiInputColumnIntermediateLayer.java | 12 +-
...InputColumnMultiReferenceIntermediateLayer.java | 14 +-
...nputColumnSingleReferenceIntermediateLayer.java | 12 +-
.../dag/transformer/Transformer.java | 4 +-
.../dag/transformer/binary/BinaryTransformer.java | 4 +-
.../transformer/binary/LogicBinaryTransformer.java | 2 +-
.../multi/MappableUDFQueryRowTransformer.java | 2 +-
.../transformer/multi/UDFQueryRowTransformer.java | 2 +-
.../multi/UDFQueryRowWindowTransformer.java | 2 +-
.../multi/UniversalUDFQueryTransformer.java | 4 +-
.../transformer/ternary/TernaryTransformer.java | 4 +-
.../transformer/unary/DiffFunctionTransformer.java | 2 +-
.../dag/transformer/unary/IsNullTransformer.java | 2 +-
.../dag/transformer/unary/UnaryTransformer.java | 2 +-
.../db/mpp/transformation/dag/udf/UDTFContext.java | 5 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 2 +-
.../dag/udf/UDTFInformationInferrer.java | 1 -
.../transformation/dag/util/LayerCacheUtils.java | 10 +-
.../datastructure/SerializableList.java | 6 +-
.../row/ElasticSerializableRowRecordList.java | 6 +-
.../row/SerializableRowRecordList.java | 2 +-
.../tv/ElasticSerializableBinaryTVList.java | 2 +-
.../tv/ElasticSerializableTVList.java | 8 +-
.../datastructure/tv/SerializableTVList.java | 2 +-
.../influxdb/parser/InfluxDBAstVisitor.java | 6 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 5 +-
.../rest/handler/AuthorizationHandler.java | 8 +-
.../rest/{ => v1}/handler/ExceptionHandler.java | 4 +-
.../{ => v1}/handler/ExecuteStatementHandler.java | 2 +-
.../rest/{ => v1}/handler/QueryDataSetHandler.java | 45 +-
.../{ => v1}/handler/RequestValidationHandler.java | 22 +-
.../handler/StatementConstructionHandler.java | 9 +-
.../rest/{ => v1}/impl/GrafanaApiServiceImpl.java | 46 +-
.../rest/{ => v1}/impl/RestApiServiceImpl.java | 44 +-
.../rest/{ => v2}/handler/ExceptionHandler.java | 2 +-
.../{ => v2}/handler/ExecuteStatementHandler.java | 2 +-
.../rest/{ => v2}/handler/QueryDataSetHandler.java | 47 +-
.../{ => v2}/handler/RequestValidationHandler.java | 8 +-
.../handler/StatementConstructionHandler.java | 9 +-
.../rest/{ => v2}/impl/GrafanaApiServiceImpl.java | 46 +-
.../rest/{ => v2}/impl/RestApiServiceImpl.java | 44 +-
.../iotdb/db/query/context/QueryContext.java | 2 +
.../db/query/control/QueryResourceManager.java | 7 +-
.../iotdb/db/query/control/SessionManager.java | 15 +-
.../query/control/clientsession/ClientSession.java | 3 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 12 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 33 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 46 +-
.../db/service/TemporaryQueryDataFileService.java | 14 +-
.../db/service/metrics/CompactionMetrics.java | 12 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 8 +
.../iotdb/db/service/metrics/FileMetrics.java | 26 +-
.../metrics/IoTDBInternalLocalReporter.java | 103 +-
.../metrics/recorder/CompactionMetricsManager.java | 87 +-
.../db/service/thrift/ProcessorWithMetrics.java | 2 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 292 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 47 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 54 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 4 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 4 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 2 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 2 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 6 +-
.../db/tools/validate/TsFileValidationTool.java | 16 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 11 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../iotdb/db/utils/TimestampPrecisionUtils.java | 57 +
.../org/apache/iotdb/db/utils/UpgradeUtils.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 18 +-
.../datastructure/FixedPriorityBlockingQueue.java | 10 +
.../java/org/apache/iotdb/db/wal/WALManager.java | 8 +-
.../db/wal/allocation/FirstCreateStrategy.java | 3 +
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 41 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 9 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 14 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 -
.../iotdb/db/auth/AuthorizerManagerTest.java | 26 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 9 +-
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 8 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 8 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 8 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 6 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 8 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 6 +-
.../db/auth/user/LocalFileUserManagerTest.java | 8 +-
.../iotdb/db/engine/cache/ChunkCacheTest.java | 4 +-
.../engine/compaction/AbstractCompactionTest.java | 75 +-
.../engine/compaction/CompactionSchedulerTest.java | 5 +
.../compaction/CompactionTaskComparatorTest.java | 67 +-
.../compaction/CompactionTaskManagerTest.java | 6 +-
.../compaction/CompactionValidationTest.java | 224 +
.../compaction/FastAlignedCrossCompactionTest.java | 1191 +-
.../FastCrossCompactionPerformerTest.java | 5 +
.../FastInnerCompactionPerformerTest.java | 30 +-
.../FastNonAlignedCrossCompactionTest.java | 1351 +-
.../db/engine/compaction/MemoryControlTest.java | 75 +
.../compaction/ReadChunkInnerCompactionTest.java | 377 +
...va => ReadPointAlignedCrossCompactionTest.java} | 1244 +-
.../ReadPointCompactionPerformerTest.java | 16 +-
...=> ReadPointNonAlignedCrossCompactionTest.java} | 1259 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 7 +-
.../cross/CrossSpaceCompactionSelectorTest.java | 1819 ++
.../CrossSpaceCompactionWithFastPerformerTest.java | 13 +-
...eCompactionWithFastPerformerValidationTest.java | 747 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 6 +-
...actionWithReadPointPerformerValidationTest.java | 733 +-
.../db/engine/compaction/cross/MergeTest.java | 7 +-
.../cross/RewriteCompactionFileSelectorTest.java | 103 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 10 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 21 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 21 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 4 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../inner/InnerCompactionSchedulerTest.java | 12 +-
.../compaction/inner/InnerCompactionTest.java | 4 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 626 +
.../ReadChunkCompactionPerformerAlignedTest.java | 76 +
.../SizeTieredCompactionRecoverTest.java | 52 +-
.../SizeTieredCompactionSelectorTest.java | 40 +
.../inner/sizetiered/SizeTieredCompactionTest.java | 10 +-
.../compaction/utils/CompactionCheckerUtils.java | 4 +
.../utils/MultiTsFileDeviceIteratorTest.java | 915 +
.../compaction/utils/TsFileGeneratorUtils.java | 116 +-
.../db/engine/settle/SettleRequestHandlerTest.java | 1 -
.../db/engine/snapshot/IoTDBSnapshotTest.java | 4 +-
.../db/engine/storagegroup/DataRegionTest.java | 27 +
.../engine/storagegroup/FakedTsFileResource.java | 4 +-
.../storagegroup/TsFileResourceListTest.java | 110 +
.../db/engine/storagegroup/TsFileResourceTest.java | 2 +-
.../cache/DataNodeDevicePathCacheTest.java | 62 +
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 3 +
.../mtree/lock/StampedWriterPreferredLockTest.java | 16 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 140 +-
.../mtree/schemafile/WrappedSegmentTest.java | 15 +
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 19 +
.../schemaRegion/SchemaRegionBasicTest.java | 103 +-
.../schemaRegion/SchemaStatisticsTest.java | 136 +
.../apache/iotdb/db/metric/MetricServiceTest.java | 9 +-
.../db/mpp/execution/ConfigExecutionTest.java | 2 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 1 +
.../db/mpp/execution/QueryStateMachineTest.java | 2 +
.../execution/exchange/LocalSinkChannelTest.java | 14 +-
.../execution/exchange/LocalSourceHandleTest.java | 14 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 7 +-
.../iotdb/db/mpp/execution/exchange/StubSink.java | 5 +
.../operator/AggregationOperatorTest.java | 26 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 38 +-
.../operator/AlignedSeriesScanOperatorTest.java | 6 +-
.../execution/operator/AlignedSeriesTestUtil.java | 6 +-
.../operator/DeviceMergeOperatorTest.java | 565 -
.../execution/operator/DeviceViewOperatorTest.java | 3 +-
.../mpp/execution/operator/FillOperatorTest.java | 16 +-
.../operator/HorizontallyConcatOperatorTest.java | 2 +-
.../operator/LastQueryMergeOperatorTest.java | 38 +-
.../execution/operator/LastQueryOperatorTest.java | 4 +-
.../operator/LastQuerySortOperatorTest.java | 5 +-
.../mpp/execution/operator/LimitOperatorTest.java | 2 +-
.../execution/operator/LinearFillOperatorTest.java | 56 +-
.../execution/operator/MergeSortOperatorTest.java | 139 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 6 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 111 +
.../operator/RawDataAggregationOperatorTest.java | 54 +-
.../SeriesAggregationScanOperatorTest.java | 65 +-
.../execution/operator/SeriesScanOperatorTest.java | 2 +-
.../operator/SingleDeviceViewOperatorTest.java | 3 +-
.../SlidingWindowAggregationOperatorTest.java | 3 +-
.../execution/operator/TimeJoinOperatorTest.java | 6 +-
.../operator/UpdateLastCacheOperatorTest.java | 6 +-
.../operator/schema/SchemaCountOperatorTest.java | 4 +-
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../execution/schedule/DriverSchedulerTest.java | 21 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 36 +
.../mpp/plan/analyze/QueryTimePartitionTest.java | 14 +-
.../iotdb/db/mpp/plan/plan/ExpressionTest.java | 68 +
.../db/mpp/plan/plan/PipelineBuilderTest.java | 96 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 3 +-
.../node/process/AggregationNodeSerdeTest.java | 7 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 8 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 5 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 7 +-
.../db/mpp/plan/statement/QueryStatementTest.java | 148 +
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 46 +-
.../query/reader/series/SeriesReaderTestUtil.java | 6 +-
.../series/SeriesScanLimitOffsetPushDownTest.java | 114 +-
.../udf/datastructure/SerializableListTest.java | 2 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 12 +-
.../security/encrypt/MessageDigestEncryptTest.java | 6 +-
.../DataNodeInternalRPCServiceImplTest.java | 31 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 9 +-
.../db/utils/datastructure/VectorTVListTest.java | 11 +
service-rpc/pom.xml | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
session/pom.xml | 2 +-
.../java/org/apache/iotdb/session/Session.java | 14 +
.../apache/iotdb/session/SessionConnection.java | 21 +
.../org/apache/iotdb/session/pool/SessionPool.java | 339 +-
site/pom.xml | 2 +-
site/src/main/.vuepress/config.js | 6 +-
spark-iotdb-connector/pom.xml | 2 +-
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 2 +-
thrift-commons/pom.xml | 2 +-
thrift-confignode/pom.xml | 2 +-
.../src/main/thrift/confignode.thrift | 16 +-
thrift-influxdb/pom.xml | 2 +-
thrift-iot-consensus/pom.xml | 2 +-
thrift-mlnode/pom.xml | 2 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/client.thrift | 10 +
thrift/src/main/thrift/datanode.thrift | 31 +-
trigger-api/pom.xml | 2 +-
tsfile/pom.xml | 6 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../apache/iotdb/tsfile/compress/ICompressor.java | 61 +-
.../iotdb/tsfile/compress/IUnCompressor.java | 44 +
.../iotdb/tsfile/file/header/PageHeader.java | 3 +
.../file/metadata/enums/CompressionType.java | 6 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 2 +-
.../common/block/column/ColumnEncoderFactory.java | 5 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 13 +-
.../read/filter/PredicateRemoveNotRewriter.java | 50 +
.../iotdb/tsfile/read/filter/TimeFilter.java | 158 +-
.../iotdb/tsfile/read/filter/ValueFilter.java | 179 +-
.../tsfile/read/filter/basic/BinaryFilter.java | 5 -
.../iotdb/tsfile/read/filter/basic/Filter.java | 11 +-
.../tsfile/read/filter/factory/FilterFactory.java | 10 +-
.../tsfile/read/filter/operator/AndFilter.java | 11 +
.../iotdb/tsfile/read/filter/operator/Between.java | 127 +-
.../iotdb/tsfile/read/filter/operator/Eq.java | 25 +-
.../iotdb/tsfile/read/filter/operator/Gt.java | 23 +-
.../iotdb/tsfile/read/filter/operator/GtEq.java | 23 +-
.../iotdb/tsfile/read/filter/operator/In.java | 34 +-
.../iotdb/tsfile/read/filter/operator/Like.java | 55 +-
.../iotdb/tsfile/read/filter/operator/Lt.java | 23 +-
.../iotdb/tsfile/read/filter/operator/LtEq.java | 23 +-
.../iotdb/tsfile/read/filter/operator/NotEq.java | 25 +-
.../tsfile/read/filter/operator/NotFilter.java | 26 +-
.../tsfile/read/filter/operator/OrFilter.java | 11 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 57 +-
.../read/reader/chunk/AlignedChunkReader.java | 40 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 4 +
.../iotdb/tsfile/read/reader/page/PageReader.java | 12 +-
.../read/reader/series/PaginationController.java | 23 +
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 20 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 42 +-
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 33 +-
.../tsfile/write/schema/MeasurementSchema.java | 8 +
.../apache/iotdb/tsfile/compress/CompressTest.java | 39 +
.../org/apache/iotdb/tsfile/compress/ZstdTest.java | 88 +
.../apache/iotdb/tsfile/read/common/PathTest.java | 44 +-
.../tsfile/read/filter/FilterSerializeTest.java | 21 +-
.../read/filter/MinTimeMaxTimeFilterTest.java | 42 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 4 +-
.../filter/PredicateRemoveNotRewriterTest.java | 121 +
.../tsfile/read/filter/StatisticsFilterTest.java | 113 +-
udf-api/pom.xml | 2 +-
zeppelin-interpreter/pom.xml | 2 +-
901 files changed, 33484 insertions(+), 42701 deletions(-)
create mode 100644 client-py/SessionPoolExample.py
create mode 100644 client-py/iotdb/SessionPool.py
create mode 100644 client-py/tests/test_session_pool.py
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup => database}/AdjustMaxRegionGroupNumPlan.java (94%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup => database}/DatabaseSchemaPlan.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup => database}/DeleteDatabasePlan.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup => database}/PreDeleteDatabasePlan.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup => database}/SetDataReplicationFactorPlan.java (74%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup => database}/SetSchemaReplicationFactorPlan.java (92%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup => database}/SetTTLPlan.java (90%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup => database}/SetTimePartitionIntervalPlan.java (91%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ => schema}/ClusterSchemaManager.java (76%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/driver/SchemaDriver.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaQuotaStatistics.java (51%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricsManager.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/RatisLogMonitor.java
rename consensus/src/main/java/org/apache/iotdb/consensus/ratis/{ => utils}/Utils.java (87%)
delete mode 100644 docker/src/main/DockerCompose/docker-compose-cluster-3c3d.yml
copy docs/UserGuide/API/{RestService.md => RestServiceV1.md} (93%)
rename docs/UserGuide/API/{RestService.md => RestServiceV2.md} (94%)
delete mode 100644 docs/UserGuide/Monitor-Alert/Apache-IoTDB-ConfigNode-Dashboard.json
delete mode 100644 docs/UserGuide/Monitor-Alert/Apache-IoTDB-DataNode-Dashboard.json
delete mode 100644 docs/UserGuide/Monitor-Alert/Apache-IoTDB-Performance-Overview-Dashboard.json
copy docs/zh/UserGuide/API/{RestService.md => RestServiceV1.md} (94%)
rename docs/zh/UserGuide/API/{RestService.md => RestServiceV2.md} (94%)
delete mode 100644 external-api/src/main/java/org/apache/iotdb/external/api/ISeriesNumerMonitor.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/cq/IoTDBCQExecInNsIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/cq/IoTDBCQExecInUsIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryLastCache2IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryLastCacheIT.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/merge/DescTimeComparator.java => integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBClusterDeviceQuotaIT.java (63%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBClusterMeasurementQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBDatabaseQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/specialwords/IoTDBSpecialWordsIT.java
copy consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricSet.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/UpTimeMetrics.java (56%)
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/INetMetricManager.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/LinuxNetMetricManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/IQueryTerminator.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/MacNetMetricManager.java (84%)
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/IQueryTerminator.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/WindowsNetMetricManager.java (84%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/IQueryTerminator.java => node-commons/src/main/java/org/apache/iotdb/commons/schema/ClusterSchemaQuotaLevel.java (76%)
create mode 100644 openapi/src/main/openapi3/iotdb_rest_common.yaml
copy openapi/src/main/openapi3/{iotdb-rest.yaml => iotdb_rest_v1.yaml} (92%)
rename openapi/src/main/openapi3/{iotdb-rest.yaml => iotdb_rest_v2.yaml} (92%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/conf/DataNodeStartupCheck.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/plan/scheduler/IQueryTerminator.java => engine/compaction/constant/CompactionTaskStatus.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/plan/scheduler/IQueryTerminator.java => engine/compaction/constant/CompactionTaskType.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/plan/scheduler/IQueryTerminator.java => engine/compaction/execute/exception/CompactionMemoryNotEnoughException.java} (73%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/SchemaQuotaExceededException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeDevicePathCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/DataNodeSchemaQuotaManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/scheduler/IQueryTerminator.java => exception/exchange/GetTsBlockFromClosedOrAbortedChannelException.java} (78%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{driver/SchemaDriver.java => exchange/source/PipelineSourceHandle.java} (55%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/PerformanceOverviewMetricsManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/{InternalCreateMultiTimeSeriesNode.java => BatchActivateTemplateNode.java} (58%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/{DropSchemaTemplateStatement.java => BatchActivateTemplateStatement.java} (60%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v1}/handler/ExceptionHandler.java (97%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v1}/handler/ExecuteStatementHandler.java (97%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v1}/handler/QueryDataSetHandler.java (84%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v1}/handler/RequestValidationHandler.java (74%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v1}/handler/StatementConstructionHandler.java (95%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v1}/impl/GrafanaApiServiceImpl.java (89%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v1}/impl/RestApiServiceImpl.java (86%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v2}/handler/ExceptionHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v2}/handler/ExecuteStatementHandler.java (97%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v2}/handler/QueryDataSetHandler.java (84%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v2}/handler/RequestValidationHandler.java (89%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v2}/handler/StatementConstructionHandler.java (95%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v2}/impl/GrafanaApiServiceImpl.java (89%)
rename server/src/main/java/org/apache/iotdb/db/protocol/rest/{ => v2}/impl/RestApiServiceImpl.java (86%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/TimestampPrecisionUtils.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/CompactionValidationTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/MemoryControlTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/ReadChunkInnerCompactionTest.java
copy server/src/test/java/org/apache/iotdb/db/engine/compaction/{FastAlignedCrossCompactionTest.java => ReadPointAlignedCrossCompactionTest.java} (83%)
copy server/src/test/java/org/apache/iotdb/db/engine/compaction/{FastNonAlignedCrossCompactionTest.java => ReadPointNonAlignedCrossCompactionTest.java} (83%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionSelectorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionSelectorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/cache/DataNodeDevicePathCacheTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/DeviceMergeOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/ExpressionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/statement/QueryStatementTest.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/PredicateRemoveNotRewriter.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/compress/ZstdTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/PredicateRemoveNotRewriterTest.java