This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch tsbs/iot
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6eb29f4365e add query time cost statistics
add c2837425ad6 Allowing create statement from bad connection (#12444)
add 9ea369559b8 [IOTDB-1667] Speed up the deletion of database by avoiding
flush (#12445)
add b75627e1203 pref(bat): support space in path (#12435)
add 352269f3ded update spotless version (#12345)
add 65fbf47897b add blame (#12449)
add 5d8deac225f Ensuring IoTconsensus data consistency during region
migration (#12448)
add 789cc6983f1 Modify initConfigManager() (#12452)
add a5ed1745e7f fix compaction selector ut (#12442)
add 5c25ef63b78 Bump golang.org/x/net in /iotdb-connector/grafana-plugin
(#12379)
add 7726741c61b Fix the issue of obtaining Windows directory permissions,
fix the issue of allocating IoTDB memory for configuration, and add the -- help
command (#12450)
add e857bccf54d Remove backup (#12455)
add ab8a33cfc7f Feature/move stuff to the extras repository take 2 (#12373)
add b91abb51644 Revert "Modify initConfigManager() (#12452)"
add 7df7e5cfa95 Lift the storage limit for tag and attribute management
(#12447)
add f4e498f1685 Bump org.bouncycastle:bcprov-jdk18on from 1.75 to 1.78
(#12458)
add f1b42deb387 Fix PartialPath#intersectWithPrefixPattern return wrong
result (#12465)
add 57a6ff4b44f add alter view statement in snapshot parser
add c63a940a74c remove connector it (#12471)
add 6f29fcf26d8 Pipe: Fixed connector subtask manager to allow restarted
DataRegions to reuse connectors from other not restarted DataRegions (#12470)
add 46319bd403b Pipe IT: Return directly when SQL retry failed in IT to
avoid potential fake failure interference (#12468)
add 2db087dc0fd Subscription: randomly generate consumer group id and
consumer id if not exist & validate topic config ahead on DN (#12467)
add f7f34de5d3f Load: Avoid NPE when load task ends after clean task's
execution (#12474)
add 139720d7f9a Limit direct buffer memory cost when create consensus
region (#12431)
add e383b0faf5b Fix region migration code (#12472)
add 1a16b6d333a Normalize LoadCache interfaces (#12441)
new 367e0104862 Merge remote-tracking branch 'origin/master' into tsbs/iot
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.git-blame-ignore-revs | 1 +
.github/workflows/grafana-plugin.yml | 68 -
.gitignore | 7 -
codecov.yml | 1 -
distribution/pom.xml | 133 -
distribution/src/assembly/flink-sql-connector.xml | 41 -
distribution/src/assembly/grafana-connector.xml | 48 -
distribution/src/assembly/grafana-plugin.xml | 38 -
distribution/src/assembly/spark-connector.xml | 48 -
docker/ReadMe.md | 44 -
.../GrafanaPlugin/Dockerfile-0.14.0-iotdb | 42 -
.../DockerCompose/GrafanaPlugin/docker-compose.yml | 48 -
.../main/DockerCompose/docker-compose-grafana.yml | 50 -
docker/src/main/Dockerfile-0.12.6-grafana | 41 -
.../src/main/Dockerfile-0.13.3-grafana-connector | 41 -
example/flink-sql/pom.xml | 99 -
.../org/apache/iotdb/example/BatchSinkExample.java | 74 -
.../apache/iotdb/example/BoundedScanExample.java | 52 -
.../java/org/apache/iotdb/example/CDCExample.java | 54 -
.../org/apache/iotdb/example/LookupExample.java | 77 -
.../apache/iotdb/example/StreamingSinkExample.java | 68 -
example/flink/README.md | 40 -
example/flink/pom.xml | 61 -
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 101 -
.../org/apache/iotdb/flink/FlinkIoTDBSource.java | 93 -
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 128 -
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 81 -
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 129 -
.../iotdb/flink/FlinkTsFileStreamSource.java | 84 -
.../java/org/apache/iotdb/flink/TsFileUtils.java | 107 -
example/hadoop/pom.xml | 38 -
.../org/apache/iotdb/hadoop/tsfile/Constant.java | 32 -
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 136 -
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 185 -
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 139 -
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 77 -
example/kafka/pom.xml | 48 -
example/kafka/readme.md | 75 -
.../main/java/org/apache/iotdb/kafka/Constant.java | 68 -
.../main/java/org/apache/iotdb/kafka/Consumer.java | 136 -
.../org/apache/iotdb/kafka/ConsumerThread.java | 164 -
.../main/java/org/apache/iotdb/kafka/Producer.java | 63 -
example/pom.xml | 15 +-
example/pulsar/pom.xml | 55 -
.../java/org/apache/iotdb/pulsar/Constant.java | 67 -
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 111 -
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 161 -
.../org/apache/iotdb/pulsar/PulsarProducer.java | 55 -
example/rabbitmq/pom.xml | 47 -
example/rabbitmq/readme.md | 63 -
.../java/org/apache/iotdb/rabbitmq/Constant.java | 72 -
.../iotdb/rabbitmq/RabbitMQChannelUtils.java | 52 -
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 139 -
.../apache/iotdb/rabbitmq/RabbitMQProducer.java | 49 -
example/rocketmq/pom.xml | 48 -
example/rocketmq/readme.md | 83 -
.../java/org/apache/iotdb/rocketmq/Constant.java | 70 -
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 208 -
.../apache/iotdb/rocketmq/RocketMQProducer.java | 100 -
.../main/java/org/apache/iotdb/rocketmq/Utils.java | 39 -
.../org/apache/iotdb/DataMigrationExample.java | 4 +-
.../iotdb/HybridTimeseriesSessionExample.java | 1 +
.../iotdb/SyntaxConventionRelatedExample.java | 1 +
integration-test/pom.xml | 61 +-
.../it/env/cluster/config/MppCommonConfig.java | 18 +
.../env/cluster/config/MppSharedCommonConfig.java | 21 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 1 +
.../it/env/remote/config/RemoteCommonConfig.java | 15 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../iotdb/itbase/runtime/ClusterTestStatement.java | 38 +-
.../IoTDBRegionMigrateReliabilityITFramework.java | 8 +-
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 4 +-
.../db/it/aggregation/minby/IoTDBMinByIT.java | 4 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 1 +
.../apache/iotdb/db/it/schema/IoTDBTagLimitIT.java | 196 +
.../org/apache/iotdb/flink/it/AbstractTest.java | 46 -
.../java/org/apache/iotdb/flink/it/SinkTest.java | 163 -
.../java/org/apache/iotdb/flink/it/SourceTest.java | 192 -
.../test/java/org/apache/iotdb/flink/it/Utils.java | 94 -
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 32 +-
.../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 28 +-
.../org/apache/iotdb/spark/it/AbstractTest.java | 55 -
.../java/org/apache/iotdb/spark/it/ReadTest.java | 145 -
.../test/java/org/apache/iotdb/spark/it/Utils.java | 95 -
.../java/org/apache/iotdb/spark/it/WriteTest.java | 116 -
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 4 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 47 +
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 390 -
.../main/java/org/apache/iotdb/udf/api/State.java | 3 +-
.../main/java/org/apache/iotdb/udf/api/UDAF.java | 3 +-
.../cli/src/assembly/resources/sbin/start-cli.bat | 2 +-
.../cli/src/assembly/resources/tools/backup.bat | 125 -
.../cli/src/assembly/resources/tools/backup.sh | 134 -
.../src/assembly/resources/tools/export-data.bat | 6 +-
.../src/assembly/resources/tools/export-tsfile.bat | 6 +-
.../src/assembly/resources/tools/import-data.bat | 6 +-
.../src/assembly/resources/tools/load-tsfile.bat | 2 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 4 +-
.../java/org/apache/iotdb/tool/ImportData.java | 3 +-
.../java/org/apache/iotdb/isession/ISession.java | 36 +-
.../org/apache/iotdb/isession/SessionConfig.java | 1 +
.../apache/iotdb/isession/pool/ISessionPool.java | 52 +-
.../iotdb/isession/pool/SessionDataSetWrapper.java | 1 +
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 4 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 1 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 1 +
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 11 +-
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 1 +
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 1 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 1 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 1 +
.../rpc/subscription/config/ConsumerConfig.java | 8 +
.../response/PipeSubscribeHandshakeResp.java | 26 +-
.../java/org/apache/iotdb/session/Session.java | 33 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 12 +-
.../session/subscription/SubscriptionConsumer.java | 30 +-
.../subscription/SubscriptionEndpointsSyncer.java | 9 +-
.../session/subscription/SubscriptionProvider.java | 25 +-
.../SubscriptionSessionConnection.java | 6 +-
iotdb-connector/flink-iotdb-connector/README.md | 58 -
iotdb-connector/flink-iotdb-connector/pom.xml | 84 -
.../iotdb/flink/DefaultIoTSerializationSchema.java | 130 -
.../main/java/org/apache/iotdb/flink/Event.java | 70 -
.../java/org/apache/iotdb/flink/IoTDBSink.java | 213 -
.../java/org/apache/iotdb/flink/IoTDBSource.java | 100 -
.../apache/iotdb/flink/IoTSerializationSchema.java | 32 -
.../apache/iotdb/flink/options/IoTDBOptions.java | 70 -
.../iotdb/flink/options/IoTDBSinkOptions.java | 106 -
.../iotdb/flink/options/IoTDBSourceOptions.java | 51 -
.../flink/DefaultIoTSerializationSchemaTest.java | 54 -
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 116 -
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 83 -
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 72 -
iotdb-connector/flink-sql-iotdb-connector/pom.xml | 124 -
.../flink/sql/client/IoTDBWebSocketClient.java | 92 -
.../org/apache/iotdb/flink/sql/common/Options.java | 64 -
.../org/apache/iotdb/flink/sql/common/Utils.java | 177 -
.../sql/exception/IllegalIoTDBPathException.java | 25 -
.../sql/exception/IllegalOptionException.java | 25 -
.../sql/exception/IllegalSchemaException.java | 25 -
.../sql/exception/IllegalUrlPathException.java | 25 -
.../exception/UnsupportedDataTypeException.java | 25 -
.../sql/factory/IoTDBDynamicTableFactory.java | 230 -
.../sql/function/IoTDBBoundedScanFunction.java | 167 -
.../flink/sql/function/IoTDBCDCSourceFunction.java | 297 -
.../flink/sql/function/IoTDBLookupFunction.java | 149 -
.../flink/sql/function/IoTDBSinkFunction.java | 143 -
.../flink/sql/provider/IoTDBDynamicTableSink.java | 64 -
.../sql/provider/IoTDBDynamicTableSource.java | 76 -
.../iotdb/flink/sql/wrapper/SchemaWrapper.java | 46 -
.../iotdb/flink/sql/wrapper/TabletWrapper.java | 47 -
.../org.apache.flink.table.factories.Factory | 20 -
iotdb-connector/flink-tsfile-connector/README.md | 177 -
iotdb-connector/flink-tsfile-connector/pom.xml | 158 -
.../apache/iotdb/flink/tsfile/RowRecordParser.java | 46 -
.../iotdb/flink/tsfile/RowRowRecordParser.java | 121 -
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 166 -
.../iotdb/flink/tsfile/TSRecordConverter.java | 60 -
.../iotdb/flink/tsfile/TSRecordOutputFormat.java | 98 -
.../iotdb/flink/tsfile/TsFileInputFormat.java | 174 -
.../iotdb/flink/tsfile/TsFileOutputFormat.java | 136 -
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 65 -
.../RowTSRecordOutputFormatIntegrationTest.java | 54 -
.../flink/tsfile/RowTSRecordOutputFormatTest.java | 75 -
.../flink/tsfile/RowTsFileConnectorTestBase.java | 77 -
.../RowTsFileInputFormatIntegrationTest.java | 108 -
.../flink/tsfile/RowTsFileInputFormatTest.java | 88 -
.../flink/tsfile/RowTsFileInputFormatTestBase.java | 49 -
.../tsfile/RowTsFileOutputFormatTestBase.java | 119 -
.../util/TSFileConfigUtilCompletenessTest.java | 102 -
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 233 -
.../src/test/resources/log4j.properties | 28 -
.../grafana-connector/img/add_data_source.png | Bin 108927 -> 0 bytes
.../grafana-connector/img/add_graph.png | Bin 364163 -> 0 bytes
.../grafana-connector/img/edit_data_source.png | Bin 177869 -> 0 bytes
iotdb-connector/grafana-connector/pom.xml | 257 -
iotdb-connector/grafana-connector/readme.md | 192 -
iotdb-connector/grafana-connector/readme_zh.md | 195 -
.../web/grafana/TsfileWebDemoApplication.java | 30 -
.../apache/iotdb/web/grafana/bean/TimeValues.java | 47 -
.../iotdb/web/grafana/conf/MyConfiguration.java | 47 -
.../controller/DatabaseConnectController.java | 196 -
.../org/apache/iotdb/web/grafana/dao/BasicDao.java | 34 -
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 208 -
.../web/grafana/interceptor/LoginInterceptor.java | 64 -
.../grafana/service/DatabaseConnectService.java | 33 -
.../service/impl/DatabaseConnectServiceImpl.java | 46 -
.../src/main/resources/application.properties | 39 -
.../web/grafana/dao/impl/BasicDaoImplTest.java | 53 -
iotdb-connector/grafana-plugin/.gitignore | 33 -
iotdb-connector/grafana-plugin/.prettierrc.js | 20 -
iotdb-connector/grafana-plugin/CHANGELOG.md | 24 -
iotdb-connector/grafana-plugin/LICENSE | 201 -
iotdb-connector/grafana-plugin/Magefile.go | 32 -
iotdb-connector/grafana-plugin/README.md | 177 -
iotdb-connector/grafana-plugin/backend-compile.bat | 31 -
iotdb-connector/grafana-plugin/backend-compile.sh | 48 -
iotdb-connector/grafana-plugin/go.mod | 107 -
iotdb-connector/grafana-plugin/jest.config.js | 24 -
iotdb-connector/grafana-plugin/package.json | 31 -
iotdb-connector/grafana-plugin/pkg/main.go | 40 -
.../pkg/plugin/iotdb_resource_handler.go | 170 -
.../grafana-plugin/pkg/plugin/plugin.go | 430 -
iotdb-connector/grafana-plugin/pom.xml | 116 -
.../grafana-plugin/src/ConfigEditor.tsx | 108 -
iotdb-connector/grafana-plugin/src/QueryEditor.tsx | 343 -
.../src/componments/AggregateFun.tsx | 44 -
.../src/componments/ControlValue.tsx | 38 -
.../grafana-plugin/src/componments/FillValue.tsx | 38 -
.../grafana-plugin/src/componments/Form.tsx | 42 -
.../grafana-plugin/src/componments/FromValue.tsx | 110 -
.../grafana-plugin/src/componments/GroupBy.tsx | 58 -
.../grafana-plugin/src/componments/SelectValue.tsx | 110 -
.../grafana-plugin/src/componments/TimeSeries.tsx | 82 -
.../grafana-plugin/src/componments/WhereValue.tsx | 39 -
iotdb-connector/grafana-plugin/src/datasource.ts | 106 -
iotdb-connector/grafana-plugin/src/functions.ts | 20 -
.../grafana-plugin/src/img/addIoTDBDataSource.png | Bin 43760 -> 0 bytes
iotdb-connector/grafana-plugin/src/img/logo.svg | 271 -
.../grafana-plugin/src/img/showData.png | Bin 170827 -> 0 bytes
iotdb-connector/grafana-plugin/src/module.ts | 25 -
iotdb-connector/grafana-plugin/src/plugin.json | 50 -
iotdb-connector/grafana-plugin/src/types.ts | 68 -
iotdb-connector/grafana-plugin/tsconfig.json | 9 -
iotdb-connector/grafana-plugin/yarn.lock | 11194 -------------------
iotdb-connector/hadoop/README.md | 212 -
iotdb-connector/hadoop/pom.xml | 191 -
.../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 115 -
.../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 455 -
.../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 114 -
.../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 108 -
.../org/apache/iotdb/hadoop/tsfile/IReaderSet.java | 38 -
.../iotdb/hadoop/tsfile/TSFHadoopException.java | 45 -
.../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 297 -
.../apache/iotdb/hadoop/tsfile/TSFInputSplit.java | 39 -
.../iotdb/hadoop/tsfile/TSFOutputFormat.java | 58 -
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 260 -
.../iotdb/hadoop/tsfile/TSFRecordWriter.java | 62 -
.../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 202 -
.../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 229 -
.../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 71 -
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 121 -
.../iotdb/hadoop/tsfile/constant/TestConstant.java | 28 -
.../hadoop/src/test/resources/logback.xml | 41 -
iotdb-connector/hive-connector/pom.xml | 139 -
.../org/apache/iotdb/hive/TSFHiveInputFormat.java | 56 -
.../org/apache/iotdb/hive/TSFHiveOutputFormat.java | 75 -
.../org/apache/iotdb/hive/TSFHiveRecordReader.java | 158 -
.../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 71 -
.../org/apache/iotdb/hive/TsFileDeserializer.java | 159 -
.../java/org/apache/iotdb/hive/TsFileSerDe.java | 169 -
.../apache/iotdb/hive/TsFileSerDeException.java | 40 -
.../apache/iotdb/hive/TSFHiveInputFormatTest.java | 111 -
.../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 159 -
.../apache/iotdb/hive/TsFileDeserializerTest.java | 126 -
.../org/apache/iotdb/hive/TsFileSerDeTest.java | 149 -
.../org/apache/iotdb/hive/TsFileTestHelper.java | 126 -
.../apache/iotdb/hive/constant/TestConstant.java | 28 -
.../hive-connector/src/test/resources/logback.xml | 39 -
iotdb-connector/pom.xml | 66 -
iotdb-connector/spark-iotdb-connector/pom.xml | 140 -
.../spark-iotdb-connector/scala_2.11/pom.xml | 50 -
.../spark-iotdb-connector/scala_2.12/pom.xml | 51 -
.../org/apache/iotdb/spark/db/Converter.scala | 89 -
.../org/apache/iotdb/spark/db/DataFrameTools.scala | 131 -
.../org/apache/iotdb/spark/db/DefaultSource.scala | 61 -
.../org/apache/iotdb/spark/db/IoTDBOptions.scala | 43 -
.../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 137 -
.../org/apache/iotdb/spark/db/IoTDBRelation.scala | 117 -
.../org/apache/iotdb/spark/db/SQLConstant.scala | 27 -
.../org/apache/iotdb/spark/db/Transformer.scala | 172 -
.../scala/org/apache/iotdb/spark/db/package.scala | 36 -
iotdb-connector/spark-tsfile/pom.xml | 114 -
.../iotdb/spark/tsfile/io/TsFileOutputFormat.java | 45 -
.../iotdb/spark/tsfile/io/TsFileRecordWriter.java | 61 -
.../org/apache/iotdb/spark/tsfile/qp/Executor.java | 51 -
.../iotdb/spark/tsfile/qp/QueryProcessor.java | 195 -
.../spark/tsfile/qp/common/BasicOperator.java | 66 -
.../spark/tsfile/qp/common/FilterOperator.java | 161 -
.../iotdb/spark/tsfile/qp/common/Operator.java | 44 -
.../iotdb/spark/tsfile/qp/common/SQLConstant.java | 138 -
.../iotdb/spark/tsfile/qp/common/SingleQuery.java | 65 -
.../iotdb/spark/tsfile/qp/common/TSQueryPlan.java | 68 -
.../qp/exception/BasicOperatorException.java | 29 -
.../tsfile/qp/exception/DNFOptimizeException.java | 29 -
.../qp/exception/LogicalOptimizeException.java | 29 -
.../tsfile/qp/exception/MergeFilterException.java | 28 -
.../qp/exception/QueryOperatorException.java | 28 -
.../qp/exception/QueryProcessorException.java | 37 -
.../tsfile/qp/exception/RemoveNotException.java | 29 -
.../tsfile/qp/optimizer/DNFFilterOptimizer.java | 154 -
.../tsfile/qp/optimizer/IFilterOptimizer.java | 31 -
.../qp/optimizer/MergeSingleFilterOptimizer.java | 133 -
.../tsfile/qp/optimizer/PhysicalOptimizer.java | 251 -
.../tsfile/qp/optimizer/RemoveNotOptimizer.java | 92 -
.../org/apache/iotdb/spark/tsfile/Converter.scala | 144 -
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 293 -
.../iotdb/spark/tsfile/NarrowConverter.scala | 596 -
.../spark/tsfile/NarrowTsFileOutputWriter.scala | 50 -
.../apache/iotdb/spark/tsfile/Transformer.scala | 175 -
.../iotdb/spark/tsfile/TsFileWriterFactory.scala | 42 -
.../apache/iotdb/spark/tsfile/WideConverter.scala | 504 -
.../spark/tsfile/WideTsFileOutputWriter.scala | 53 -
.../org/apache/iotdb/spark/tsfile/package.scala | 62 -
.../apache/iotdb/spark/constant/TestConstant.java | 28 -
.../org/apache/iotdb/spark/tool/TsFileExample.java | 111 -
.../apache/iotdb/spark/tool/TsFileWriteTool.java | 280 -
.../apache/iotdb/spark/tsfile/ConverterTest.scala | 270 -
.../apache/iotdb/spark/tsfile/HDFSInputTest.java | 81 -
.../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 641 --
.../zeppelin-interpreter/IoTDB-Zeppelin-Demo.zpln | 377 -
iotdb-connector/zeppelin-interpreter/pom.xml | 90 -
.../apache/zeppelin/iotdb/IoTDBInterpreter.java | 296 -
.../src/main/resources/interpreter-setting.json | 70 -
.../src/assembly/resources/conf/confignode-env.bat | 14 +-
.../assembly/resources/sbin/remove-confignode.bat | 2 +-
.../assembly/resources/sbin/start-confignode.bat | 10 +-
.../assembly/resources/sbin/stop-confignode.bat | 4 +-
.../iotdb/confignode/manager/ProcedureManager.java | 14 +-
.../manager/consensus/ConsensusManager.java | 13 +-
.../iotdb/confignode/manager/load/LoadManager.java | 46 +-
.../manager/load/balancer/RouteBalancer.java | 9 +-
.../router/leader/AbstractLeaderBalancer.java | 48 +-
.../router/leader/GreedyLeaderBalancer.java | 14 +-
.../router/leader/MinCostFlowLeaderBalancer.java | 142 +-
.../confignode/manager/load/cache/LoadCache.java | 181 +-
.../consensus/ConsensusGroupHeartbeatSample.java | 7 +
.../cache/consensus/ConsensusGroupStatistics.java | 7 +
.../manager/load/cache/node/BaseNodeCache.java | 8 +-
.../manager/load/cache/node/NodeStatistics.java | 4 +-
.../manager/load/cache/region/RegionCache.java | 3 +-
.../load/cache/region/RegionGroupCache.java | 30 +-
.../load/cache/region/RegionHeartbeatSample.java | 7 +
.../manager/load/service/EventService.java | 133 +-
.../iotdb/confignode/manager/node/NodeManager.java | 7 +-
.../manager/partition/PartitionManager.java | 1 +
.../pipe/execution/PipeConfigNodeSubtask.java | 1 +
.../execution/PipeConfigNodeSubtaskExecutor.java | 4 +-
.../manager/schema/ClusterSchemaManager.java | 36 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +-
.../confignode/persistence/node/NodeInfo.java | 24 +-
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/PartitionInfo.java | 1 +
.../persistence/partition/RegionGroup.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 8 +-
.../iotdb/confignode/procedure/Procedure.java | 32 +-
.../confignode/procedure/ProcedureExecutor.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 38 +-
.../procedure/env/RegionMaintainHandler.java | 14 +-
.../impl/node/AddConfigNodeProcedure.java | 2 +-
.../impl/region/AddRegionPeerProcedure.java | 48 +-
.../impl/region/CreateRegionGroupsProcedure.java | 9 +-
.../impl/region/RemoveRegionPeerProcedure.java | 6 +-
.../procedure/scheduler/ProcedureScheduler.java | 4 +-
.../confignode/manager/load/FakeSubscriber.java | 92 +
.../confignode/manager/load/LoadManagerTest.java | 295 +
.../router/leader/CFDLeaderBalancerTest.java | 34 +-
.../router/leader/GreedyLeaderBalancerTest.java | 30 +-
.../leader/LeaderBalancerComparisonTest.java | 39 +-
.../manager/load/cache/RegionGroupCacheTest.java | 23 +-
.../consensus/iot/IoTConsensusServerImpl.java | 7 +-
.../iot/service/IoTConsensusRPCService.java | 7 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 9 +
.../iotdb/consensus/ratis/utils/RetryPolicy.java | 1 +
.../src/assembly/resources/conf/datanode-env.bat | 17 +-
.../assembly/resources/sbin/remove-datanode.bat | 2 +-
.../src/assembly/resources/sbin/start-datanode.bat | 41 +-
.../src/assembly/resources/sbin/start-datanode.sh | 1 +
.../src/assembly/resources/sbin/stop-datanode.bat | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 23 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 1 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 8 +-
.../tsfile/TsFileInsertionDataContainer.java | 4 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 4 +-
.../sdt/SwingingDoorTrendingFilter.java | 1 +
.../connector/PipeConnectorSubtaskManager.java | 29 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 1 +
.../rest/utils/InsertTabletSortDataUtils.java | 1 +
.../iotdb/db/protocol/session/SessionManager.java | 1 +
.../common/schematree/ClusterSchemaTree.java | 1 +
.../timerangeiterator/ITimeRangeIterator.java | 4 +-
.../execution/exchange/sink/SinkChannel.java | 2 +
.../exchange/source/LocalSourceHandle.java | 1 +
.../fragment/FragmentInstanceContext.java | 3 +
.../execution/load/LoadTsFileManager.java | 6 +-
.../queryengine/execution/memory/MemoryPool.java | 2 +
.../process/AbstractConsumeAllOperator.java | 5 +-
.../operator/process/LinearFillOperator.java | 1 +
.../operator/process/MergeSortOperator.java | 4 +-
.../process/join/FullOuterTimeJoinOperator.java | 4 +-
.../process/join/InnerTimeJoinOperator.java | 1 +
.../metric/DataExchangeCostMetricSet.java | 1 +
.../metric/QueryExecutionMetricSet.java | 3 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 1 +
.../queryengine/plan/analyze/ExpressionUtils.java | 3 +-
.../analyze/cache/partition/PartitionCache.java | 5 +
.../cache/partition/StorageGroupCacheResult.java | 2 +
.../plan/analyze/schema/ISchemaComputation.java | 8 +-
.../plan/execution/IQueryExecution.java | 4 +-
.../queryengine/plan/execution/QueryExecution.java | 4 +-
.../config/executor/ClusterConfigTaskExecutor.java | 31 +-
.../visitor/TransformToViewExpressionVisitor.java | 6 +
.../metedata/write/view/CreateLogicalViewNode.java | 1 +
.../plan/planner/plan/node/write/InsertNode.java | 2 +
.../planner/plan/node/write/InsertRowNode.java | 1 +
.../planner/plan/node/write/InsertTabletNode.java | 1 +
.../planner/plan/parameter/SeriesScanOptions.java | 4 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 4 +-
.../plan/statement/crud/InsertBaseStatement.java | 1 +
.../metadata/view/AlterLogicalViewStatement.java | 1 +
.../row/ElasticSerializableRowRecordList.java | 1 +
.../tv/ElasticSerializableTVList.java | 1 +
.../schemaengine/schemaregion/ISchemaRegion.java | 4 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 57 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 54 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 1 +
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 6 +-
.../mtree/impl/mem/mnode/info/MeasurementInfo.java | 3 +
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 1 +
.../mtree/impl/pbtree/flush/Scheduler.java | 1 +
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 1 +
.../impl/pbtree/schemafile/SegmentedPage.java | 1 +
.../schemafile/pagemgr/BTreePageManager.java | 4 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 5 +-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 1 +
.../schemaengine/schemaregion/tag/TagLogFile.java | 215 +-
.../schemaengine/schemaregion/tag/TagManager.java | 162 +-
.../schemaregion/utils/ResourceByPathUtils.java | 2 +
.../view/visitor/TransformToExpressionVisitor.java | 6 +
.../write/req/view/ICreateLogicalViewPlan.java | 8 +-
.../db/service/DataNodeServerCommandLine.java | 7 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +-
.../org/apache/iotdb/db/service/RPCService.java | 7 +-
.../db/service/metrics/CompactionMetrics.java | 2 +
.../db/storageengine/dataregion/DataRegion.java | 62 +-
.../dataregion/ILastFlushTimeMap.java | 3 +
.../impl/ReadChunkCompactionPerformer.java | 5 +-
.../compaction/selector/estimator/FileInfo.java | 1 +
.../compaction/tool/ListTimeRangeImpl.java | 1 +
.../dataregion/memtable/AbstractMemTable.java | 3 +
.../dataregion/memtable/DeviceIDFactory.java | 1 +
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 4 +-
.../dataregion/memtable/TsFileProcessor.java | 6 +
.../dataregion/read/control/FileReaderManager.java | 2 +
.../dataregion/tsfile/TsFileResource.java | 24 +-
.../generator/SimpleFileVersionController.java | 2 +
.../dataregion/tsfile/timeindex/ITimeIndex.java | 8 +-
.../dataregion/wal/allocation/ElasticStrategy.java | 1 +
.../wal/allocation/FirstCreateStrategy.java | 1 +
.../wal/allocation/RoundRobinStrategy.java | 1 +
.../dataregion/wal/buffer/WALBuffer.java | 6 +
.../wal/checkpoint/CheckpointManager.java | 5 +
.../storageengine/dataregion/wal/node/WALNode.java | 9 +
.../dataregion/wal/recover/WALRecoverManager.java | 2 +
.../wal/utils/listener/AbstractResultListener.java | 1 +
.../db/storageengine/rescon/disk/TierManager.java | 5 +
.../db/storageengine/rescon/memory/SystemInfo.java | 34 +
.../rescon/memory/TimePartitionManager.java | 14 +
.../agent/SubscriptionBrokerAgent.java | 4 +-
.../broker/SerializedEnrichedEvent.java | 4 +-
.../receiver/SubscriptionReceiverV1.java | 39 +-
.../SubscriptionConnectorSubtaskManager.java | 37 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 4 +-
.../db/tools/schema/SRStatementGenerator.java | 71 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 1 +
.../java/org/apache/iotdb/db/utils/MathUtils.java | 1 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 20 +
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 3 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 1 +
.../AlignedSeriesAggregationScanOperatorTest.java | 3 +-
.../operator/RawDataAggregationOperatorTest.java | 1 +
.../schedule/DefaultDriverSchedulerTest.java | 3 +-
.../storageengine/dataregion/DataRegionTest.java | 101 +-
.../iotdb/db/storageengine/dataregion/TTLTest.java | 4 +-
.../compaction/CompactionSchedulerTest.java | 8 +
.../CompactionSchedulerWithFastPerformerTest.java | 8 +
.../TsFileValidationCorrectnessTests.java | 1 +
.../cross/CrossSpaceCompactionSelectorTest.java | 44 +-
...actionWithReadPointPerformerValidationTest.java | 8 +-
.../cross/RewriteCompactionFileSelectorTest.java | 5 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 22 +-
...nkCompactionPerformerWithAlignedSeriesTest.java | 55 +-
.../settle/SettleRequestHandlerTest.java | 3 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 10 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 5 +-
.../rescon/memory/TimePartitionManagerTest.java | 3 +
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 3 +
.../iotdb/metrics/core/IoTDBMetricManager.java | 1 +
.../metrics/core/reporter/IoTDBJmxReporter.java | 5 +
.../iotdb/metrics/core/uitls/IoTDBCachedGauge.java | 5 +
.../iotdb/metrics/AbstractMetricManager.java | 3 +
.../iotdb/metrics/AbstractMetricService.java | 5 +
.../apache/iotdb/metrics/config/MetricConfig.java | 11 +
.../reporter/iotdb/IoTDBSessionReporter.java | 1 +
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 4 +
iotdb-core/node-commons/pom.xml | 7 +-
.../resources/conf/iotdb-common.properties | 14 +-
.../assembly/resources/sbin/destroy-confignode.bat | 2 +-
.../assembly/resources/sbin/destroy-datanode.bat | 2 +-
.../src/assembly/resources/sbin/health_check.bat | 40 +-
.../src/assembly/resources/sbin/health_check.sh | 23 +-
.../assembly/resources/sbin/start-standalone.bat | 4 +-
.../assembly/resources/sbin/stop-standalone.bat | 4 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 1 +
.../iotdb/commons/auth/user/BasicUserManager.java | 1 +
.../commons/auth/user/LocalFileUserAccessor.java | 1 +
.../client/property/ThriftClientProperty.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 18 +
.../iotdb/commons/conf/CommonDescriptor.java | 12 +
.../commons/consensus/index/ProgressIndex.java | 4 +-
.../index/impl/TimeWindowStateProgressIndex.java | 4 +-
.../iotdb/commons/exception/IoTDBException.java | 1 +
.../commons/executable/ExecutableManager.java | 1 +
.../org/apache/iotdb/commons/path/PartialPath.java | 18 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 5 +-
.../apache/iotdb/commons/path/PatternTreeMap.java | 1 +
.../org/apache/iotdb/commons/path/fa/IFAState.java | 12 +-
.../iotdb/commons/path/fa/IFATransition.java | 4 +-
.../apache/iotdb/commons/path/fa/IPatternFA.java | 12 +-
.../commons/path/fa/match/IStateMatchInfo.java | 28 +-
.../task/subtask/PipeAbstractConnectorSubtask.java | 4 +-
.../commons/schema/node/info/IDeviceInfo.java | 8 +-
.../commons/schema/node/role/IDeviceMNode.java | 8 +-
.../schema/view/viewExpression/ViewExpression.java | 4 +-
.../binary/BinaryViewExpression.java | 2 +
.../binary/arithmetic/AdditionViewExpression.java | 1 +
.../arithmetic/ArithmeticBinaryViewExpression.java | 1 +
.../binary/arithmetic/DivisionViewExpression.java | 1 +
.../binary/arithmetic/ModuloViewExpression.java | 1 +
.../arithmetic/MultiplicationViewExpression.java | 1 +
.../arithmetic/SubtractionViewExpression.java | 1 +
.../compare/CompareBinaryViewExpression.java | 1 +
.../binary/logic/LogicBinaryViewExpression.java | 1 +
.../view/viewExpression/leaf/NullViewOperand.java | 4 +-
.../viewExpression/leaf/TimeSeriesViewOperand.java | 2 +
.../viewExpression/leaf/TimestampViewOperand.java | 4 +-
.../multi/FunctionViewExpression.java | 2 +
.../ternary/BetweenViewExpression.java | 2 +
.../ternary/TernaryViewExpression.java | 2 +
.../viewExpression/unary/InViewExpression.java | 2 +
.../viewExpression/unary/IsNullViewExpression.java | 2 +
.../viewExpression/unary/LikeViewExpression.java | 2 +
.../unary/LogicNotViewExpression.java | 1 +
.../unary/NegationViewExpression.java | 1 +
.../unary/RegularViewExpression.java | 2 +
.../viewExpression/unary/UnaryViewExpression.java | 1 +
.../visitor/ViewExpressionVisitor.java | 6 +
.../iotdb/commons/service/StartupChecks.java | 1 +
.../iotdb/commons/service/ThriftService.java | 7 +-
.../meta/consumer/ConsumerGroupMeta.java | 4 +-
.../commons/subscription/meta/topic/TopicMeta.java | 4 +-
.../iotdb/commons/trigger/TriggerInformation.java | 2 +
.../apache/iotdb/commons/trigger/TriggerTable.java | 1 +
.../udf/builtin/BuiltinAggregationFunction.java | 8 +-
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 2 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 1 +
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 1 +
.../apache/iotdb/commons/path/PartialPathTest.java | 8 +
.../iotdb/library/anomaly/util/MissDetector.java | 56 +-
.../library/anomaly/util/StreamMissDetector.java | 4 +-
.../iotdb/library/anomaly/util/WindowDetect.java | 8 +-
.../library/dquality/util/TimeSeriesQuality.java | 8 +-
.../iotdb/library/frequency/util/DWTUtil.java | 2 +
pom.xml | 39 +-
568 files changed, 3277 insertions(+), 39347 deletions(-)
delete mode 100644 .github/workflows/grafana-plugin.yml
delete mode 100644 distribution/src/assembly/flink-sql-connector.xml
delete mode 100644 distribution/src/assembly/grafana-connector.xml
delete mode 100644 distribution/src/assembly/grafana-plugin.xml
delete mode 100644 distribution/src/assembly/spark-connector.xml
delete mode 100644
docker/src/main/DockerCompose/GrafanaPlugin/Dockerfile-0.14.0-iotdb
delete mode 100644
docker/src/main/DockerCompose/GrafanaPlugin/docker-compose.yml
delete mode 100644 docker/src/main/DockerCompose/docker-compose-grafana.yml
delete mode 100644 docker/src/main/Dockerfile-0.12.6-grafana
delete mode 100644 docker/src/main/Dockerfile-0.13.3-grafana-connector
delete mode 100644 example/flink-sql/pom.xml
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/BatchSinkExample.java
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/BoundedScanExample.java
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/CDCExample.java
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/LookupExample.java
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/StreamingSinkExample.java
delete mode 100644 example/flink/README.md
delete mode 100644 example/flink/pom.xml
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSource.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/TsFileUtils.java
delete mode 100644 example/hadoop/pom.xml
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/Constant.java
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TsFileHelper.java
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TsFileWriteToHDFS.java
delete mode 100644 example/kafka/pom.xml
delete mode 100644 example/kafka/readme.md
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/Constant.java
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/Consumer.java
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/ConsumerThread.java
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/Producer.java
delete mode 100644 example/pulsar/pom.xml
delete mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/Constant.java
delete mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumer.java
delete mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumerThread.java
delete mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarProducer.java
delete mode 100644 example/rabbitmq/pom.xml
delete mode 100644 example/rabbitmq/readme.md
delete mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/Constant.java
delete mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQChannelUtils.java
delete mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQConsumer.java
delete mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQProducer.java
delete mode 100644 example/rocketmq/pom.xml
delete mode 100644 example/rocketmq/readme.md
delete mode 100644
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Constant.java
delete mode 100644
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQConsumer.java
delete mode 100644
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQProducer.java
delete mode 100644
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Utils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBTagLimitIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/flink/it/AbstractTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/flink/it/SinkTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/flink/it/SourceTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/flink/it/Utils.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/spark/it/AbstractTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/spark/it/ReadTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/spark/it/Utils.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/spark/it/WriteTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/zeppelin/it/IoTDBInterpreterIT.java
delete mode 100644 iotdb-client/cli/src/assembly/resources/tools/backup.bat
delete mode 100755 iotdb-client/cli/src/assembly/resources/tools/backup.sh
delete mode 100644 iotdb-connector/flink-iotdb-connector/README.md
delete mode 100644 iotdb-connector/flink-iotdb-connector/pom.xml
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/Event.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBOptions.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSourceOptions.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkInsertTest.java
delete mode 100644 iotdb-connector/flink-sql-iotdb-connector/pom.xml
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/client/IoTDBWebSocketClient.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Options.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Utils.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalIoTDBPathException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalOptionException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalSchemaException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalUrlPathException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/UnsupportedDataTypeException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/factory/IoTDBDynamicTableFactory.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBBoundedScanFunction.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBCDCSourceFunction.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBLookupFunction.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBSinkFunction.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSink.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSource.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/SchemaWrapper.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/TabletWrapper.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 iotdb-connector/flink-tsfile-connector/README.md
delete mode 100644 iotdb-connector/flink-tsfile-connector/pom.xml
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordConverter.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordOutputFormat.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileOutputFormat.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatIntegrationTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileConnectorTestBase.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatIntegrationTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileOutputFormatTestBase.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TSFileConfigUtilCompletenessTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/resources/log4j.properties
delete mode 100644 iotdb-connector/grafana-connector/img/add_data_source.png
delete mode 100644 iotdb-connector/grafana-connector/img/add_graph.png
delete mode 100644 iotdb-connector/grafana-connector/img/edit_data_source.png
delete mode 100644 iotdb-connector/grafana-connector/pom.xml
delete mode 100644 iotdb-connector/grafana-connector/readme.md
delete mode 100644 iotdb-connector/grafana-connector/readme_zh.md
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/conf/MyConfiguration.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/interceptor/LoginInterceptor.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/DatabaseConnectService.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/resources/application.properties
delete mode 100644
iotdb-connector/grafana-connector/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java
delete mode 100644 iotdb-connector/grafana-plugin/.gitignore
delete mode 100644 iotdb-connector/grafana-plugin/.prettierrc.js
delete mode 100644 iotdb-connector/grafana-plugin/CHANGELOG.md
delete mode 100644 iotdb-connector/grafana-plugin/LICENSE
delete mode 100644 iotdb-connector/grafana-plugin/Magefile.go
delete mode 100644 iotdb-connector/grafana-plugin/README.md
delete mode 100644 iotdb-connector/grafana-plugin/backend-compile.bat
delete mode 100755 iotdb-connector/grafana-plugin/backend-compile.sh
delete mode 100644 iotdb-connector/grafana-plugin/go.mod
delete mode 100644 iotdb-connector/grafana-plugin/jest.config.js
delete mode 100644 iotdb-connector/grafana-plugin/package.json
delete mode 100644 iotdb-connector/grafana-plugin/pkg/main.go
delete mode 100644
iotdb-connector/grafana-plugin/pkg/plugin/iotdb_resource_handler.go
delete mode 100644 iotdb-connector/grafana-plugin/pkg/plugin/plugin.go
delete mode 100644 iotdb-connector/grafana-plugin/pom.xml
delete mode 100644 iotdb-connector/grafana-plugin/src/ConfigEditor.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/QueryEditor.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/AggregateFun.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/ControlValue.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/componments/FillValue.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/componments/Form.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/componments/FromValue.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/componments/GroupBy.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/SelectValue.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/TimeSeries.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/WhereValue.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/datasource.ts
delete mode 100644 iotdb-connector/grafana-plugin/src/functions.ts
delete mode 100644
iotdb-connector/grafana-plugin/src/img/addIoTDBDataSource.png
delete mode 100644 iotdb-connector/grafana-plugin/src/img/logo.svg
delete mode 100644 iotdb-connector/grafana-plugin/src/img/showData.png
delete mode 100644 iotdb-connector/grafana-plugin/src/module.ts
delete mode 100644 iotdb-connector/grafana-plugin/src/plugin.json
delete mode 100644 iotdb-connector/grafana-plugin/src/types.ts
delete mode 100644 iotdb-connector/grafana-plugin/tsconfig.json
delete mode 100644 iotdb-connector/grafana-plugin/yarn.lock
delete mode 100644 iotdb-connector/hadoop/README.md
delete mode 100644 iotdb-connector/hadoop/pom.xml
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSFile.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSInput.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSOutput.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/IReaderSet.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopException.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplit.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFOutputFormat.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/record/HDFSTSRecord.java
delete mode 100644
iotdb-connector/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopTest.java
delete mode 100644
iotdb-connector/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplitTest.java
delete mode 100644
iotdb-connector/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TsFileTestHelper.java
delete mode 100644
iotdb-connector/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/constant/TestConstant.java
delete mode 100644 iotdb-connector/hadoop/src/test/resources/logback.xml
delete mode 100644 iotdb-connector/hive-connector/pom.xml
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveInputFormat.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveOutputFormat.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordReader.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordWriter.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileDeserializer.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDe.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDeException.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TSFHiveInputFormatTest.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TSFHiveRecordReaderTest.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TsFileDeserializerTest.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TsFileSerDeTest.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TsFileTestHelper.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/constant/TestConstant.java
delete mode 100644
iotdb-connector/hive-connector/src/test/resources/logback.xml
delete mode 100644 iotdb-connector/pom.xml
delete mode 100644 iotdb-connector/spark-iotdb-connector/pom.xml
delete mode 100644 iotdb-connector/spark-iotdb-connector/scala_2.11/pom.xml
delete mode 100644 iotdb-connector/spark-iotdb-connector/scala_2.12/pom.xml
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/Converter.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/DataFrameTools.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/DefaultSource.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBOptions.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBRDD.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBRelation.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/SQLConstant.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/Transformer.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/package.scala
delete mode 100644 iotdb-connector/spark-tsfile/pom.xml
delete mode 100644
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/io/TsFileOutputFormat.java
delete mode 100644
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/io/TsFileRecordWriter.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/Executor.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/QueryProcessor.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/BasicOperator.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/FilterOperator.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/SQLConstant.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/SingleQuery.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/TSQueryPlan.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/BasicOperatorException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/DNFOptimizeException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/LogicalOptimizeException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/MergeFilterException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/QueryOperatorException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/QueryProcessorException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/RemoveNotException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/DNFFilterOptimizer.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/IFilterOptimizer.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/MergeSingleFilterOptimizer.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/PhysicalOptimizer.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/RemoveNotOptimizer.java
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/Converter.scala
delete mode 100755
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/DefaultSource.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/NarrowConverter.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/NarrowTsFileOutputWriter.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/Transformer.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/TsFileWriterFactory.scala
delete mode 100755
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/WideConverter.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/WideTsFileOutputWriter.scala
delete mode 100755
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/package.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tool/TsFileExample.java
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tool/TsFileWriteTool.java
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tsfile/ConverterTest.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tsfile/HDFSInputTest.java
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tsfile/TSFileSuit.scala
delete mode 100644
iotdb-connector/zeppelin-interpreter/IoTDB-Zeppelin-Demo.zpln
delete mode 100644 iotdb-connector/zeppelin-interpreter/pom.xml
delete mode 100644
iotdb-connector/zeppelin-interpreter/src/main/java/org/apache/zeppelin/iotdb/IoTDBInterpreter.java
delete mode 100644
iotdb-connector/zeppelin-interpreter/src/main/resources/interpreter-setting.json
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/FakeSubscriber.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/LoadManagerTest.java
