This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.4
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard be638dab1d3 Bump org.xerial.snappy:snappy-java from 1.1.8.4 to 1.1.10.4
add 8980844590a Add UT for session module (#11158)
add 53a2bee7b20 Fix the dead lock bug when the generated distributed query
plan contains cycle
add 0cb79e5f07e [IoTDB-6172] Finish canAddTsBlock of SharedTsBlockQueue to
ensure that blocked Driver could be correctly finished
add 9a7e114a5b6 Ensure concurrency safety when updating last cache
add 2fd218422b6 Optimize the python client performance for Python 3.10 or
later (#11198)
add 1c3a59e4b9b Pipe: Added tablet event count and tsfile event count to
PipeHeartbeatEvent reports (#11225)
add 6e7088ae6ae [IOTDB-6170] Pipe: Removed unnecessary parse when tsFile
resources' time ranges are covered by startTime-endTime (#11211)
add a4eeeba9759 SchemaCache supports precise eviction
add ae8f284d429 Fix the data scan ordering when executing last query
add ed62ba67cd4 [IOTDB-6168] ConfigNode register retry logic does not
worked (#11188)
add 9ab3c422cdb Auth online upgrade
add fde69bc82c2 Fix auth check when alter and create view
add 0f2cf0a3b48 Optimize merge selection process and increase disk space
availability logic (#11197)
add 1c3ab3900c7 Pipe: fix drop pipe stuck (make connector subtask close
faster by early returning) (#11222)
add 62a956d3ed5 [auth].fix internal error when check sysPri grant option
add 4d3a16fb61b Bump org.apache.avro:avro in
/iotdb-connector/hive-connector (#11236)
add 7af3d774343 Bump org.apache.tomcat.embed:tomcat-embed-core from
10.1.0-M1 to 10.0.27 in /iotdb-core/datanode (#11235)
add 4d38980c075 Bump postcss from 8.4.21 to 8.4.31 in
/iotdb-connector/grafana-plugin (#11238)
add 24dd2b7f2c9 [IOTDB-6160] Correct the target paths verify logic in
Select Into
add 68b394a470e Pipe: instantiate iotdb-thrift-connector from sync to
async (#11248)
add e929ceed0c0 Allow `\``*`\`` in DevicePath (#10901)
add e3c8643fae2 chore: Enable ge.apache.org
add fefb873a8bf Pipe: add status message for procedure execution timed out
(#11257)
add 18a4d91b94f [IOTDB-6177] Pipe: Removed the exception time judgement
when reporting exceptions to avoid losing failure message (#11249)
add 7c976f13c55 [IOTDB-6176] Pipe: record SimpleProgressIndex for
insertion when using SimpleConsensus to avoid wrong advance progress report
(#11255)
add 6f83353c2f3 [IOTDB-6179] Load: remove uncessary create schema logic
when loading tsfiles (which allows users without create schema permission to
execute load) (#11256)
add 9ffca1c7997 Load: skipping instead of throwing exceptions when loading
empty tsfiles (#11261)
add ff7fdb795ab [IOTDB-6183] Optimize the timeout retry logic of
IoTConsensus sending RPCS (#11266)
add c0260ea7b5c Fix NPE when partially inserting tablet span multiple data
partitions
add f36af625129 Add database and region tag into tsfile metrics (#11228)
add f22baa079c0 [IOTDB-6185] Fix show cluster null status bug (#11273)
add 6a3b3e33650 Fixed failed to compile Grafana plugin using the latest
version of SDK (#11271)
add 59e97fd405a [IOTDB-6184] MergeSort should break when one tsBlock is
run out in one iteration. (#11270)
add 1be2eebac36 Fixed ping command for rest service (#11247)
add 8951eb8ce04 Pipe: running count of the connector does not return to
zero after exceptions occur (resulting in the failure of the automatic restart
mechanism) (#11279)
add 9111d69d217 Refactor the CompactionWorker part of Compaction framework
(#11242)
add f3619920e29 Bump golang.org/x/net in /iotdb-connector/grafana-plugin
(#11288)
add 5bbe062515c Pipe: fix recovering huge entry from wal with wrong
position bug & fix multi pipes sharing the same ByteBuffer (#11285)
add 2ee7675ce10 Pipe: make hybrid extractor aware of event collector's
queue size & block processor subtask's execution when events buffered in
EventCollector (#11283)
add 4cee8227e75 [IOTDB-6182] Add fsync in ConfigNode persistence modules
(#11264)
add 52ce8855836 Add stopwatch for AbstractConsumeAllOperator
add 32a1e10b2e4 Fix SYS_DISK_FREE_SPACE metric and add SYS_AVAILABLE_SPACE
metric (#11289)
add af56f90e26a Added fsync operation when persisting files (#11275)
add 1d1b52cccb8 Optimize result set iteration in Python Client (#11231)
add 848af7209ec upgrade compression ratio file name format and solve the
problem of high compression ratio caused by repeated data writing (#11220)
add b61f634b57e Fix the problem of inaccurate GC monitor detection at the
beginning and adjusting the alert threshold. (#11297)
add 8c384da094c [IOTDB-6188] Load: Optimize the return of error codes
related to user privileges (#11299)
add 17ba8eb944f add disk free ration check before compaction task start
(#11292)
add 5f7a0bff761 Fix potential loss of metrics when restart confignode
(#11287)
add 0b57fd39e1d [auth].fix error when check role. (#11293)
add c66f53faf97 fix(csv):Fixed the prompt after CSV file import (#10835)
add cfca49e0e0f Pipe: fix tsfile and wal forever pinned when enabling log
batch mode in iotdb-async-thrift-connector & fine tune hybrid extractor mode
(#11305)
add ae77b4f360e [IOTDB-6190] Increase the threshold for Ratis to shut
itself down if it detects that a process is stuck
add ba77da8a75a [IOTDB-6178] Add fsync for schemaregion, CQInfo, ModelInfo
add 46fd4520026 Fix bad tsfile being recoverd from wal (#11276)
add e1a0830ff27 ci(grafana): only build on
iotdb-connector/grafana-plugin/** changed (#11311)
add 16f287f2cab Fixed an issue where searchIndex was not restored properly
after IoT protocol restart (#11306)
add 24f24eaee51 Set ShowQuries related DriverTasks to the highest priority
add 676a21bacbd fix(cli-windows): Ensure that any user defined CLASSPATH
variables are not used on startup (#11316)
add e93d0fcaaa6 Set default compaction validation level to RESOURCE_ONLY
(#11278)
add 15824d9a292 Pipe: fix missing `pipeReceiverFileDir` update after
updating `systemDir` during conf initialization (#11318)
add 37a5212f23a [IOTDB-6175] Add TopKNode for `order by time|expression
limit N align by device` query and push down LIMIT value.
add 87a15d2860a [IOTDB-6189] Fix bugs for csv-tools (The output is
incorrect when the import fails. The csv file with bom header can not be
imported. The last line can not be imported) (#11308)
add fd1b9823d8e Refactor/managing dependencies (#11150)
add e4e07feed4e Bump org.xerial.snappy:snappy-java from 1.1.8.4 to 1.1.10.4
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 (be638dab1d3)
\
N -- N -- N
refs/heads/dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.4 (e4e07feed4e)
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/client-go.yml | 1 +
.github/workflows/client-python.yml | 1 +
.github/workflows/cluster-it-1c1d.yml | 1 +
.github/workflows/cluster-it-1c3d.yml | 1 +
.github/workflows/grafana-plugin.yml | 15 +-
.github/workflows/iotdb-ml.yml | 1 +
.github/workflows/pipe-it-2cluster.yml | 1 +
.github/workflows/sonar-codecov.yml | 1 +
.github/workflows/unit-test.yml | 1 +
.gitignore | 3 +
.../conf/logback-tool.xml => .mvn/extensions.xml | 29 +-
.mvn/gradle-enterprise.xml | 48 +
code-coverage/pom.xml | 72 +-
distribution/pom.xml | 165 +-
example/client-cpp-example/pom.xml | 28 +-
example/flink-sql/pom.xml | 2 +-
example/flink/pom.xml | 22 +-
example/hadoop/pom.xml | 2 +-
example/jdbc/pom.xml | 4 +-
example/pom.xml | 61 +-
example/pulsar/pom.xml | 2 +-
example/rest-java-example/pom.xml | 7 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 3 +-
example/trigger/pom.xml | 10 +-
example/udf/pom.xml | 4 +-
integration-test/checkstyle.xml | 2 +-
integration-test/pom.xml | 592 +++--
.../iotdb/it/env/cluster/env/AbstractEnv.java | 12 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 18 +-
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 7 +-
.../iotdb/it/framework/IoTDBTestConstants.java | 11 +-
.../iotdb/it/framework/IoTDBTestReporter.java | 4 +-
.../apache/iotdb/it/framework/IoTDBTestStat.java | 4 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 71 +
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 102 +
.../IoTDBOrderByWithAlignByDeviceIT.java | 290 ++-
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 12 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 6 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 10 +-
.../IoTDBStrangePathIT.java} | 33 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 159 +-
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 4 +-
.../iotdb/it/framework/IoTDBTestListener.java | 7 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 0
.../framework/IoTDBTestRunnerWithParameters.java | 0
.../IoTDBTestRunnerWithParametersFactory.java | 0
.../apache/iotdb/libudf/it/anomaly/AnomalyIT.java | 121 +-
.../iotdb/libudf/it/dprofile/DProfileIT.java | 12 +-
.../iotdb/libudf/it/dquality/DQualityIT.java | 2 +
.../apache/iotdb/libudf/it/drepair/DRepairIT.java | 2 +
.../iotdb/libudf/it/frequency/FrequencyIT.java | 2 +
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 5 +-
iotdb-api/external-api/pom.xml | 8 +-
iotdb-api/pipe-api/pom.xml | 8 +-
iotdb-api/trigger-api/pom.xml | 14 +-
iotdb-api/udf-api/pom.xml | 6 +-
iotdb-client/cli/pom.xml | 178 +-
.../cli/src/assembly/resources/sbin/start-cli.bat | 16 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 1 -
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 86 +-
iotdb-client/client-cpp/pom.xml | 61 +-
iotdb-client/client-py/iotdb/Session.py | 57 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.py | 12 +-
iotdb-client/client-py/iotdb/utils/Field.py | 148 +-
.../client-py/iotdb/utils/IoTDBConstants.py | 33 +-
.../client-py/iotdb/utils/IoTDBRpcDataSet.py | 299 ++-
iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 8 +-
.../client-py/iotdb/utils/SessionDataSet.py | 90 +-
iotdb-client/client-py/iotdb/utils/Tablet.py | 14 +-
iotdb-client/client-py/pom.xml | 45 +-
iotdb-client/client-py/tests/test_tablet.py | 18 +-
iotdb-client/isession/pom.xml | 21 +-
iotdb-client/jdbc/pom.xml | 128 +-
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 2 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 2 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 2 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 2 +-
iotdb-client/service-rpc/pom.xml | 104 +-
iotdb-client/session/pom.xml | 105 +-
.../iotdb/session/SessionConnectionTest.java | 388 ++++
.../java/org/apache/iotdb/session/SessionTest.java | 1175 ++++++++++
.../session/pool/SessionPoolExceptionTest.java | 266 +++
.../apache/iotdb/session/pool/SessionPoolTest.java | 1264 ++++++++++-
.../iotdb/session/util/SessionUtilsTest.java | 176 ++
iotdb-connector/flink-iotdb-connector/pom.xml | 35 +-
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 2 +-
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 2 +-
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 2 +-
iotdb-connector/flink-sql-iotdb-connector/pom.xml | 72 +-
.../flink/sql/function/IoTDBLookupFunction.java | 4 +-
iotdb-connector/flink-tsfile-connector/pom.xml | 112 +-
.../src/test/resources/log4j.properties | 16 +-
iotdb-connector/grafana-connector/pom.xml | 138 +-
.../iotdb/web/grafana/conf/MyConfiguration.java | 15 +-
.../web/grafana/interceptor/LoginInterceptor.java | 14 +-
iotdb-connector/grafana-plugin/go.mod | 85 +-
.../grafana-plugin/pkg/plugin/plugin.go | 6 +-
iotdb-connector/grafana-plugin/pom.xml | 6 +-
iotdb-connector/grafana-plugin/yarn.lock | 16 +-
iotdb-connector/hadoop/pom.xml | 105 +-
.../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 5 +
iotdb-connector/hive-connector/pom.xml | 178 +-
iotdb-connector/pom.xml | 15 +
iotdb-connector/spark-iotdb-connector/pom.xml | 101 +-
.../spark-iotdb-connector/scala_2.11/pom.xml | 5 +-
.../spark-iotdb-connector/scala_2.12/pom.xml | 7 +
iotdb-connector/spark-tsfile/pom.xml | 87 +-
iotdb-connector/zeppelin-interpreter/pom.xml | 38 +-
iotdb-core/antlr/pom.xml | 20 +-
iotdb-core/confignode/pom.xml | 150 +-
.../confignode/conf/SystemPropertiesUtils.java | 1 +
.../statemachine/ConfigRegionStateMachine.java | 5 +
.../iotdb/confignode/manager/ConfigManager.java | 37 +-
.../apache/iotdb/confignode/manager/IManager.java | 2 +
.../confignode/manager/PermissionManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 11 +-
.../manager/partition/PartitionMetrics.java | 250 +-
.../manager/pipe/runtime/PipeHeartbeatParser.java | 19 +-
.../manager/schema/ClusterSchemaManager.java | 73 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 139 +-
.../iotdb/confignode/persistence/ModelInfo.java | 1 +
.../iotdb/confignode/persistence/cq/CQInfo.java | 1 +
.../confignode/persistence/node/NodeInfo.java | 7 +-
.../persistence/partition/PartitionInfo.java | 29 +-
.../procedure/env/DataNodeRemoveHandler.java | 2 +-
.../impl/node/AddConfigNodeProcedure.java | 9 +
.../impl/schema/DeleteDatabaseProcedure.java | 2 +-
.../confignode/procedure/store/ProcedureWAL.java | 3 +
.../iotdb/confignode/service/ConfigNode.java | 11 +-
.../confignode/persistence/AuthorInfoTest.java | 651 ++++++
.../iotdb/confignode/persistence/NodeInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 2 +-
iotdb-core/consensus/pom.xml | 140 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 2 +-
.../consensus/iot/IoTConsensusServerImpl.java | 32 +-
.../iot/client/IoTConsensusClientPool.java | 11 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 2 +-
iotdb-core/datanode/pom.xml | 567 +++--
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 45 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 12 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 8 +-
.../pipe/agent/runtime/PipeCronEventInjector.java | 2 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 5 +-
.../SimpleConsensusProgressIndexAssigner.java | 12 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 76 +
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 7 +-
.../thrift/async/IoTDBThriftAsyncConnector.java | 5 +-
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 10 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 65 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 16 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 8 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 148 +-
.../pipe/extractor/realtime/epoch/TsFileEpoch.java | 3 +-
.../realtime/epoch/TsFileEpochManager.java | 4 +-
.../db/pipe/resource/wal/PipeWALResource.java | 2 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 4 +
.../pipe/task/connection/BlockingPendingQueue.java | 61 +-
.../db/pipe/task/connection/EnrichedDeque.java | 98 +
.../pipe/task/connection/PipeEventCollector.java | 23 +-
.../connection/UnboundedBlockingPendingQueue.java | 60 -
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 29 +-
.../subtask/connector/PipeConnectorSubtask.java | 42 +-
.../connector/PipeConnectorSubtaskManager.java | 2 +-
.../subtask/processor/PipeProcessorSubtask.java | 44 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 5 +
.../protocol/rest/filter/AuthorizationFilter.java | 7 +-
.../PingApiServiceImpl.java} | 34 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 16 +-
.../db/queryengine/execution/driver/Driver.java | 12 +
.../db/queryengine/execution/driver/IDriver.java | 4 +
.../execution/exchange/SharedTsBlockQueue.java | 9 +
.../fragment/FragmentInstanceManager.java | 5 +
.../process/AbstractConsumeAllOperator.java | 101 +-
.../operator/process/MergeSortOperator.java | 61 +-
.../execution/operator/process/TopKOperator.java | 323 +++
.../process/join/RowBasedTimeJoinOperator.java | 57 +-
.../last/AlignedUpdateLastCacheOperator.java | 6 +-
.../execution/schedule/DriverScheduler.java | 5 +-
.../multilevelqueue/MultilevelPriorityQueue.java | 111 +-
.../execution/schedule/task/DriverTask.java | 22 +-
.../db/queryengine/plan/analyze/Analysis.java | 23 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 78 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 10 +-
.../analyze/cache/partition/PartitionCache.java | 10 +-
.../analyze/cache/schema/DataNodeSchemaCache.java | 64 +-
.../schema/DeviceUsingTemplateSchemaCache.java | 18 +
.../analyze/cache/schema/SchemaCacheEntry.java | 16 +-
.../cache/schema/TimeSeriesSchemaCache.java | 71 +-
.../cache/schema/dualkeycache/IDualKeyCache.java | 22 +
.../dualkeycache/impl/CacheEntryGroupImpl.java | 6 +
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 159 +-
.../dualkeycache/impl/FIFOCacheEntryManager.java | 60 +-
.../schema/dualkeycache/impl/ICacheEntry.java | 2 +
.../schema/dualkeycache/impl/ICacheEntryGroup.java | 4 +
.../dualkeycache/impl/ICacheEntryManager.java | 2 +
.../dualkeycache/impl/LRUCacheEntryManager.java | 86 +-
.../schema/lastcache/DataNodeLastCacheManager.java | 6 +-
.../queryengine/plan/execution/QueryExecution.java | 8 +
.../db/queryengine/plan/parser/ASTVisitor.java | 11 +-
.../plan/planner/LocalExecutionPlanner.java | 4 +-
.../plan/planner/LogicalPlanBuilder.java | 311 ++-
.../plan/planner/LogicalPlanVisitor.java | 36 +-
.../plan/planner/OperatorTreeGenerator.java | 40 +
.../distribution/DistributionPlanContext.java | 5 +-
.../planner/distribution/DistributionPlanner.java | 22 +-
.../planner/distribution/ExchangeNodeAdder.java | 166 +-
.../planner/distribution/NodeGroupContext.java | 18 +-
.../plan/planner/distribution/SourceRewriter.java | 110 +-
.../plan/planner/plan/FragmentInstance.java | 10 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 6 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../process/{MergeSortNode.java => TopKNode.java} | 54 +-
.../node/process/last/LastQueryTransformNode.java | 7 +
.../planner/plan/node/sink/IdentitySinkNode.java | 5 +
.../planner/plan/node/sink/ShuffleSinkNode.java | 12 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +-
.../planner/plan/node/write/InsertTabletNode.java | 45 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/component/IntoComponent.java | 2 +
.../metadata/view/AlterLogicalViewStatement.java | 26 +-
.../metadata/view/CreateLogicalViewStatement.java | 19 +-
.../plan/statement/sys/AuthorStatement.java | 4 +-
.../plan/statement/sys/ShowQueriesStatement.java | 3 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 9 +-
.../org/apache/iotdb/db/service/MQTTService.java | 7 +-
.../iotdb/db/service/metrics/FileMetrics.java | 542 +----
.../metrics/file/CompactionFileMetrics.java | 165 ++
.../metrics/file/ModsFileMetrics.java} | 69 +-
.../metrics/file/SystemRelatedFileMetrics.java | 109 +
.../db/service/metrics/file/TsFileMetrics.java | 414 ++++
.../metrics/file/WalFileMetrics.java} | 35 +-
.../db/storageengine/dataregion/DataRegion.java | 57 +-
.../FileCannotTransitToCompactingException.java | 30 +-
.../execute/task/AbstractCompactionTask.java | 71 +-
.../CompactionTaskType.java} | 17 +-
.../execute/task/CrossSpaceCompactionTask.java | 90 +-
.../execute/task/InnerSpaceCompactionTask.java | 105 +-
.../compaction/execute/utils/CompactionUtils.java | 47 +-
.../execute/utils/log/CompactionLogger.java | 34 +-
.../compaction/schedule/CompactionScheduler.java | 28 +-
.../compaction/schedule/CompactionTaskManager.java | 4 -
.../compaction/schedule/CompactionWorker.java | 72 +-
.../DefaultCompactionTaskComparatorImpl.java | 7 +
.../compaction/selector/ICompactionSelector.java | 3 +-
.../selector/IInnerSeqSpaceSelector.java | 3 +-
.../selector/IInnerUnseqSpaceSelector.java | 3 +-
.../impl/SizeTieredCompactionSelector.java | 121 +-
.../compaction/settle/SettleRequestHandler.java | 1 -
.../dataregion/flush/CompressionRatio.java | 132 +-
.../memtable/AlignedWritableMemChunk.java | 19 +-
.../dataregion/memtable/TsFileProcessor.java | 10 +-
.../dataregion/memtable/WritableMemChunk.java | 18 +-
.../io/LocalTextModificationAccessor.java | 36 +-
.../modification/io/ModificationWriter.java | 3 +
.../dataregion/snapshot/SnapshotLogger.java | 6 +-
.../dataregion/tsfile/TsFileResource.java | 84 +-
.../dataregion/wal/buffer/WALBuffer.java | 30 +-
.../storageengine/dataregion/wal/node/WALNode.java | 5 +
.../dataregion/wal/recover/WALNodeRecoverTask.java | 61 +-
.../wal/recover/file/TsFilePlanRedoer.java | 9 +-
.../file/UnsealedTsFileRecoverPerformer.java | 61 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 19 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 9 +-
.../db/utils/datastructure/MergeSortHeap.java | 4 +
.../iotdb/db/utils/datastructure/MergeSortKey.java | 3 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 55 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 59 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 62 +-
.../db/auth/user/LocalFileUserManagerTest.java | 56 +-
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 40 +-
.../cache/dualkeycache/DualKeyCacheTest.java | 185 +-
.../db/queryengine/execution/DataDriverTest.java | 1 +
.../operator/AlignedSeriesScanOperatorTest.java | 2 +
.../operator/HorizontallyConcatOperatorTest.java | 3 +
.../execution/operator/LimitOperatorTest.java | 2 +
.../execution/operator/MergeSortOperatorTest.java | 244 +-
.../execution/operator/OffsetOperatorTest.java | 4 +
.../operator/SingleDeviceViewOperatorTest.java | 2 +
.../execution/operator/SortOperatorTest.java | 3 +
...SortOperatorTest.java => TopKOperatorTest.java} | 1046 +++------
.../schedule/DefaultDriverSchedulerTest.java | 28 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 19 +-
.../queue/MultilevelPriorityQueueTest.java | 199 ++
.../queryengine/plan/analyze/AnalyzeFailTest.java | 5 +
.../db/queryengine/plan/analyze/AnalyzeTest.java | 14 +-
.../AlignByDeviceOrderByLimitOffsetTest.java | 278 +++
.../storageengine/dataregion/DataRegionTest.java | 2 -
.../compaction/CompactionTaskComparatorTest.java | 121 +-
.../compaction/CompactionTaskManagerTest.java | 26 +-
...yControlTest.java => CompactionWorkerTest.java} | 78 +-
.../CrossSpaceCompactionWithUnusualCasesTest.java | 9 -
.../compaction/FastAlignedCrossCompactionTest.java | 47 -
.../FastCompactionPerformerWithEmptyPageTest.java | 2 -
...InconsistentCompressionTypeAndEncodingTest.java | 7 -
.../FastCrossCompactionPerformerTest.java | 17 +-
.../FastInnerCompactionPerformerTest.java | 121 +-
.../FastNonAlignedCrossCompactionTest.java | 47 -
.../compaction/ReadChunkInnerCompactionTest.java | 19 +-
.../ReadPointAlignedCrossCompactionTest.java | 47 -
.../ReadPointNonAlignedCrossCompactionTest.java | 47 -
.../cross/CrossSpaceCompactionSelectorTest.java | 92 +-
.../CrossSpaceCompactionWithFastPerformerTest.java | 4 -
...eCompactionWithFastPerformerValidationTest.java | 173 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 4 -
...actionWithReadPointPerformerValidationTest.java | 160 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 12 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 12 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 2 -
.../InnerSeqCompactionWithFastPerformerTest.java | 14 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 7 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 112 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 4 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 4 +-
.../utils/CompactionFileGeneratorUtils.java | 23 +-
.../utils/CompactionUpdateFileCountTest.java | 42 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 7 -
.../dataregion/flush/CompressionRatioTest.java | 108 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 35 +-
.../wal/utils/WALInsertNodeCacheTest.java | 155 +-
.../db/utils/datastructure/MergeSortHeapTest.java | 116 +
iotdb-core/metrics/dropwizard-metrics/pom.xml | 14 +-
iotdb-core/metrics/interface/pom.xml | 81 +-
.../iotdb/metrics/AbstractMetricService.java | 1 +
.../metrics/metricsets/system/SystemMetrics.java | 31 +-
.../apache/iotdb/metrics/utils/SystemMetric.java | 1 +
iotdb-core/metrics/micrometer-metrics/pom.xml | 10 +-
iotdb-core/metrics/pom.xml | 6 +-
iotdb-core/mlnode/pom.xml | 74 +-
iotdb-core/node-commons/pom.xml | 299 ++-
.../resources/conf/iotdb-common.properties | 2 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 42 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 19 +
.../commons/auth/authorizer/OpenIdAuthorizer.java | 2 +-
.../commons/auth/entity/PriPrivilegeType.java | 91 +
.../org/apache/iotdb/commons/auth/entity/Role.java | 10 +
.../iotdb/commons/auth/role/BasicRoleManager.java | 88 +-
.../iotdb/commons/auth/role/IRoleManager.java | 6 +
.../commons/auth/role/LocalFileRoleAccessor.java | 25 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 98 +-
.../iotdb/commons/auth/user/IUserManager.java | 6 +
.../commons/auth/user/LocalFileUserAccessor.java | 60 +-
.../client/property/ThriftClientProperty.java | 3 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 27 +-
.../iotdb/commons/conf/CommonDescriptor.java | 11 +-
.../PipeRuntimeConnectorCriticalException.java | 6 +-
.../pipe/PipeRuntimeCriticalException.java | 5 -
.../pipe/PipeRuntimeNonCriticalException.java | 5 -
.../iotdb/commons/pipe/config/PipeConfig.java | 16 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 26 +-
.../service/metric/JvmGcMonitorMetrics.java | 35 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 81 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 45 +
.../apache/iotdb/commons/utils/AuthUtilsTest.java | 12 +
iotdb-core/tsfile/pom.xml | 182 +-
.../iotdb/tsfile/file/header/ChunkGroupHeader.java | 3 +
.../iotdb/tsfile/read/common/block/TsBlock.java | 46 +
.../tsfile/write/writer/LocalTsFileOutput.java | 6 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 7 +
.../iotdb/tsfile/write/writer/TsFileOutput.java | 3 +
.../tsfile/read/TsFileSequenceReaderTest.java | 11 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 2 +
.../write/writer/RestorableTsFileIOWriterTest.java | 37 +
.../tsfile/write/writer/TestTsFileOutput.java | 5 +
iotdb-protocol/openapi/pom.xml | 100 +-
iotdb-protocol/thrift-commons/pom.xml | 14 +-
iotdb-protocol/thrift-confignode/pom.xml | 28 +-
iotdb-protocol/thrift-consensus/pom.xml | 28 +-
iotdb-protocol/thrift-datanode/pom.xml | 46 +-
iotdb-protocol/thrift-mlnode/pom.xml | 28 +-
library-udf/pom.xml | 43 +-
pom.xml | 2376 +++++++++++++++-----
377 files changed, 16600 insertions(+), 7265 deletions(-)
copy iotdb-core/confignode/src/assembly/resources/conf/logback-tool.xml =>
.mvn/extensions.xml (55%)
create mode 100644 .mvn/gradle-enterprise.xml
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/RpcThrottlingException.java
=>
integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestConstants.java
(83%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBOrderByLimitOffsetAlignByDeviceIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{specialwords/IoTDBSpecialWordsIT.java
=> strangepath/IoTDBStrangePathIT.java} (75%)
rename integration-test/src/{main =>
test}/java/org/apache/iotdb/it/framework/IoTDBTestListener.java (89%)
rename integration-test/src/{main =>
test}/java/org/apache/iotdb/it/framework/IoTDBTestRunner.java (100%)
rename integration-test/src/{main =>
test}/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParameters.java
(100%)
rename integration-test/src/{main =>
test}/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParametersFactory.java
(100%)
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/SessionConnectionTest.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/SessionTest.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/pool/SessionPoolExceptionTest.java
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/util/SessionUtilsTest.java
copy docker/src/main/DockerCompose/start-1c1d.sh =>
iotdb-connector/flink-tsfile-connector/src/test/resources/log4j.properties (70%)
mode change 100755 => 100644
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/EnrichedDeque.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/{handler/AuthorizationHandler.java
=> impl/PingApiServiceImpl.java} (50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TopKOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/{MergeSortNode.java
=> TopKNode.java} (71%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/CompactionFileMetrics.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution/exchange/MppDataExchangeServiceThriftHandlerMetrics.java
=> service/metrics/file/ModsFileMetrics.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/SystemRelatedFileMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/TsFileMetrics.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution/exchange/MPPDataExchangeServiceMetrics.java
=> service/metrics/file/WalFileMetrics.java} (64%)
copy
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopException.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/FileCannotTransitToCompactingException.java
(59%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/{performer/ICrossCompactionPerformer.java
=> task/CompactionTaskType.java} (72%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/{MergeSortOperatorTest.java
=> TopKOperatorTest.java} (60%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/MultilevelPriorityQueueTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/distribution/AlignByDeviceOrderByLimitOffsetTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{MemoryControlTest.java
=> CompactionWorkerTest.java} (76%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/datastructure/MergeSortHeapTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/PriPrivilegeType.java
