You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2022/11/07 08:58:31 UTC
[iotdb] branch beyyes/confignode_ratis_addNewNodeToExistedGroup updated (b97438bd6a -> e83e674c42)
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/confignode_ratis_addNewNodeToExistedGroup
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b97438bd6a Merge branch 'master' into beyyes/confignode_ratis_addNewNodeToExistedGroup
add c9fc459c59 Merge branch 'master' into beyyes/confignode_ratis_addNewNodeToExistedGroup
add 3127fdd6be merge master
add c034d4cbce [IOTDB-4142] Add delete generated file logic in pom of antlr (#7820)
add 1b1d9bffad Unify thread number configurations to thread_count && Fix clusterIT NPE (#7817)
add 773c963a15 [IOTDB-4806] Add size limit of UDF jar when create UDF on ConfigNode
add b023bb390c [IOTDB-4744] Fix schema register validation bug (#7816)
add a12f66885e fix ConfigNodeSnapshotIT
add 0460a054a1 fix client bug during deactivate template (#7833)
add 07bdbddf16 [IOTDB-4810] Fix print-tsfile-sketch.bat bug when reading measurementID containing Chinese (#7831)
add 952ffcf87d [IOTDB-4527] [IOTDB-4748] Make IoTDB-SQL syntax more flexible (#7806)
add 6e089fb200 Add docs for udf accuracy (#7824)
add b8a20c4078 Change log level of some messages from INFO to DEBUG (#7834)
add 521f9b5f8e [IOTDB-4738]TsFile damaged after writing empty value pages (#7827)
add 60133208c7 Bump actions/first-interaction from 1.1.0 to 1.1.1 (#7836)
add bc0e88b878 [IOTDB-4695] GROUP LEVEL query de-duplicates result columns unexpected (#7736)
add 6485242274 fix doc typo (#7850)
add cfe0fcfa07 Transfer IoTDBQueryWithRecreatedTimeseriesIT (#7851)
add 36c32c7347 Modify default path of iotdb metric reporter (#7819)
add 954a33f9e1 Rename StandAloneConsensus to OneCopyConsensus (#7832)
add 27c0d99eb2 Bump jetty.version from 9.4.48.v20220622 to 9.4.49.v20220914 (#7837)
add 3ee59e33cb Bump reactor-netty-http from 1.0.4 to 1.0.24 (#7838)
add 426d9344a1 remove (#7856)
add 4efeabeb21 [IOTDB-4791] Optimize the endFile in `TsFileIOWriter` (#7826)
add 3904afce17 [IOTDB-4822]Migrate Query tests to the new IT framework
add 933d51bf04 Fix conflicts in path constructor (#7859)
add d7b2fc48ac Change log level (#7861)
add 520467804c Update IoTDBSessionAlignedInsertIT.java (#7857)
add 3ab613f854 [IOTDB-3149] There is a difference between adding ** path and without a path to list user privileges (#7808)
add 2407a5ae65 [IOTDB-4230] add -p pid, -v version feature into start-server.sh (#7802)
add 267ab13524 Fix isBlocked bug of schema query (#7862)
add 2d9dd5be83 [IOTDB-4814] Using 1C1D as the default mode in integration test (#7855)
add 388c988eb4 [IOTDB-4230]fix start-cli.sh does not support -e (#7866)
add b419918d50 Change log level (#7868)
add 09e256656f Change to Debug level (#7871)
add 6823e6ec57 Add debug level judgement firstly (#7872)
add ff5b62f113 init (#7863)
add b73f8d07a2 Rename iotdb-engine.properties to iotdb-datanode.properties in UTs (#7869)
add dbfacd9c1c [IOTDB-4616] Add conf for ConfigNode OneCopy protocol (#7815)
add 37a0423f24 Hide all SchemaFile options in config file (#7867)
add 78a6b10226 [IOTDB-4801] rewrite UT PipeDataTest & BufferedPipeDataQueueTest
add 71c55e9abd Complete document of Data Write chapter and add ways of loading (#7876)
add 2c1b4e93ce Rename OneCopyConsensus to SimpleConsensus (#7882)
add 695dd65fc7 [IOTDB-3773] [IOTDB-4831] Optimize the rpc call numbers in query processing & make query cost time print more accurate (#7875)
add bc96c312dd Rename and simplify cluster IT actions (#7873)
add 9d0a312585 [IOTDB-4828] Implement TestOnly RPC interface setDataNodeStatus (#7877)
add 5874879e54 [IOTDB-4824] Fix error when insert a null value into a non-existed timeseries (#7884)
add 0c34ee1d9c add: define a constant instead load manager metrics. (#7835)
add 3badb017a9 [IOTDB-4813] Update the doc of metric module and grafana dashboard (#7883)
add 5a448c6e21 [IOTDB-4842] Fix type infer error when insert a large number (#7887)
add ae83e89676 [IOTDB-4616] Support snapshot serialization and deserialization for confignode standalone mode (#7874)
add 617fd5ad99 Upgrade github action version (#7890)
add 9663127db1 [IOTDB-4821]Move settleIT (#7853)
add f857667c9d [IOTDB-4597] add option to set query timeout in Cli
add a9858c9e2c Disable compiling library-udf by default when package distribution (#7896)
add 876564ddc1 [IOTDB-4778][IOTDB-4031][IOTDB-4764][IOTDB-4514] restServer module adaptation and optimization (#7897)
add 31f8eeec26 Bump caffeine from 2.9.1 to 2.9.3 (#7615)
add 1dd2e47c59 [IOTDB-4827][IOTDB-4840] Adaptation and fix mlog logic for for cluster template (#7885)
add b0f68c5801 [IOTDB-4800] [Rewrite UT] Rewrite some UT in compaction module
add 2c8f898988 [IOTDB-4826] Move some IT to integration-test (#7891)
add 37a40629c5 Fix shell scripts in tools and change -b to -d (#7905)
add 62edbd431a [IOTDB-4769] When modifying an alias, you need to add back quotes when the alias is a special character. (#7745)
add 2ef642275c Adjusted location of trigger section, added an example of REST API (#7906)
add 8d0c685b07 Improve query performance (#7894)
add b135ebdeca [IOTDB-4848] fix Bug: TimeSeries cannot be used in logical operator
add 5dd8d88103 Bump reload4j from 1.2.19 to 1.2.22 (#7892)
add f58cc6c223 Add a function quantile in UDF library (#7912)
add abbb45b891 Adjust configuration files (#7909)
add 96c860f876 [IOTDB-4807] Check nodes' status at the INVALIDATE_CACHE state (#7895)
add 95fa01f4fe Update client-go commit to fix CI
add 523e82a437 Fixed the bugs of shell (#7910)
add b63d8acb49 Merge branch 'master' into beyyes/confignode_ratis_addNewNodeToExistedGroup
add 98e0091bf3 add sleep time when executing addNewNodeToExistedGroup
add e83e674c42 Merge branch 'beyyes/confignode_ratis_addNewNodeToExistedGroup' of github.com:apache/iotdb into beyyes/confignode_ratis_addNewNodeToExistedGroup
No new revisions were added by this update.
Summary of changes:
.github/dependabot.yml | 52 -
.github/workflows/client-cpp.yml | 14 +-
.github/workflows/client-go.yml | 7 +-
.github/workflows/client-python.yml | 7 +-
.../{cluster-it.yml => cluster-it-1c1d.yml} | 22 +-
.../{cluster-it.yml => cluster-it-1c3d.yml} | 13 +-
.github/workflows/e2e.yml | 4 +-
.github/workflows/grafana-plugin.yml | 12 +-
.github/workflows/greetings.yml | 2 +-
.github/workflows/influxdb-protocol.yml | 7 +-
.github/workflows/main-unix.yml | 14 +-
.github/workflows/main-win.yml | 11 +-
.github/workflows/sonar-coveralls.yml | 33 +-
.github/workflows/standalone-it-for-mpp.yml | 79 --
.github/workflows/sync.yml | 7 +-
README.md | 3 +-
README_ZH.md | 3 +-
antlr/pom.xml | 17 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 43 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../src/assembly/resources/conf/logback-cli.xml | 20 +-
cli/src/assembly/resources/sbin/start-cli.sh | 118 +-
cli/src/assembly/resources/tools/export-csv.sh | 7 +
cli/src/assembly/resources/tools/export-tsfile.sh | 7 +
cli/src/assembly/resources/tools/import-csv.sh | 7 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 21 +
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 5 +
client-go | 2 +-
confignode/src/assembly/confignode.xml | 4 +
.../src/assembly/resources/conf/confignode-env.bat | 27 +-
.../src/assembly/resources/conf/confignode-env.sh | 10 +
.../resources/conf/iotdb-confignode.properties | 41 +-
.../src/assembly/resources/conf/logback-tool.xml | 16 +-
.../assembly/resources/sbin/remove-confignode.sh | 59 +-
.../assembly/resources/sbin/start-confignode.bat | 41 +-
.../assembly/resources/sbin/start-confignode.sh | 169 ++-
.../assembly/resources/sbin/stop-confignode.bat | 3 +
.../src/assembly/resources/sbin/stop-confignode.sh | 4 +-
.../client/async/AsyncDataNodeClientPool.java | 3 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 180 +--
.../iotdb/confignode/conf/ConfigNodeConstant.java | 6 +
.../confignode/conf/ConfigNodeDescriptor.java | 178 +--
.../confignode/conf/ConfigNodeStartupCheck.java | 22 +-
.../consensus/request/ConfigPhysicalPlan.java | 7 +
.../write/procedure/UpdateProcedurePlan.java | 8 -
.../consensus/response/TemplateSetInfoResp.java | 1 +
.../statemachine/PartitionRegionStateMachine.java | 129 ++-
.../iotdb/confignode/manager/ConfigManager.java | 9 +
.../iotdb/confignode/manager/ConsensusManager.java | 43 +-
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 10 +-
.../iotdb/confignode/manager/UDFManager.java | 34 +-
.../manager/load/LoadManagerMetrics.java | 10 +-
.../manager/load/balancer/RouteBalancer.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 15 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 6 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 62 +-
.../procedure/env/DataNodeRemoveHandler.java | 10 +-
.../impl/statemachine/RegionMigrateProcedure.java | 2 +-
.../procedure/store/ConfigProcedureStore.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 10 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 7 +
.../confignode/persistence/AuthorInfoTest.java | 36 +-
...nfignode.properties => iotdb-common.properties} | 14 +-
...otdb-metric.yml => iotdb-confignode-metric.yml} | 4 +-
.../confignode1conf/iotdb-confignode.properties | 13 +-
...nfignode.properties => iotdb-common.properties} | 13 +-
...otdb-metric.yml => iotdb-confignode-metric.yml} | 4 +-
.../confignode2conf/iotdb-confignode.properties | 12 +-
...nfignode.properties => iotdb-common.properties} | 13 +-
...otdb-metric.yml => iotdb-confignode-metric.yml} | 4 +-
.../confignode3conf/iotdb-confignode.properties | 12 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 7 +-
.../multileader/MultiLeaderServerImpl.java | 10 +
.../multileader/client/DispatchLogHandler.java | 2 +
.../multileader/logdispatcher/LogDispatcher.java | 2 +
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +
.../SimpleConsensus.java} | 24 +-
.../SimpleServerImpl.java} | 6 +-
.../multileader/MultiLeaderConsensusTest.java | 4 +-
.../iotdb/consensus/multileader/RecoveryTest.java | 4 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 +-
.../{standalone => simple}/RecoveryTest.java | 6 +-
.../SimpleConsensusTest.java} | 8 +-
.../tests/tools/tsfile/ExportTsFileTestIT.java | 6 +-
.../src/test/resources/iotdb-datanode.properties | 29 +-
.../src/test/resources/iotdb-engine.properties | 21 -
distribution/src/assembly/all.xml | 5 +
distribution/src/assembly/confignode.xml | 5 +
distribution/src/assembly/datanode.xml | 5 +
docker/src/main/Dockerfile-1c1d | 14 +-
docker/src/main/Dockerfile-1c1d-influxdb | 16 +-
docs/UserGuide/Alert/Alerting.md | 2 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 154 ++-
docs/UserGuide/{Alert => Process-Data}/Triggers.md | 10 +-
.../Process-Data/UDF-User-Defined-Function.md | 14 +-
docs/UserGuide/QuickStart/QuickStart.md | 31 +-
.../Reference/ConfigNode-Config-Manual.md | 24 +-
docs/UserGuide/Reference/Keywords.md | 2 +
docs/UserGuide/UDF-Library/Data-Profiling.md | 73 ++
docs/UserGuide/UDF-Library/Data-Quality.md | 57 +-
docs/UserGuide/UDF-Library/M4.md | 2 +-
.../UserGuide/Write-Data/MQTT.md | 10 +-
.../{UDF-Library/M4.md => Write-Data/REST-API.md} | 37 +-
.../{UDF-Library/M4.md => Write-Data/Session.md} | 16 +-
docs/zh/UserGuide/Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 190 +--
.../UserGuide/{Alert => Process-Data}/Triggers.md | 6 +-
.../Process-Data/UDF-User-Defined-Function.md | 12 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 20 +-
.../Reference/ConfigNode-Config-Manual.md | 16 +-
docs/zh/UserGuide/Reference/Keywords.md | 2 +
docs/zh/UserGuide/UDF-Library/Data-Profiling.md | 74 ++
docs/zh/UserGuide/UDF-Library/Data-Quality.md | 57 +-
.../zh/UserGuide/Write-Data/MQTT.md | 10 +-
.../M4.md => zh/UserGuide/Write-Data/REST-API.md} | 38 +-
.../M4.md => zh/UserGuide/Write-Data/Session.md} | 16 +-
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 11 +-
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 234 +---
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 119 +-
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 2 +-
integration-test/README.md | 61 +-
integration-test/import-control.xml | 4 +
integration-test/pom.xml | 23 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 14 +
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 8 +-
.../org/apache/iotdb/it/env/ConfigFactory.java | 41 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 8 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 3 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 20 +-
...StandaloneDataNodeWrapper.java => EnvType.java} | 16 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 6 +-
.../{StandaloneOnMppEnv.java => SimpleEnv.java} | 22 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 8 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 53 +
.../confignode/it/IoTDBClusterAuthorityIT.java | 38 +-
.../iotdb/confignode/it/IoTDBClusterNodeIT.java | 2 +-
.../confignode/it/IoTDBClusterPartitionIT.java | 6 +-
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 4 +-
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 4 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 6 +-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 3 +-
.../apache/iotdb/db/it}/IoTDBDatetimeFormatIT.java | 31 +-
.../org/apache/iotdb/db/it}/IoTDBEncodingIT.java | 131 +--
.../apache/iotdb/db/it}/IoTDBExecuteBatchIT.java | 21 +-
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 62 +-
.../apache/iotdb/db/it}/IoTDBFloatPrecisionIT.java | 43 +-
.../apache/iotdb/db/it/IoTDBFlushQueryMergeIT.java | 12 +-
.../apache/iotdb/db/it}/IoTDBInsertMultiRowIT.java | 33 +-
.../org/apache/iotdb/db/it}/IoTDBInsertNaNIT.java | 45 +-
.../org/apache/iotdb/db/it}/IoTDBInsertNullIT.java | 42 +-
.../iotdb/db/it}/IoTDBInsertWithQueryIT.java | 31 +-
.../iotdb/db/it}/IoTDBPartialInsertionIT.java | 41 +-
.../it}/IoTDBQueryWithRecreatedTimeseriesIT.java | 21 +-
.../org/apache/iotdb/db/it}/IoTDBRecoverIT.java | 141 +--
.../iotdb/db/it}/IoTDBRecoverUnclosedIT.java | 125 +-
.../org/apache/iotdb/db/it}/IoTDBRestartIT.java | 221 ++--
.../org/apache/iotdb/db/it}/IoTDBSettleIT.java | 25 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 4 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 19 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 11 +
.../iotdb/db/it/env/StandaloneEnvConfig.java | 8 +-
.../iotdb/db/it/query}/IoTDBArithmeticIT.java | 151 +--
.../iotdb/db/it/query}/IoTDBFuzzyQueryIT.java | 159 ++-
.../org/apache/iotdb/db/it/query}/IoTDBInIT.java | 39 +-
.../iotdb/db/it/query}/IoTDBQueryDemoIT.java | 627 +++++-----
.../it/query}/IoTDBSelectCompareExpressionIT.java | 13 +-
.../iotdb/db/it/query}/IoTDBSelectSchemaIT.java | 13 +-
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 19 +
.../session/it/IoTDBSessionAlignedInsertIT.java | 95 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 46 +-
.../src/test/resources/iotdb-datanode.properties | 30 +-
.../src/test/resources/iotdb-engine.properties | 21 -
.../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 99 --
.../db/integration/IoTDBLoadExternalTsfileIT.java | 5 +-
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 3 +-
.../integration/IoTDBManageTsFileResourceIT.java | 291 -----
.../integration/IoTDBSizeTieredCompactionIT.java | 12 +-
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 5 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 6 +-
.../session/IoTDBSessionAlignedAggregationIT.java | 6 +-
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 6 +-
.../src/test/resources/iotdb-datanode.properties | 30 +-
.../src/test/resources/iotdb-engine.properties | 21 -
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 72 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 12 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 5 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 127 +-
library-udf/pom.xml | 115 +-
library-udf/src/assembly/tools/register-UDF.bat | 1 +
library-udf/src/assembly/tools/register-UDF.sh | 1 +
.../iotdb/library/dprofile/UDAFQuantile.java | 127 ++
.../library/dprofile/util/HeapLongKLLSketch.java | 356 ++++++
.../dprofile/util/KLLSketchForQuantile.java | 172 +++
metrics/dropwizard-metrics/pom.xml | 2 +-
.../resources/conf/iotdb-confignode-metric.yml | 2 +-
.../resources/conf/iotdb-datanode-metric.yml | 2 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 16 +-
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 5 +-
.../iotdb/metrics/config/MetricConfigTest.java | 2 +-
.../interface/src/test/resources/iotdb-metric.yml | 2 +-
metrics/micrometer-metrics/pom.xml | 2 +-
.../resources/conf/iotdb-common.properties | 1212 +++++++++-----------
.../src/assembly/resources/sbin/iotdb-common.sh | 211 ++++
.../apache/iotdb/commons/conf/CommonConfig.java | 2 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 9 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 2 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 17 -
pom.xml | 9 +-
server/logtest.test | Bin 75 -> 0 bytes
.../src/assembly/resources/conf/datanode-env.bat | 25 +-
server/src/assembly/resources/conf/datanode-env.sh | 10 +
.../resources/conf/iotdb-datanode.properties | 49 +-
.../src/assembly/resources/conf/logback-tool.xml | 16 +-
.../src/assembly/resources/sbin/remove-datanode.sh | 45 +-
.../src/assembly/resources/sbin/start-datanode.bat | 42 +-
.../src/assembly/resources/sbin/start-datanode.sh | 194 +++-
.../assembly/resources/sbin/start-new-server.bat | 55 +-
.../assembly/resources/sbin/start-new-server.sh | 182 ++-
.../src/assembly/resources/sbin/start-server.bat | 126 --
server/src/assembly/resources/sbin/start-server.sh | 151 ---
.../src/assembly/resources/sbin/stop-datanode.bat | 3 +
.../src/assembly/resources/sbin/stop-datanode.sh | 6 +-
server/src/assembly/resources/sbin/stop-server.bat | 38 -
server/src/assembly/resources/sbin/stop-server.sh | 74 --
.../assembly/resources/tools/detect-watermark.sh | 9 +-
.../assembly/resources/tools/rocksdb-transfer.bat | 2 +-
.../assembly/resources/tools/rocksdb-transfer.sh | 2 +-
.../resources/tools/schema/SchemaFileSketcher.sh | 9 +-
.../assembly/resources/tools/schema/mLogParser.sh | 9 +-
.../assembly/resources/tools/start-WalChecker.bat | 2 +-
.../assembly/resources/tools/start-WalChecker.sh | 11 +-
.../tools/tsfileToolSet/print-iotdb-data-dir.sh | 10 +-
.../tsfileToolSet/print-tsfile-resource-files.sh | 11 +-
.../tools/tsfileToolSet/print-tsfile-sketch.bat | 7 +-
.../tools/tsfileToolSet/print-tsfile-sketch.sh | 10 +-
.../tools/tsfileToolSet/print-tsfile-visdata.sh | 9 +-
.../resources/tools/tsfileToolSet/settle.sh | 9 +-
.../tools/tsfileToolSet/split-tsfile-tool.sh | 9 +-
.../tools/tsfileToolSet/validate-tsfile.sh | 9 +-
server/src/assembly/server.xml | 17 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 6 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 159 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 136 +--
.../db/consensus/DataRegionConsensusImpl.java | 2 +-
.../statemachine/SchemaRegionStateMachine.java | 2 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 4 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 5 +-
.../engine/compaction/CompactionTaskManager.java | 10 +-
.../RewriteCrossSpaceCompactionSelector.java | 4 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 7 +-
.../impl/ReadChunkCompactionPerformer.java | 2 +-
.../writer/CrossSpaceCompactionWriter.java | 2 +-
.../writer/InnerSpaceCompactionWriter.java | 2 +-
.../db/engine/flush/pool/FlushTaskPoolManager.java | 4 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 4 +-
.../db/engine/storagegroup/TsFileResource.java | 9 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 11 +
.../storagegroup/timeindex/FileTimeIndex.java | 5 +
.../engine/storagegroup/timeindex/ITimeIndex.java | 5 +
.../storagegroup/timeindex/V012FileTimeIndex.java | 6 +
.../iotdb/db/localconfignode/LocalConfigNode.java | 6 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 7 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 185 ++-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 9 +-
.../mtree/store/disk/schemafile/RecordUtils.java | 27 +-
.../impl/DeactivateTemplatePlanImpl.java | 6 +
.../impl/PreDeactivateTemplatePlanImpl.java | 6 +
.../RollbackPreDeactivateTemplatePlanImpl.java | 6 +
.../schemaregion/impl/SchemaRegionPlanFactory.java | 18 +
.../db/metadata/schemaregion/SchemaEngine.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 26 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 131 ++-
.../metadata/template/ClusterTemplateManager.java | 17 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 14 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 12 +-
.../execution/exchange/MPPDataExchangeManager.java | 28 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 2 +-
.../db/mpp/execution/exchange/SinkHandle.java | 16 +-
.../db/mpp/execution/exchange/SourceHandle.java | 16 +-
.../execution/executor/RegionWriteExecutor.java | 24 +-
.../fragment/FragmentInstanceExecution.java | 2 +-
.../fragment/FragmentInstanceStateMachine.java | 14 +-
.../operator/schema/CountMergeOperator.java | 65 +-
.../operator/schema/NodePathsCountOperator.java | 35 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 133 ++-
.../db/mpp/execution/schedule/DriverScheduler.java | 2 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 25 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 51 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 39 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 2 +
.../db/mpp/plan/execution/IQueryExecution.java | 4 +
.../db/mpp/plan/execution/QueryExecution.java | 33 +-
.../mpp/plan/execution/config/ConfigExecution.java | 10 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 49 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 4 +-
.../planner/plan/node/write/InsertRowNode.java | 3 +-
.../planner/plan/node/write/InsertTabletNode.java | 3 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 8 +-
.../scheduler/FixedRateFragInsStateTracker.java | 46 +-
.../plan/scheduler/IFragInstanceStateTracker.java | 6 +
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 30 +-
.../protocol/rest/filter/AuthorizationFilter.java | 7 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 10 +-
.../rest/handler/ExecuteStatementHandler.java | 52 +
.../protocol/rest/handler/QueryDataSetHandler.java | 37 +-
.../rest/handler/StatementConstructionHandler.java | 3 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 22 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 8 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 45 +-
.../iotdb/db/query/pool/QueryTaskManager.java | 4 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 19 +-
.../GetVersion.java} | 11 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 10 +
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 9 +
.../org/apache/iotdb/db/service/UpgradeSevice.java | 2 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 118 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 8 +-
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 5 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 3 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 3 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 3 -
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 12 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 6 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 5 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 8 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 2 +-
.../engine/compaction/AbstractCompactionTest.java | 48 +-
.../engine/compaction/CompactionSchedulerTest.java | 283 +----
.../ReadPointCompactionPerformerTest.java | 5 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 3 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 20 +-
.../cross/CrossSpaceCompactionValidationTest.java | 3 +-
.../cross/RewriteCompactionFileSelectorTest.java | 14 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 3 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 16 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 1 +
.../inner/InnerCompactionMoreDataTest.java | 63 +-
.../inner/InnerCompactionSchedulerTest.java | 13 +-
.../compaction/inner/InnerCompactionTest.java | 20 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 18 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 2 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 8 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 3 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 3 +-
.../compaction/utils/CompactionCheckerUtils.java | 9 +-
.../compaction/utils/CompactionConfigRestorer.java | 2 +-
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 10 +
.../schemaRegion/SchemaRegionBasicTest.java | 154 +++
.../schemaRegion/SchemaRegionSnapshotTest.java | 2 +-
.../operator/schema/CountMergeOperatorTest.java | 4 +-
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 2 +-
.../iotdb/db/qp/physical/ConcatOptimizerTest.java | 10 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 56 +-
.../org/apache/iotdb/db/service/DaemonTest.java | 23 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 17 +-
.../iotdb/db/sync/pipedata/PipeDataTest.java | 11 -
.../iotdb/db/utils/TsFileRewriteToolTest.java | 4 +-
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 2 +
.../db/wal/recover/WALRecoverManagerTest.java | 16 +-
.../file/SealedTsFileRecoverPerformerTest.java | 32 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 16 +-
...datanode.properties => iotdb-common.properties} | 22 +-
...{iotdb-metric.yml => iotdb-datanode-metric.yml} | 2 +-
.../datanode1conf/iotdb-datanode.properties | 7 +-
.../resources/datanode1conf/iotdb-rest.properties | 45 +-
...datanode.properties => iotdb-common.properties} | 22 +-
...{iotdb-metric.yml => iotdb-datanode-metric.yml} | 2 +-
.../datanode2conf/iotdb-datanode.properties | 7 +-
.../resources/datanode2conf/iotdb-rest.properties | 43 -
.../datanode3conf/iotdb-common.properties} | 30 +-
...{iotdb-metric.yml => iotdb-datanode-metric.yml} | 2 +-
.../datanode3conf/iotdb-datanode.properties | 9 +-
.../resources/datanode3conf/iotdb-rest.properties | 45 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 30 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../apache/iotdb/session/SessionConnection.java | 9 +-
.../org/apache/iotdb/session/SessionDataSet.java | 10 +-
.../src/test/resources/iotdb-datanode.properties | 29 +-
session/src/test/resources/iotdb-engine.properties | 20 -
site/src/main/.vuepress/config.js | 18 +-
.../src/test/resources/iotdb-datanode.properties | 29 +-
.../src/test/resources/iotdb-engine.properties | 21 -
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 10 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 181 ++-
.../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 30 +-
.../src/main/thrift/confignode.thrift | 8 +
thrift/src/main/thrift/client.thrift | 2 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 12 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 9 +-
.../read/controller/MetadataQuerierByFileImpl.java | 3 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 4 +-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 6 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 4 +
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 1 +
.../tsfile/write/chunk/IChunkGroupWriter.java | 4 +-
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 1 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 12 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 26 +-
.../write/writer/tsmiterator/DiskTSMIterator.java | 7 +-
.../write/writer/tsmiterator/TSMIterator.java | 9 +-
...easurementChunkMetadataListMapIteratorTest.java | 2 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 22 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 54 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 55 +-
.../tsfile/read/TimeSeriesMetadataReadTest.java | 4 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 126 +-
.../tsfile/read/controller/ChunkLoaderTest.java | 2 +-
.../controller/IMetadataQuerierByFileImplTest.java | 16 +-
.../read/filter/IExpressionOptimizerTest.java | 30 +-
.../read/query/executor/QueryExecutorTest.java | 32 +-
.../read/query/timegenerator/ReadWriteTest.java | 8 +-
.../query/timegenerator/ReaderByTimestampTest.java | 2 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 8 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 8 +-
.../query/timegenerator/TimeGeneratorTest.java | 6 +-
.../iotdb/tsfile/read/reader/ChunkReaderTest.java | 2 +-
.../tsfile/read/reader/FakedTimeGenerator.java | 9 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 8 +-
.../tsfile/write/DefaultSchemaTemplateTest.java | 2 +-
.../tsfile/write/MetadataIndexConstructorTest.java | 6 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 4 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 4 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 264 +++++
.../iotdb/tsfile/write/TsFileWriterTest.java | 10 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 2 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 4 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 36 +-
.../writer/TsFileIOWriterMemoryControlTest.java | 11 +-
432 files changed, 7632 insertions(+), 6634 deletions(-)
copy .github/workflows/{cluster-it.yml => cluster-it-1c1d.yml} (84%)
rename .github/workflows/{cluster-it.yml => cluster-it-1c3d.yml} (92%)
delete mode 100644 .github/workflows/standalone-it-for-mpp.yml
copy server/src/assembly/resources/conf/logback-tool.xml => cli/src/assembly/resources/conf/logback-cli.xml (62%)
mode change 100644 => 100755 cli/src/assembly/resources/sbin/start-cli.sh
mode change 100644 => 100755 confignode/src/assembly/resources/sbin/remove-confignode.sh
copy confignode/src/test/resources/confignode1conf/{iotdb-confignode.properties => iotdb-common.properties} (73%)
rename confignode/src/test/resources/confignode1conf/{iotdb-metric.yml => iotdb-confignode-metric.yml} (97%)
copy confignode/src/test/resources/confignode2conf/{iotdb-confignode.properties => iotdb-common.properties} (73%)
rename confignode/src/test/resources/confignode2conf/{iotdb-metric.yml => iotdb-confignode-metric.yml} (97%)
copy confignode/src/test/resources/confignode3conf/{iotdb-confignode.properties => iotdb-common.properties} (73%)
rename confignode/src/test/resources/confignode3conf/{iotdb-metric.yml => iotdb-confignode-metric.yml} (97%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{standalone/StandAloneConsensus.java => simple/SimpleConsensus.java} (91%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{standalone/StandAloneServerImpl.java => simple/SimpleServerImpl.java} (92%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{standalone => simple}/RecoveryTest.java (95%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{standalone/StandAloneConsensusTest.java => simple/SimpleConsensusTest.java} (98%)
copy server/src/assembly/resources/tools/detect-watermark.sh => cross-tests/src/test/resources/iotdb-datanode.properties (57%)
delete mode 100644 cross-tests/src/test/resources/iotdb-engine.properties
rename docs/UserGuide/{Alert => Process-Data}/Triggers.md (98%)
copy confignode/src/assembly/resources/conf/logback-tool.xml => docs/UserGuide/Write-Data/MQTT.md (88%)
copy docs/UserGuide/{UDF-Library/M4.md => Write-Data/REST-API.md} (52%)
copy docs/UserGuide/{UDF-Library/M4.md => Write-Data/Session.md} (50%)
rename docs/zh/UserGuide/{Alert => Process-Data}/Triggers.md (98%)
copy confignode/src/assembly/resources/conf/logback-tool.xml => docs/zh/UserGuide/Write-Data/MQTT.md (89%)
copy docs/{UserGuide/UDF-Library/M4.md => zh/UserGuide/Write-Data/REST-API.md} (51%)
copy docs/{UserGuide/UDF-Library/M4.md => zh/UserGuide/Write-Data/Session.md} (52%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/{StandaloneDataNodeWrapper.java => EnvType.java} (69%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{StandaloneOnMppEnv.java => SimpleEnv.java} (67%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBDatetimeFormatIT.java (81%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBEncodingIT.java (76%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBExecuteBatchIT.java (92%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBFloatPrecisionIT.java (86%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBInsertMultiRowIT.java (84%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBInsertNaNIT.java (85%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBInsertNullIT.java (85%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBInsertWithQueryIT.java (93%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBPartialInsertionIT.java (77%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBQueryWithRecreatedTimeseriesIT.java (84%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBRecoverIT.java (75%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBRecoverUnclosedIT.java (71%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBRestartIT.java (57%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it}/IoTDBSettleIT.java (81%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it/query}/IoTDBArithmeticIT.java (60%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it/query}/IoTDBFuzzyQueryIT.java (66%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it/query}/IoTDBInIT.java (90%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it/query}/IoTDBQueryDemoIT.java (51%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it/query}/IoTDBSelectCompareExpressionIT.java (98%)
rename {integration/src/test/java/org/apache/iotdb/db/integration => integration-test/src/test/java/org/apache/iotdb/db/it/query}/IoTDBSelectSchemaIT.java (92%)
copy server/src/assembly/resources/tools/detect-watermark.sh => integration-test/src/test/resources/iotdb-datanode.properties (57%)
delete mode 100644 integration-test/src/test/resources/iotdb-engine.properties
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBFilePathUtilsIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBManageTsFileResourceIT.java
copy server/src/assembly/resources/tools/detect-watermark.sh => integration/src/test/resources/iotdb-datanode.properties (57%)
delete mode 100644 integration/src/test/resources/iotdb-engine.properties
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFQuantile.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/HeapLongKLLSketch.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/KLLSketchForQuantile.java
create mode 100755 node-commons/src/assembly/resources/sbin/iotdb-common.sh
delete mode 100644 server/logtest.test
delete mode 100755 server/src/assembly/resources/sbin/start-server.bat
delete mode 100755 server/src/assembly/resources/sbin/start-server.sh
delete mode 100755 server/src/assembly/resources/sbin/stop-server.bat
delete mode 100755 server/src/assembly/resources/sbin/stop-server.sh
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/handler/ExecuteStatementHandler.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/plan/scheduler/IFragInstanceStateTracker.java => service/GetVersion.java} (76%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/StandaloneDataNodeWrapper.java => server/src/test/java/org/apache/iotdb/db/service/DaemonTest.java (65%)
copy server/src/test/resources/datanode1conf/{iotdb-datanode.properties => iotdb-common.properties} (59%)
rename server/src/test/resources/datanode1conf/{iotdb-metric.yml => iotdb-datanode-metric.yml} (98%)
copy server/src/test/resources/datanode2conf/{iotdb-datanode.properties => iotdb-common.properties} (59%)
rename server/src/test/resources/datanode2conf/{iotdb-metric.yml => iotdb-datanode-metric.yml} (98%)
copy server/src/{assembly/resources/tools/detect-watermark.sh => test/resources/datanode3conf/iotdb-common.properties} (57%)
rename server/src/test/resources/datanode3conf/{iotdb-metric.yml => iotdb-datanode-metric.yml} (98%)
copy server/src/assembly/resources/tools/detect-watermark.sh => session/src/test/resources/iotdb-datanode.properties (57%)
delete mode 100644 session/src/test/resources/iotdb-engine.properties
copy server/src/assembly/resources/tools/detect-watermark.sh => spark-iotdb-connector/src/test/resources/iotdb-datanode.properties (57%)
delete mode 100644 spark-iotdb-connector/src/test/resources/iotdb-engine.properties