This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/extendFilter
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 545362d313b fix sonar code smell
add 259d3fcd618 Fix npe in TopKOperator when topKResult is null
add 7b82a00764d Fix compaction selector ut running time is too long
(#11635)
add afc6c7f916f Only root can alter template
add 431e9b81e80 Fix error judgement for MainFragmentLocatedRegion and
MostlyUsedDataRegion in distributed plan
add 919a24f3d37 fix:grafana plugin build
add 80c5b2ad138 auth.add IT for create role/user with identifier.
add 2a1fad8c871 Bump ch.qos.logback:logback-classic from 1.3.11 to 1.3.12
(#11645)
add 0dcb04086e3 Get correct TsFileSequenceReader from FileReaderManager
add 0cc841b7639 Fix close method of TopOperator and make close method of
Operator an interface
add d0918bd367a Temporarily ignore testPBTreeMemoryStatistics (#11648)
add 2aadeb4a93c [IOTDB-6259] Bump ratis version to 3.0.0 (#11618)
add 477e8e5480c [IOTDB-6248] Fix the connection will close when
WebSocketConnectorServer doesn't response in Flink-CDC-Connector & Fix multiple
cdc tasks cannot run properly at the same time (#11598)
add 35c29e16cfc Fix concurrent bug During Heartbeat and Region Creation
(#11656)
add 636bd465714 delete data and files together
add 0144133481c PBTree Improvement: WrappedSegment Layout Revision for
Reduced GC Overhead (#11652)
add 9eb60a9faa8 Bump logback.version from 1.3.12 to 1.3.13 (#11653)
add b2be051adb0 fix the error when last query non-writble view with same
sensors (#11658)
add b232fcf163d fix inner compaction select task base on mod file (#11654)
add 4a9fb924391 Fix file counted twice in TsFileMetrics (#11662)
add 3427b320b62 Fix compaction UTs and add concurrency control when
schedule compaction (#11638)
add f48454ab50a Update iotdb-doap.rdf
add 2edc91d287f Add format check for Prometheus Reporter Check (#11666)
add ec118416f36 Added getRegionId api for partitionManager (#11663)
add 24f0a606cbc Ignore MismatchedType caused by delete
add 639d1f379ef Merge remote-tracking branch 'origin/master' into
lmh/extendFilter
add 911f60da7f6 merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/grafana-plugin.yml | 2 +-
example/schema/pom.xml | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 1 +
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 34 +
.../IoTDBAlignByDeviceWithTemplateIT.java | 16 +
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 25 +-
.../db/it/auth/IoTDBTemplatePermissionIT.java | 5 +
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 71 +++
.../flink/sql/client/IoTDBWebSocketClient.java | 20 +-
.../flink/sql/function/IoTDBCDCSourceFunction.java | 84 ++-
iotdb-connector/grafana-plugin/backend-compile.bat | 2 +-
iotdb-connector/grafana-plugin/backend-compile.sh | 31 +-
iotdb-connector/grafana-plugin/go.mod | 35 +-
.../manager/partition/PartitionManager.java | 15 +-
.../partition/DatabasePartitionTable.java | 8 +
.../persistence/partition/PartitionInfo.java | 8 +
.../confignode/persistence/PartitionInfoTest.java | 70 +-
iotdb-core/consensus/pom.xml | 10 +-
.../consensus/ratis/metrics/CounterProxy.java | 6 +-
.../iotdb/consensus/ratis/metrics/GaugeProxy.java | 24 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 121 +---
.../ratis/metrics/MetricRegistryManager.java | 2 +-
.../ratis/metrics/RatisMetricsManager.java | 20 +-
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 32 +-
.../dataregion/DataExecutionVisitor.java | 21 +-
.../protocol/websocket/WebSocketConnector.java | 95 ++-
.../websocket/WebSocketConnectorServer.java | 467 ++++++++++----
.../db/queryengine/execution/driver/Driver.java | 4 -
.../execution/exchange/sink/LocalSinkChannel.java | 39 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 27 +-
.../execution/exchange/sink/SinkChannel.java | 73 ++-
.../exchange/source/LocalSourceHandle.java | 15 +-
.../execution/exchange/source/SourceHandle.java | 20 +-
.../fragment/FragmentInstanceExecution.java | 3 +-
.../queryengine/execution/memory/MemoryPool.java | 6 +-
.../queryengine/execution/operator/Operator.java | 12 +-
.../execution/operator/process/TopKOperator.java | 35 +-
.../operator/schema/SchemaFetchScanOperator.java | 5 +
.../source/AbstractDataSourceOperator.java | 5 +
.../operator/source/AlignedSeriesScanUtil.java | 6 +
.../operator/source/LastCacheScanOperator.java | 5 +
.../execution/operator/source/SeriesScanUtil.java | 6 +
.../operator/source/ShowQueriesOperator.java | 5 +
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 2 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 1 +
.../analyze/schema/AutoCreateSchemaExecutor.java | 61 +-
.../planner/distribution/ExchangeNodeAdder.java | 41 +-
.../template/AlterSchemaTemplateStatement.java | 19 -
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 33 +-
.../mtree/impl/pbtree/schemafile/InternalPage.java | 18 +-
.../mtree/impl/pbtree/schemafile/SchemaPage.java | 2 +-
.../mtree/impl/pbtree/schemafile/Segment.java | 478 --------------
.../impl/pbtree/schemafile/WrappedSegment.java | 708 +++++++++++++++++----
.../db/service/metrics/file/TsFileMetrics.java | 8 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 10 +-
.../db/storageengine/dataregion/DataRegion.java | 175 ++++-
.../compaction/schedule/CompactionScheduler.java | 13 +
.../impl/SizeTieredCompactionSelector.java | 3 +
.../compaction/settle/SettleRequestHandler.java | 24 +-
.../io/LocalTextModificationAccessor.java | 3 -
.../read/reader/chunk/DiskAlignedChunkLoader.java | 6 +-
.../read/reader/chunk/DiskChunkLoader.java | 6 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +
.../execution/operator/FillOperatorTest.java | 15 +
.../operator/LastQueryMergeOperatorTest.java | 20 +
.../execution/operator/LinearFillOperatorTest.java | 35 +
.../execution/operator/TopKOperatorTest.java | 297 +++++++--
.../db/storageengine/buffer/ChunkCacheTest.java | 6 +-
.../storageengine/dataregion/DataRegionTest.java | 86 +++
.../compaction/CompactionSchedulerTest.java | 25 +-
.../ReadPointCompactionPerformerTest.java | 2 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 63 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 15 +
.../tsfile/file/metadata/ITimeSeriesMetadata.java | 4 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 9 +
.../read/reader/chunk/AlignedChunkReader.java | 2 +-
iotdb-doap.rdf | 33 +
pom.xml | 8 +-
79 files changed, 2451 insertions(+), 1277 deletions(-)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/Segment.java
