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
