This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch optiNewStandaloneAutoCreateSchema
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0bd055d272 Fix insert OOM
add 9855b3688e [IOTDB-3432] Add IT for raw query (#6188)
add 08006e2ae0 [IOTDB-3360] Fix precision loss bug due to float converted
to double (#6192)
add 0868dfa889 Add thread name for log (#6202)
add 4fde65e41e [IOTDB-3394] Add cache metrics (#6201)
add 5d48b1ecd8 [IOTDB-3425] [IOTDB-3415] add permission operate to
LocalConfigNode && Abstract an interface for Standalone Authority Check (#6196)
add b9aea02d8f Fix insert OOM
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/persistence/AuthorInfo.java | 1 +
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 6 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 5 +-
.../org/apache/iotdb/it/env/ClusterEnvConfig.java | 29 +
.../org/apache/iotdb/it/env/ConfigFactory.java | 11 +-
.../iotdb/itbase}/constant/TestConstant.java | 2 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 24 +
.../iotdb/db/it}/aligned/AlignedWriteUtil.java | 24 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 39 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 41 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1472 ++++++++++++++++++++
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 41 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 150 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 51 +
.../db/integration/aligned/IoTDBLastQuery2IT.java | 65 -
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 68 -
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 381 -----
.../IoTDBRawQueryWithoutValueFilter2IT.java | 66 -
.../IoTDBRawQueryWithoutValueFilter3IT.java | 63 -
.../aligned/IoTDBRawQueryWithoutValueFilterIT.java | 633 ---------
pom.xml | 9 +-
server/pom.xml | 4 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 8 +-
.../org/apache/iotdb/db/auth/AuthorityFetcher.java | 182 ---
.../apache/iotdb/db/auth/AuthorizerManager.java | 225 +--
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 341 +++++
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 32 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 133 ++
.../engine/compaction/CompactionTaskManager.java | 11 +-
.../utils/AlignedSeriesCompactionExecutor.java | 8 +-
.../utils/SingleSeriesCompactionExecutor.java | 10 +-
.../writer/AbstractCompactionWriter.java | 4 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 234 ++++
.../db/metadata/cache/DataNodeSchemaCache.java | 17 +
.../iotdb/db/mpp/common/FragmentInstanceId.java | 7 +-
.../execution/datatransfer/DataBlockManager.java | 265 ++--
.../db/mpp/execution/datatransfer/SinkHandle.java | 73 +-
.../mpp/execution/datatransfer/SourceHandle.java | 271 ++--
.../fragment/FragmentInstanceManager.java | 67 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 119 +-
.../mpp/execution/schedule/DriverTaskThread.java | 69 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 36 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 41 +-
.../db/mpp/plan/execution/IQueryExecution.java | 2 +
.../db/mpp/plan/execution/QueryExecution.java | 28 +-
...thorizerConfigTask.java => AuthorizerTask.java} | 42 +-
.../mpp/plan/execution/config/ConfigExecution.java | 5 +
.../plan/execution/config/ConfigTaskVisitor.java | 2 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 14 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 13 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 86 --
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 14 +-
.../query/reader/chunk/MemAlignedPageReader.java | 52 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +-
.../iotdb/db/service/metrics/enums/Metric.java | 1 +
.../metrics/recorder/CacheMetricsRecorder.java} | 73 +-
.../recorder/CompactionMetricsRecorder.java} | 16 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 44 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 38 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 8 +
60 files changed, 3262 insertions(+), 2517 deletions(-)
copy {server/src/main/java/org/apache/iotdb/db =>
integration-test/src/main/java/org/apache/iotdb/itbase}/constant/TestConstant.java
(99%)
copy {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/AlignedWriteUtil.java
(95%)
copy
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilter2IT.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery2IT.java
(53%)
copy
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilter2IT.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery3IT.java
(52%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java
copy
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilter2IT.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCache2IT.java
(53%)
rename
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryIT.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheIT.java
(61%)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQuery2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCache2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilter3IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterIT.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/auth/AuthorityFetcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/auth/ClusterAuthorityFetcher.java
copy
service-rpc/src/main/java/org/apache/iotdb/rpc/BatchExecutionException.java =>
server/src/main/java/org/apache/iotdb/db/auth/IAuthorityFetcher.java (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{AuthorizerConfigTask.java
=> AuthorizerTask.java} (73%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/rescon/TimeseriesStatistics.java
=> service/metrics/recorder/CacheMetricsRecorder.java} (50%)
rename
server/src/main/java/org/apache/iotdb/db/{engine/compaction/CompactionMetricsManager.java
=> service/metrics/recorder/CompactionMetricsRecorder.java} (94%)
