You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2023/01/30 07:16:33 UTC
[iotdb] branch lmh/querySession updated (9db4b7e967 -> ae509ca6c3)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/querySession
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9db4b7e967 fix test
add 5f914f014e [IOTDB-3662] upgrade audit log (#8791)
add 362f56cdf5 Change version to 1.1.0-SNAPSHOT (#8796)
add 5de6adf3de [IOTDB-5386] Implement SchemaSource Component to Simplify Schema Operators (#8792)
add c1dde58682 Jenkins disable integration (#8787)
add c085fb1a8c [IOTDB-4005] Pipeline fragmentInstance to implement parallel execution
add 27549169a3 [IOTDB-5384] add core_client_count_for_each_node_in_client_manager and max_client_count_for_each_node_in_client_manager parameters for confignode and datanode （#8800）
add a1cc705fdd [IOTDB-5387] Refine IT: Make JVM parameters mutable easily (#8795)
add 7b1977330a [IOTDB-5328] Rename "REMOVE_DATANODE_PROCESS" in MIGRATE_REGION_PROCEDURE to "REGION_MIGRATE_PROCESS" (#8790)
add 76d3a13e29 Eliminate LocalSchemaProcessor and stale code (#8802)
add 4dcaf696d5 Eliminate LocalConfigNode and Fix NPE while forceMLog (#8804)
add dfb013b710 Separate SYNC_CONNECTION_ERROR and DISPATCH_ERROR (#8726)
add 8e40479c42 [IOTDB-5288][IOTDB-5163] Fix the file metrics is wrong (#8805)
add 5ad3384f0f Change config in SourceHandleTest according to IoTDBDescriptor
add 44fb69a7ff Fix wal manager test (#8808)
add 5dac205243 [IOTDB-4437] Implement event window in RawDataAggregationOperator
add 43cd37bdcf [IOTDB-5389] Cause DataNode startup to fail when wal_mode is disabled in IoTConsensus (#8798)
add 3ddaa39983 [IOTDB-5391] Implement SchemaReader using iterative Traverser (#8816)
add 4f1409df4d Fix testGetSlots bug (#8819)
add ee93ad4145 [IOTDB-4960]SchemaFile implements separate FileChannel for read/write operation (#8813)
add 8224a70a41 [IOTDB-5398] Handle failure in schema query if there is exception occurs during the iteration (#8830)
add 309206e504 [IOTDB-5392] accelerate pointPriorityReader in fast compaction
add 3c01a93437 [IOTDB-5401] Reduce the estimated size of memory retained after calling next in SeriesAggregationScanOperator
add b93dbfa5e6 [IOTDB-5369] Add query related panels in Grafana Dashboard (#8764)
add 4ee81d4d68 [IOTDB-5345] Use the logical clock to identify the snapshot version of IoTConsensus (#8807)
add a009560f26 [IOTDB-5390] Keep mqtt_host same with rpc_address (#8831)
add 2122ae3353 [IOTDB-5404] Fix concurrency problem of metricSets in AbstractMetricService (#8841)
add 4a73e612d3 Fix mqtt docs (#8845)
add df26f54db3 [IOTDB-5403] Refine IT: Add ensureNodeStatus to test status after starting or stopping (#8844)
add ed75dfcc81 finish (#8837)
add 0e5e53ad97 [IOTDB-5370] Implement MultilevelPriorityQueue for query schedule
add 3299f1310e Update the user guide of Flink-IoTDB sink (#8848)
add 9d5d78285d [IOTDB-4674] Reimplement settle by compaction (#8644)
add a7f910ffc4 Finish (#8847)
add 0308ab6cab [IOTDB-5404] Optimize concurrency problem of metricSets in AbstractMetricService (#8855)
add d970dc6a98 [IOTDB-5414] Timeseries with alias deleted success but can still be queried by alias (#8865)
add 8383c48012 [IOTDB-5324] Fix wal cann't be deleted in destDataNode after region migration when data_replication_factor is 1 in IoTConsensus (#8836)
add db335faecc Fix jenkins sonar report error (#8868)
add 280ea4e034 [IOTDB-5399] Implement batch auto create schema (#8826)
add c32b3f524c Add Metric Doc (#8857)
add a5167ac654 Update Data-Repairing.md (#8852)
add e0d1cc9e08 Add query metrics doc (#8853)
add 2684767547 [IOTDB-5410] Refine IT: Refine Session and SessionPool IT (#8860)
add 993cf647fb fix data partition update error (#8840)
add a387d290f2 [IOTDB-5372] Support data type cast in SELECT INTO
add ac726021a9 [IOTDB-5412]Print Help Message when loading empty tsfile (#8877)
add d82ae63f95 [IOTDB-5396] Iterative interface for query about TagManager (#8878)
add 5ad67dedf0 [IOTDB-5415] Move parameters into correct ConfigClass (#8867)
add 5ee9541dae [IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator
add 974afbadb9 [IOTDB-5424] Fix FI memory allocation limit calculation
add ecc0224195 Update IoTDBConfig.java (#8887)
add 5e2e9d33c7 Fix typo in README
add bcf1b923ab [IOTDB-5382]Support DIFF as built-in scalar function in IoTDB
add 1345d259d1 [IOTDB-5423] Disable reusing same JVM and processing in random order in tests (#8890)
add 7ccc5b0497 Revert "[IOTDB-5415] Move parameters into correct ConfigClass (#8867)" (#8898)
add 7d2a79d779 Add distance-based outlier detection funtion (#8892)
add 93a2d57013 Fix files with unapporved license error after running OpenIdAuthorizerTest (#8900)
add deb848a968 [IOTDB-5429] Disable first election in RatisConsensus UT to avoid inconsistency states (#8896)
add 030302c965 [IOTDB-5287] Added status “Discouraged” to RegionGroup (#8901)
add f241aba4db [IOTDB-5140] Add metrics for compaction deserializing pages or writing chunks (#8879)
add c5e8ec4c1d [IOTDB-5432] Use freemarker to generate eventWindow and eventWindowManager
add ca84f2f904 [IOTDB-5425] Consolidate all ConfigNodeClient to be managed by clientManager (#8891)
add 6629816b25 fix win CI
add 5aaa80a37d [IOTDB-5431] Fix concurrent bug caused by using synchronizedSet() in DriverScheduler
add 1dec87939a Use gitbox thrift url instead of github to avoid download issue in China
add b9f209f69a Add AR function in Operators-Functions/Machine-Learning
add 76a8b7d720 [IOTDB-5338] WAL buffer flush threshold optimaztion (#8832)
add eef5c5c981 [IOTDB-5434] Fix occasional timeout error in CI
add 57974350ec [IOTDB-5435] Add close method for logWriter of ConfigNodeRegionStateMachine (#8917)
add 315d6526fa Use gitbox to accelerate the picture loading (#8918)
add 24b99cb9a3 [IOTDB-5426] Cannot trigger flush for sequence file when timed flush enabled (#8921)
add c130222b48 [IOTDB-5284] Fix some sonar bugs (#8846)
add ae509ca6c3 Merge remote-tracking branch 'origin/master' into lmh/querySession
No new revisions were added by this update.
Summary of changes:
.github/workflows/main-win.yml | 47 +-
.github/workflows/site-build.yml | 2 +-
Jenkinsfile | 66 +-
README.md | 2 +-
antlr/pom.xml | 2 +-
cli/pom.xml | 6 +-
client-cpp/pom.xml | 2 +-
client-py/pom.xml | 2 +-
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 5 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 15 +-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 +
.../confignode/conf/ConfigNodeDescriptor.java | 9 +-
.../statemachine/ConfigNodeRegionStateMachine.java | 1 +
.../confignode/manager/ClusterSchemaManager.java | 107 +-
.../iotdb/confignode/manager/ProcedureManager.java | 13 +-
.../manager/partition/PartitionManager.java | 20 +-
.../manager/partition/RegionGroupStatus.java | 11 +-
.../partition/heartbeat/RegionGroupCache.java | 17 +-
.../procedure/env/DataNodeRemoveHandler.java | 15 +-
.../statemachine/CreateRegionGroupsProcedure.java | 2 +-
.../impl/statemachine/RegionMigrateProcedure.java | 15 +-
.../manager/ClusterSchemaManagerTest.java | 22 +-
.../manager/partition/RegionGroupCacheTest.java | 2 +-
consensus/pom.xml | 5 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 1 +
.../consensus/iot/IoTConsensusServerImpl.java | 102 +-
.../consensus/iot/IoTConsensusServerMetrics.java | 2 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 2 +-
.../service/IoTConsensusRPCServiceProcessor.java | 2 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 32 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 55 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 8 +
distribution/pom.xml | 2 +-
docs/Development/HowtoContributeCode.md | 2 +-
docs/UserGuide/API/Programming-MQTT.md | 6 +-
docs/UserGuide/Data-Concept/Data-Type.md | 25 +-
docs/UserGuide/Data-Concept/Encoding.md | 29 +-
.../UserGuide/Ecosystem-Integration/Flink-IoTDB.md | 3 +-
.../Apache-IoTDB-DataNode-Dashboard.json | 15737 +++++++++++++++----
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 129 +-
.../Operators-Functions/Anomaly-Detection.md | 71 +-
.../Operators-Functions/Data-Repairing.md | 104 +
.../Operators-Functions/Machine-Learning.md | 84 +
.../Operators-Functions/Variation-Trend.md | 63 +
docs/UserGuide/Query-Data/Select-Into.md | 2 +-
docs/UserGuide/Reference/Status-Codes.md | 15 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 6 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 33 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 33 +-
.../UserGuide/Ecosystem-Integration/Flink-IoTDB.md | 8 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 131 +-
.../Operators-Functions/Anomaly-Detection.md | 73 +-
.../Operators-Functions/Data-Repairing.md | 102 +
.../Operators-Functions/Machine-Learning.md | 85 +
docs/zh/UserGuide/Operators-Functions/Overview.md | 5 +
.../Operators-Functions/Variation-Trend.md | 63 +
docs/zh/UserGuide/Query-Data/Select-Into.md | 2 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 249 +-
example/client-cpp-example/pom.xml | 2 +-
example/ext-pipe-plugin-example/pom.xml | 4 +-
example/flink/pom.xml | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSource.java | 5 +-
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 +-
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 63 +-
example/rest-java-example/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 17 +-
example/trigger/pom.xml | 2 +-
example/tsfile/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
external-api/pom.xml | 2 +-
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/pom.xml | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
influxdb-protocol/pom.xml | 6 +-
integration-test/import-control.xml | 2 +-
integration-test/pom.xml | 5 +-
.../apache/iotdb/it/env/cluster/AbstractEnv.java | 99 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 43 +-
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 19 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 9 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 25 +-
.../iotdb/it/env/cluster/MppClusterConfig.java | 15 +
.../apache/iotdb/it/env/cluster/MppJVMConfig.java | 116 +
.../iotdb/it/env/remote/RemoteClusterConfig.java | 12 +
.../iotdb/it/env/remote/RemoteJVMConfig.java | 26 +-
.../iotdb/it/env/remote/RemoteServerEnv.java | 47 +
.../apache/iotdb/itbase/constant/TestConstant.java | 1 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 130 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 2 -
.../org/apache/iotdb/itbase/env/ClusterConfig.java | 30 +-
.../env/{BaseNodeWrapper.java => JVMConfig.java} | 47 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 96 +-
.../it/cluster/IoTDBClusterRestartIT.java | 3 +-
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 28 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 3 +-
...urableIT.java => IoTDBPartitionCreationIT.java} | 606 +-
.../it/partition/IoTDBPartitionDurableIT.java | 97 +-
.../it/partition/IoTDBPartitionGetterIT.java | 94 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 1 +
.../scalar/IoTDBDiffFunction2IT.java | 45 +
.../scalar/IoTDBDiffFunction3IT.java | 45 +
.../scalar/IoTDBDiffFunctionIT.java | 346 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 237 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 13 +
.../apache/iotdb/libudf/it/anomaly/AnomalyIT.java | 66 +
.../apache/iotdb/libudf/it/dlearn/DLearnIT.java | 311 +
.../session/it/IoTDBSessionAlignedInsertIT.java | 2 -
.../iotdb/session/it/IoTDBSessionComplexIT.java | 2 -
.../it/IoTDBSessionDisableMemControlIT.java | 2 -
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 2 -
.../session/it/IoTDBSessionSchemaTemplateIT.java | 2 -
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 -
.../session/it/IoTDBSessionSyntaxConventionIT.java | 2 -
.../org/apache/iotdb/session/it/SessionIT.java | 83 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 230 +-
.../src/test/resources/logback-test.xml | 2 +
integration/pom.xml | 2 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 3 -
isession/pom.xml | 2 +-
jdbc/pom.xml | 6 +-
library-udf/pom.xml | 2 +-
.../apache/iotdb/library/anomaly/UDTFOutlier.java | 99 +
.../org/apache/iotdb/library/dlearn/UDTFAR.java | 131 +
metrics/dropwizard-metrics/pom.xml | 2 +-
metrics/interface/pom.xml | 2 +-
.../iotdb/metrics/AbstractMetricService.java | 9 +-
metrics/micrometer-metrics/pom.xml | 4 +-
metrics/pom.xml | 5 +-
mlnode/pom.xml | 2 +-
node-commons/pom.xml | 6 +-
.../resources/conf/iotdb-common.properties | 2 +-
.../apache/iotdb/commons/client/ClientManager.java | 13 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 -
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 -
.../commons/schema/tree/AbstractTreeVisitor.java | 2 +-
.../commons/udf/builtin/BuiltinScalarFunction.java | 59 +
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 24 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 4 +-
openapi/pom.xml | 2 +-
pom.xml | 11 +-
rewrite-tsfile-tool/pom.xml | 2 +-
.../java/org/apache/iotdb/RewriteTsFileTool.java | 5 +-
schema-engine-rocksdb/pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 62 +-
schema-engine-tag/pom.xml | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 48 +-
server/pom.xml | 6 +-
.../resources/conf/iotdb-datanode.properties | 9 -
.../resources/tools/tsfile/settle-tsfile.bat | 62 +
.../resources/tools/tsfile/settle-tsfile.sh | 32 +-
server/src/main/codegen/config.fmpp | 1 +
.../{config.fmpp => dataModel/CompareType.tdd} | 17 +-
.../src/main/codegen/templates/evEventWindow.ftl | 64 +
.../codegen/templates/evEventWindowManager.ftl | 100 +
server/src/main/codegen/templates/eventWindow.ftl | 79 +
.../main/codegen/templates/eventWindowManager.ftl | 56 +
.../AuditLogOperation.java} | 17 +-
.../AuditLogStorage.java} | 15 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 236 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 34 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 134 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 34 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 6 +
.../org/apache/iotdb/db/constant/SqlConstant.java | 3 +
.../performer/impl/FastCompactionPerformer.java | 23 +-
.../impl/ReadChunkCompactionPerformer.java | 5 +-
.../execute/task/AbstractCompactionTask.java | 4 +-
.../execute/task/CompactionTaskSummary.java | 82 +-
.../execute/task/CrossSpaceCompactionTask.java | 52 +-
.../execute/task/InnerSpaceCompactionTask.java | 45 +-
.../subtask/FastCompactionPerformerSubTask.java | 6 +-
...Summary.java => FastCompactionTaskSummary.java} | 27 +-
.../fast/AlignedSeriesCompactionExecutor.java | 4 +-
.../fast/NonAlignedSeriesCompactionExecutor.java | 4 +-
.../executor/fast/SeriesCompactionExecutor.java | 67 +-
.../fast/element/ChunkMetadataElement.java | 3 +
.../readchunk/AlignedSeriesCompactionExecutor.java | 20 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 18 +-
.../execute/utils/reader/PointPriorityReader.java | 14 +-
.../db/engine/settle/SettleRequestHandler.java | 323 +
.../iotdb/db/localconfignode/LocalConfigNode.java | 294 -
.../db/localconfignode/LocalDataPartitionInfo.java | 111 -
.../localconfignode/LocalDataPartitionTable.java | 127 -
.../localconfignode/LocalSchemaPartitionTable.java | 122 -
.../iotdb/db/metadata/LocalSchemaProcessor.java | 250 -
.../iotdb/db/metadata/mtree/ConfigMTree.java | 21 -
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 4 -
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 230 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 191 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 21 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 5 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 27 +-
.../traverser/TraverserWithLimitOffsetWrapper.java | 10 +
.../schemaregion/result/ShowTimeSeriesResult.java | 10 +-
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 5 +-
.../db/metadata/query/reader/ISchemaReader.java | 16 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 65 +-
.../db/metadata/schemaregion/SchemaEngine.java | 3 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 132 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 148 +-
.../storagegroup/IStorageGroupSchemaManager.java | 53 -
.../storagegroup/StorageGroupSchemaManager.java | 78 -
.../apache/iotdb/db/metadata/tag/TagManager.java | 132 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 61 +
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 8 +-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 4 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 8 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 12 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 12 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 12 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 12 +-
.../db/mpp/aggregation/MaxTimeAccumulator.java | 2 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 2 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 8 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 2 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 2 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 8 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 8 +-
.../common/schematree/DeviceGroupSchemaTree.java | 94 -
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 71 -
.../iotdb/db/mpp/execution/StateMachine.java | 4 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 37 +-
.../db/mpp/execution/driver/DataDriverContext.java | 48 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 34 +-
.../db/mpp/execution/driver/DriverContext.java | 76 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 5 +-
.../db/mpp/execution/driver/SchemaDriver.java | 5 +-
.../mpp/execution/driver/SchemaDriverContext.java | 13 +-
.../exchange/IMPPDataExchangeManager.java | 4 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 27 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 31 +-
.../execution/exchange/MPPDataExchangeManager.java | 219 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 5 +
.../db/mpp/execution/exchange/SinkHandle.java | 8 +-
.../db/mpp/execution/exchange/SourceHandle.java | 16 +-
.../execution/executor/RegionWriteExecutor.java | 137 +
.../fragment/FragmentInstanceContext.java | 127 +-
.../fragment/FragmentInstanceExecution.java | 25 +-
.../fragment/FragmentInstanceManager.java | 37 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 3 +-
.../db/mpp/execution/operator/OperatorContext.java | 32 +-
.../operator/factory/OperatorFactory.java} | 26 +-
.../operator/factory/SourceOperatorFactory.java | 28 +-
.../operator/process/AbstractIntoOperator.java | 47 +-
.../operator/process/DeviceViewIntoOperator.java | 8 +-
.../execution/operator/process/IntoOperator.java | 10 +-
.../process/RawDataAggregationOperator.java | 51 +-
.../process/SingleInputAggregationOperator.java | 12 +-
.../process/SlidingWindowAggregationOperator.java | 11 +
.../operator/process/TagAggregationOperator.java | 2 +-
.../operator/process/join/TimeJoinOperator.java | 1 -
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelMergeOperator.java | 7 +
...tor.java => CountGroupByLevelScanOperator.java} | 79 +-
.../operator/schema/CountMergeOperator.java | 7 +
.../operator/schema/DevicesCountOperator.java | 65 -
.../schema/NodePathsSchemaScanOperator.java | 159 -
.../operator/schema/SchemaCountOperator.java | 36 +-
.../operator/schema/SchemaQueryScanOperator.java | 37 +-
.../operator/schema/TimeSeriesCountOperator.java | 85 -
.../DeviceSchemaSource.java} | 66 +-
.../operator/schema/source/ISchemaSource.java | 50 +
.../operator/schema/source/NodeSchemaSource.java | 81 +
.../PathsUsingTemplateSource.java} | 81 +-
.../schema/source/SchemaSourceFactory.java | 78 +
.../TimeSeriesSchemaSource.java} | 81 +-
.../AbstractSeriesAggregationScanOperator.java | 8 +-
.../operator/source/AlignedSeriesScanUtil.java | 3 +-
.../operator/source/ExchangeOperator.java | 4 +
.../operator/source/SeriesScanOperator.java | 76 +-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../window/{TimeWindow.java => EventWindow.java} | 61 +-
.../operator/window/EventWindowManager.java | 138 +
.../operator/window/EventWindowParameter.java | 61 +
.../db/mpp/execution/operator/window/IWindow.java | 2 +-
.../execution/operator/window/IWindowManager.java | 68 +-
.../mpp/execution/operator/window/TimeWindow.java | 2 +-
.../operator/window/TimeWindowManager.java | 73 +-
.../operator/window/TimeWindowParameter.java} | 14 +-
.../operator/window/WindowManagerFactory.java | 84 +
.../operator/window/WindowParameter.java} | 23 +-
.../execution/operator/window/WindowType.java} | 20 +-
.../execution/schedule/AbstractDriverThread.java | 9 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 175 +-
...eption.java => DriverTaskAbortedException.java} | 8 +-
.../mpp/execution/schedule/DriverTaskThread.java | 20 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../mpp/execution/schedule/ExecutionContext.java | 10 +
.../mpp/execution/schedule/IDriverScheduler.java | 8 +-
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 3 +-
.../execution/schedule/queue/L1PriorityQueue.java | 10 +-
.../execution/schedule/queue/L2PriorityQueue.java | 16 +-
.../queue/multilevelqueue/DriverTaskHandle.java | 92 +
.../multilevelqueue/MultilevelPriorityQueue.java | 290 +
.../schedule/queue/multilevelqueue/Priority.java | 73 +
.../db/mpp/execution/schedule/task/DriverTask.java | 113 +-
.../task/{DriverTaskID.java => DriverTaskId.java} | 49 +-
...tricSet.java => DataExchangeCostMetricSet.java} | 10 +-
.../db/mpp/metric/DataExchangeCountMetricSet.java | 119 +
.../db/mpp/metric/QueryExecutionMetricSet.java | 5 -
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 13 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 12 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 105 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 33 +
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 7 +
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 63 +
.../db/mpp/plan/analyze/cache/PartitionCache.java | 7 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 276 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 10 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 143 +-
.../db/mpp/plan/execution/QueryExecution.java | 7 +-
.../config/executor/ClusterConfigTaskExecutor.java | 81 +-
.../plan/expression/multi/FunctionExpression.java | 13 +-
.../visitor/ColumnTransformerVisitor.java | 23 +
.../visitor/IntermediateLayerVisitor.java | 22 +
.../plan/planner/LocalExecutionPlanContext.java | 175 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 100 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 32 +
.../plan/planner/MemoryDistributionCalculator.java | 472 -
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 413 +-
.../db/mpp/plan/planner/PipelineDriverFactory.java | 59 +
.../plan/planner/distribution/SourceRewriter.java | 14 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 10 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 10 +
.../write/InternalBatchActivateTemplateNode.java | 162 +
.../write/InternalCreateMultiTimeSeriesNode.java | 164 +
.../parameter/DeviceViewIntoPathDescriptor.java | 45 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 27 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 3 +
.../db/mpp/plan/statement/StatementVisitor.java | 12 +
.../InternalBatchActivateTemplateStatement.java | 59 +
.../InternalCreateMultiTimeSeriesStatement.java | 57 +
.../unary/DiffFunctionColumnTransformer.java | 67 +
.../transformer/unary/DiffFunctionTransformer.java | 103 +
.../iotdb/db/query/control/SessionManager.java | 45 +-
.../query/control/clientsession/ClientSession.java | 2 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 1 -
.../java/org/apache/iotdb/db/service/DataNode.java | 28 +-
.../db/service/DataNodeServerCommandLine.java | 17 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +-
.../iotdb/db/service/RegionMigrateService.java | 14 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 6 +-
.../recorder/CompactionMetricsRecorder.java | 39 +
.../service/thrift/impl/ClientRPCServiceImpl.java | 117 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 7 +
.../tools/settle/TsFileSettleByCompactionTool.java | 123 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 66 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 58 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 16 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 158 -
.../compaction/FastAlignedCrossCompactionTest.java | 134 +
.../FastCrossCompactionPerformerTest.java | 48 +-
.../FastNonAlignedCrossCompactionTest.java | 138 +
.../compaction/TestUtilsForAlignedSeries.java | 42 +-
...eCompactionWithFastPerformerValidationTest.java | 6 +-
.../db/engine/compaction/cross/MergeTest.java | 19 -
.../inner/AbstractInnerSpaceCompactionTest.java | 19 -
.../inner/FastCompactionPerformerAlignedTest.java | 21 +-
.../FastCompactionPerformerNoAlignedTest.java | 20 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 8 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 25 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 16 +-
.../InnerUnseqCompactionWithFastPerformerTest.java | 4 +-
...rUnseqCompactionWithReadPointPerformerTest.java | 19 -
.../ReadChunkCompactionPerformerAlignedTest.java | 3 -
.../SizeTieredCompactionRecoverTest.java | 22 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 19 -
.../recover/SizeTieredCompactionRecoverTest.java | 34 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 2 -
.../db/engine/settle/SettleRequestHandlerTest.java | 162 +
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 6 -
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 12 -
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 61 +-
.../schemaRegion/SchemaRegionBasicTest.java | 45 +-
.../schemaRegion/SchemaRegionManagementTest.java | 43 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 10 +-
.../schemaRegion/SchemaRegionTestUtil.java | 36 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 52 +-
.../execution/exchange/LocalSinkHandleTest.java | 26 +-
.../execution/exchange/LocalSourceHandleTest.java | 12 +-
.../exchange/MPPDataExchangeManagerTest.java | 8 +-
.../mpp/execution/exchange/SourceHandleTest.java | 82 +-
.../operator/AggregationOperatorTest.java | 17 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 9 +-
.../operator/AlignedSeriesScanOperatorTest.java | 92 +-
.../execution/operator/AlignedSeriesTestUtil.java | 53 -
.../operator/DeviceMergeOperatorTest.java | 77 +-
.../execution/operator/DeviceViewOperatorTest.java | 16 +-
.../mpp/execution/operator/FillOperatorTest.java | 17 +-
.../operator/LastQueryMergeOperatorTest.java | 25 +-
.../execution/operator/LastQueryOperatorTest.java | 49 +-
.../operator/LastQuerySortOperatorTest.java | 49 +-
.../mpp/execution/operator/LimitOperatorTest.java | 22 +-
.../execution/operator/LinearFillOperatorTest.java | 57 +-
.../execution/operator/MergeSortOperatorTest.java | 205 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 73 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 267 +-
.../operator/RawDataAggregationOperatorTest.java | 549 +-
.../SeriesAggregationScanOperatorTest.java | 8 +-
.../execution/operator/SeriesScanOperatorTest.java | 8 +-
.../operator/SingleDeviceViewOperatorTest.java | 20 +-
.../SlidingWindowAggregationOperatorTest.java | 12 +-
.../execution/operator/TimeJoinOperatorTest.java | 56 +-
.../operator/UpdateLastCacheOperatorTest.java | 13 +-
.../operator/VerticallyConcatOperatorTest.java | 14 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 155 +-
.../operator/schema/SchemaCountOperatorTest.java | 283 +-
.../operator/schema/SchemaOperatorTestUtil.java | 66 +
.../schema/SchemaQueryScanOperatorTest.java | 146 +-
.../schedule/DefaultDriverSchedulerTest.java | 229 +-
.../execution/schedule/DriverSchedulerTest.java | 45 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 41 +-
.../schedule/queue/L1PriorityQueueTest.java | 6 +-
.../schedule/queue/L2PriorityQueueTest.java | 12 +-
.../mpp/execution/schedule/queue/QueueElement.java | 4 +-
.../plan/distribution/AlignedByDeviceTest.java | 108 +
.../query/reader/series/SeriesReaderTestUtil.java | 18 +
.../iotdb/db/rescon/ResourceManagerTest.java | 19 -
.../security/encrypt/MessageDigestEncryptTest.java | 2 +-
.../DataNodeInternalRPCServiceImplTest.java | 11 +-
.../db/sync/datasource/PipeOpManagerTest.java | 3 -
.../apache/iotdb/db/utils/EnvironmentUtils.java | 16 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 22 +-
.../db/wal/recover/WALRecoverManagerTest.java | 32 -
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 53 -
.../file/UnsealedTsFileRecoverPerformerTest.java | 31 -
.../src/test/resources/iotdb-datanode.properties | 2 +-
service-rpc/pom.xml | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
session/pom.xml | 6 +-
.../java/org/apache/iotdb/session/TabletTest.java | 81 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 63 +
site/pom.xml | 22 +-
.../replace-picture-urls.sh | 11 +-
site/src/main/.vuepress/config.js | 6 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 3 -
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 2 +-
thrift-commons/pom.xml | 2 +-
thrift-commons/src/main/thrift/common.thrift | 4 +
thrift-confignode/pom.xml | 2 +-
thrift-influxdb/pom.xml | 2 +-
thrift-iot-consensus/pom.xml | 2 +-
thrift-mlnode/pom.xml | 2 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/datanode.thrift | 2 +
trigger-api/pom.xml | 2 +-
tsfile/pom.xml | 6 +-
.../read/TsFileAlignedSeriesReaderIterator.java | 40 +-
.../iotdb/tsfile/read/TsFileRestorableReader.java | 10 +-
.../write/writer/TsFileIOWriterEndFileTest.java | 27 +-
udf-api/pom.xml | 2 +-
zeppelin-interpreter/pom.xml | 2 +-
476 files changed, 25748 insertions(+), 11153 deletions(-)
copy server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/AlignedByDeviceTest.java => confignode/src/test/java/org/apache/iotdb/confignode/manager/ClusterSchemaManagerTest.java (55%)
create mode 100644 docs/UserGuide/Operators-Functions/Machine-Learning.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Machine-Learning.md
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppJVMConfig.java
copy server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/AlignedByDeviceTest.java => integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteJVMConfig.java (67%)
copy integration-test/src/main/java/org/apache/iotdb/itbase/env/{BaseNodeWrapper.java => JVMConfig.java} (52%)
copy integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBPartitionDurableIT.java => IoTDBPartitionCreationIT.java} (53%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/builtinfunction/scalar/IoTDBDiffFunction2IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/builtinfunction/scalar/IoTDBDiffFunction3IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/builtinfunction/scalar/IoTDBDiffFunctionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/libudf/it/dlearn/DLearnIT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFOutlier.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dlearn/UDTFAR.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/BuiltinScalarFunction.java
create mode 100644 server/src/assembly/resources/tools/tsfile/settle-tsfile.bat
copy integration-test/src/test/resources/iotdb-datanode.properties => server/src/assembly/resources/tools/tsfile/settle-tsfile.sh (53%)
copy server/src/main/codegen/{config.fmpp => dataModel/CompareType.tdd} (82%)
create mode 100644 server/src/main/codegen/templates/evEventWindow.ftl
create mode 100644 server/src/main/codegen/templates/evEventWindowManager.ftl
create mode 100644 server/src/main/codegen/templates/eventWindow.ftl
create mode 100644 server/src/main/codegen/templates/eventWindowManager.ftl
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/reader/ISchemaReader.java => audit/AuditLogOperation.java} (77%)
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/reader/ISchemaReader.java => audit/AuditLogStorage.java} (77%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/subtask/{SubCompactionTaskSummary.java => FastCompactionTaskSummary.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/settle/SettleRequestHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionInfo.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionTable.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalSchemaPartitionTable.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/LocalSchemaProcessor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/IStorageGroupSchemaManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupSchemaManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/DeviceGroupSchemaTree.java
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java => mpp/execution/operator/factory/OperatorFactory.java} (58%)
rename node-commons/src/main/java/org/apache/iotdb/commons/service/metric/enums/Operation.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/factory/SourceOperatorFactory.java (55%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{LevelTimeSeriesCountOperator.java => CountGroupByLevelScanOperator.java} (63%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/DevicesCountOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/NodePathsSchemaScanOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/TimeSeriesCountOperator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesSchemaScanOperator.java => source/DeviceSchemaSource.java} (57%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/ISchemaSource.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/NodeSchemaSource.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{PathsUsingTemplateScanOperator.java => source/PathsUsingTemplateSource.java} (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/SchemaSourceFactory.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{TimeSeriesSchemaScanOperator.java => source/TimeSeriesSchemaSource.java} (64%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{TimeWindow.java => EventWindow.java} (54%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventWindowManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventWindowParameter.java
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/reader/ISchemaReader.java => mpp/execution/operator/window/TimeWindowParameter.java} (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowManagerFactory.java
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java => mpp/execution/operator/window/WindowParameter.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/reader/ISchemaReader.java => mpp/execution/operator/window/WindowType.java} (70%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/{FragmentInstanceAbortedException.java => DriverTaskAbortedException.java} (82%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/multilevelqueue/DriverTaskHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/multilevelqueue/MultilevelPriorityQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/multilevelqueue/Priority.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/{DriverTaskID.java => DriverTaskId.java} (56%)
rename server/src/main/java/org/apache/iotdb/db/mpp/metric/{DataExchangeMetricSet.java => DataExchangeCostMetricSet.java} (94%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/DataExchangeCountMetricSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/PipelineDriverFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/InternalBatchActivateTemplateNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/InternalCreateMultiTimeSeriesNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/InternalBatchActivateTemplateStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/internal/InternalCreateMultiTimeSeriesStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/DiffFunctionColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/unary/DiffFunctionTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/settle/TsFileSettleByCompactionTool.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/MetadataManagerHelper.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/settle/SettleRequestHandlerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaOperatorTestUtil.java
create mode 100644 session/src/test/java/org/apache/iotdb/session/TabletTest.java
create mode 100644 session/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java
rename integration-test/src/test/resources/iotdb-datanode.properties => site/replace-picture-urls.sh (54%)
mode change 100644 => 100755