You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2023/01/17 14:37:41 UTC
[iotdb] branch Fix-configuration-error updated (a42307af66 -> 5ad67dedf0)
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch Fix-configuration-error
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard a42307af66 Update LoadManager.java
add 5ad67dedf0 [IOTDB-5415] Move parameters into correct ConfigClass (#8867)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (a42307af66)
\
N -- N -- N refs/heads/Fix-configuration-error (5ad67dedf0)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../resources/conf/iotdb-confignode.properties | 8 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 1066 +------
.../confignode/conf/ConfigNodeDescriptor.java | 748 +----
.../confignode/conf/ConfigNodeRemoveCheck.java | 2 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 74 +-
.../confignode/conf/SystemPropertiesUtils.java | 71 +-
.../statemachine/ConfigNodeRegionStateMachine.java | 26 +-
.../confignode/manager/ClusterSchemaManager.java | 21 +-
.../iotdb/confignode/manager/ConfigManager.java | 66 +-
.../iotdb/confignode/manager/ConsensusManager.java | 82 +-
.../iotdb/confignode/manager/ProcedureManager.java | 17 +-
.../confignode/manager/RetryFailedTasksThread.java | 7 +-
.../iotdb/confignode/manager/UDFManager.java | 6 +-
.../iotdb/confignode/manager/load/LoadManager.java | 8 +-
.../manager/load/balancer/RouteBalancer.java | 21 +-
.../partition/GreedyPartitionAllocator.java | 10 +-
.../balancer/router/leader/ILeaderBalancer.java | 3 -
.../manager/node/ClusterNodeStartUtils.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 86 +-
.../manager/partition/PartitionManager.java | 27 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 2 +-
.../confignode/persistence/ProcedureInfo.java | 2 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 9 +-
.../iotdb/confignode/persistence/UDFInfo.java | 9 +-
.../confignode/persistence/node/NodeInfo.java | 6 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 7 +-
.../procedure/env/DataNodeRemoveHandler.java | 14 +-
.../procedure/store/ConfigProcedureStore.java | 2 +-
.../confignode/procedure/store/ProcedureStore.java | 3 +-
.../iotdb/confignode/service/ConfigNode.java | 56 +-
.../service/thrift/ConfigNodeRPCService.java | 10 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 11 +-
.../src/test/resources/iotdb-confignode.properties | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +-
.../util/TSFileConfigUtilCompletenessTest.java | 3 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 2 +-
integration-test/import-control.xml | 3 +-
.../apache/iotdb/db/it/IoTDBRecoverUnclosedIT.java | 8 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 23 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 8 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 2 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 2 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 6 +-
.../iotdb/db/integration/IoTDBMaxTimeQueryIT.java | 19 +-
.../IoTDBMultiOverlappedChunkInUnseqIT.java | 4 +-
.../db/integration/IoTDBMultiOverlappedPageIT.java | 4 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 2 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 155 +-
.../db/integration/IoTDBQueryWithIDTableIT.java | 7 +-
.../db/integration/IoTDBRewriteTsFileToolIT.java | 2 +-
.../db/integration/IoTDBRpcCompressionIT.java | 4 +-
.../db/integration/IoTDBSessionTimeoutIT.java | 4 +-
.../integration/IoTDBSizeTieredCompactionIT.java | 69 +-
.../iotdb/db/integration/IoTDBTimePartitionIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 4 +-
.../db/integration/env/StandaloneEnvConfig.java | 46 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 21 +-
.../sync/IoTDBSyncReceiverLoaderIT.java | 21 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 19 +-
.../IoTDBDeletionVersionAdaptionIT.java | 2 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 2 +-
.../session/IoTDBSessionAlignedAggregationIT.java | 2 +-
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 2 +-
.../resources/conf/iotdb-common.properties | 38 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 4 +-
.../auth/authorizer/LocalFileAuthorizer.java | 2 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 2 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 8 +-
.../iotdb/commons/client/ClientPoolFactory.java | 60 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 2532 +++++++++++++++-
.../iotdb/commons/conf/CommonDescriptor.java | 1903 +++++++++++-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 4 +
.../apache/iotdb/commons/conf/PropertiesUtils.java | 114 +
.../commons/consensus/ConsensusProtocolClass.java | 31 +-
.../commons/enums/HandleSystemErrorStrategy.java | 2 +-
.../iotdb/commons/file/SystemFileFactory.java | 4 +-
.../loadbalance/LeaderDistributionPolicy.java | 22 +-
.../loadbalance}/RegionGroupExtensionPolicy.java | 2 +-
.../iotdb/commons/sync/utils/SyncPathUtil.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 12 +-
.../utils/datastructure/TVListSortAlgorithm.java | 2 +-
.../org/apache/iotdb/commons/wal}/WALMode.java | 2 +-
.../schemaregion/rocksdb/RSchemaConfLoader.java | 6 +-
.../rocksdb/RSchemaReadWriteHandler.java | 5 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 2 +-
.../rocksdb/mnode/RStorageGroupMNode.java | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 2 +-
.../tagSchemaRegion/TagSchemaRegionTest.java | 20 +-
.../idtable/IDTableWithDeviceIDListImplTest.java | 20 +-
.../tagIndex/TagTagInvertedIndexTest.java | 2 +-
.../resources/conf/iotdb-datanode.properties | 5 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 3 +-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 13 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 5 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 2 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 22 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 3164 ++++----------------
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2033 +++----------
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 94 +-
.../iotdb/db/conf/adapter/CompressionRatio.java | 4 +-
.../db/conf/directories/DirectoryManager.java | 20 +-
.../iotdb/db/conf/directories/FolderManager.java | 4 +-
.../directories/strategy/DirectoryStrategy.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 93 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 64 +-
.../statemachine/DataRegionStateMachine.java | 6 +-
.../statemachine/SchemaRegionStateMachine.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 37 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 10 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 6 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 6 +-
.../performer/impl/FastCompactionPerformer.java | 2 +-
.../impl/ReadChunkCompactionPerformer.java | 5 +-
.../impl/ReadPointCompactionPerformer.java | 2 +-
.../execute/recover/CompactionRecoverTask.java | 4 +-
.../execute/task/CrossSpaceCompactionTask.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 2 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 4 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 9 +-
.../execute/utils/log/TsFileIdentifier.java | 2 +-
.../utils/writer/AbstractCompactionWriter.java | 10 +-
.../writer/AbstractCrossCompactionWriter.java | 7 +-
.../writer/AbstractInnerCompactionWriter.java | 7 +-
.../compaction/schedule/CompactionScheduler.java | 8 +-
.../compaction/schedule/CompactionTaskManager.java | 12 +-
.../DefaultCompactionTaskComparatorImpl.java | 2 +-
.../estimator/InplaceCompactionEstimator.java | 2 +-
.../ReadPointCrossCompactionEstimator.java | 2 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 14 +-
.../impl/SizeTieredCompactionSelector.java | 2 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 2 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 16 +-
.../db/engine/flush/pool/FlushTaskPoolManager.java | 6 +-
.../iotdb/db/engine/load/LoadTsFileManager.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 4 +-
.../apache/iotdb/db/engine/settle/SettleLog.java | 4 +-
.../db/engine/settle/SettleRequestHandler.java | 2 +-
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 10 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 56 +-
.../db/engine/storagegroup/DataRegionInfo.java | 8 +-
.../engine/storagegroup/TimePartitionManager.java | 4 +-
.../db/engine/storagegroup/TsFileProcessor.java | 15 +-
.../db/engine/storagegroup/TsFileResource.java | 2 +-
.../db/engine/trigger/utils/BatchHandlerQueue.java | 9 +-
.../engine/trigger/utils/HTTPConnectionPool.java | 6 +-
.../engine/trigger/utils/MQTTConnectionPool.java | 4 +-
.../apache/iotdb/db/engine/upgrade/UpgradeLog.java | 5 +-
.../exception/sql/PathNumOverLimitException.java | 4 +-
.../metadata/cache/DataNodeLastCacheManager.java | 4 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 8 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 2 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 2 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 2 +-
.../db/metadata/idtable/entry/DeviceIDFactory.java | 8 +-
.../db/metadata/idtable/entry/SchemaEntry.java | 2 +-
.../metadata/mnode/container/MNodeContainers.java | 2 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 2 +-
.../db/metadata/mtree/store/MemMTreeStore.java | 2 +-
.../store/disk/memcontrol/MemManagerHolder.java | 2 +-
.../memcontrol/MemManagerNodeNumBasedImpl.java | 2 +-
.../store/disk/schemafile/MockSchemaFile.java | 2 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 4 +-
.../store/disk/schemafile/SchemaFileConfig.java | 12 +-
.../iotdb/db/metadata/rescon/MemoryStatistics.java | 4 +-
.../db/metadata/rescon/SchemaResourceManager.java | 4 +-
.../db/metadata/schemaregion/SchemaEngine.java | 14 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 25 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 20 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 6 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 24 +-
.../iotdb/db/mpp/common/DataNodeEndPoints.java | 8 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 2 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 4 +-
.../iotdb/db/mpp/execution/QueryIdGenerator.java | 2 +-
.../execution/exchange/MPPDataExchangeService.java | 20 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 4 +-
.../db/mpp/execution/exchange/SinkHandle.java | 4 +-
.../db/mpp/execution/exchange/SourceHandle.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 33 +-
.../fragment/FragmentInstanceManager.java | 6 +-
.../mpp/execution/memory/LocalMemoryManager.java | 6 +-
.../operator/process/AbstractIntoOperator.java | 4 +-
.../operator/process/TransformOperator.java | 8 +-
.../operator/process/last/LastQueryUtil.java | 4 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 8 +-
.../mpp/execution/schedule/DriverTaskThread.java | 4 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 14 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 11 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 20 +-
.../plan/analyze/ColumnPaginationController.java | 7 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 8 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 10 +-
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../mpp/plan/execution/config/ConfigExecution.java | 2 +-
.../config/metadata/GetTimeSlotListTask.java | 2 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 30 +-
.../plan/planner/LocalExecutionPlanContext.java | 4 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 6 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 8 +-
.../SimpleFragmentParallelPlanner.java | 4 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 8 +-
.../plan/node/load/LoadSingleTsFileNode.java | 4 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 4 +-
.../plan/planner/plan/node/write/InsertNode.java | 9 +-
.../planner/plan/node/write/InsertRowNode.java | 6 +-
.../scheduler/AbstractFragInsStateTracker.java | 4 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 4 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 11 +-
.../plan/statement/crud/LoadTsFileStatement.java | 6 +-
.../metadata/CreateContinuousQueryStatement.java | 6 +-
.../datastructure/SerializableList.java | 4 +-
.../influxdb/handler/QueryHandlerFactory.java | 4 +-
.../influxdb/meta/InfluxDBMetaManagerFactory.java | 4 +-
.../influxdb/parser/InfluxDBAstVisitor.java | 6 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 9 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 2 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 8 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 6 +-
.../iotdb/db/query/control/SessionManager.java | 2 +-
.../apache/iotdb/db/rescon/MemTableManager.java | 17 +-
.../iotdb/db/rescon/PrimitiveArrayManager.java | 16 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 33 +-
.../iotdb/db/rescon/TsFileResourceManager.java | 8 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 118 +-
.../db/service/DataNodeInternalRPCService.java | 8 +-
.../org/apache/iotdb/db/service/GetVersion.java | 2 +-
.../iotdb/db/service/InfluxDBRPCService.java | 21 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 13 +-
.../org/apache/iotdb/db/service/MQTTService.java | 24 +-
.../org/apache/iotdb/db/service/RPCService.java | 16 +-
.../org/apache/iotdb/db/service/SettleService.java | 2 +-
.../db/service/TemporaryQueryDataFileService.java | 2 +-
.../org/apache/iotdb/db/service/UpgradeSevice.java | 4 +-
.../db/service/basic/QueryFrequencyRecorder.java | 4 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 2 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 32 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 22 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 2 +-
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 4 +-
.../sync/externalpipe/ExtPipePluginRegister.java | 2 +-
.../db/sync/pipedata/load/DeletionLoader.java | 5 +-
.../iotdb/db/sync/pipedata/load/TsFileLoader.java | 4 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 6 +-
.../db/sync/transport/server/ReceiverManager.java | 17 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 4 +-
.../watermark/GroupedLSBWatermarkEncoder.java | 12 +-
.../db/trigger/executor/TriggerFireVisitor.java | 4 +-
.../trigger/service/TriggerClassLoaderManager.java | 10 +-
.../trigger/service/TriggerManagementService.java | 2 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 11 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 6 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 8 +-
.../apache/iotdb/db/utils/TimePartitionUtils.java | 2 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 12 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 6 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 54 +-
.../allocation/AbstractNodeAllocationStrategy.java | 8 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 14 +-
.../apache/iotdb/db/wal/buffer/WALInfoEntry.java | 8 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 10 +-
.../java/org/apache/iotdb/db/wal/io/WALReader.java | 4 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 15 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 11 +-
.../iotdb/db/wal/recover/WALRecoverManager.java | 9 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 4 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 2 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 2 +-
.../db/auth/user/LocalFileUserManagerTest.java | 2 +-
.../db/conf/adapter/CompressionRatioTest.java | 5 +-
.../engine/compaction/AbstractCompactionTest.java | 20 +-
.../engine/compaction/CompactionSchedulerTest.java | 404 ++-
.../CompactionSchedulerWithFastPerformerTest.java | 404 ++-
.../compaction/CompactionTaskComparatorTest.java | 2 +-
.../compaction/FastAlignedCrossCompactionTest.java | 6 +-
.../FastCrossCompactionPerformerTest.java | 4 +-
.../FastInnerCompactionPerformerTest.java | 4 +-
.../FastNonAlignedCrossCompactionTest.java | 6 +-
.../ReadPointCompactionPerformerTest.java | 4 +-
.../db/engine/compaction/TsFileIdentifierUT.java | 8 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 2 +-
...eCompactionWithFastPerformerValidationTest.java | 14 +-
...actionWithReadPointPerformerValidationTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 32 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 2 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 2 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 2 +-
.../FastCompactionPerformerNoAlignedTest.java | 204 +-
.../inner/InnerCompactionSchedulerTest.java | 42 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 37 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 37 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 204 +-
.../SizeTieredCompactionSelectorTest.java | 4 +-
.../recover/SizeTieredCompactionRecoverTest.java | 6 +-
.../compaction/utils/CompactionClearUtils.java | 4 +-
.../compaction/utils/CompactionConfigRestorer.java | 8 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 2 +-
.../db/engine/settle/SettleRequestHandlerTest.java | 2 +-
.../db/engine/snapshot/IoTDBSnapshotTest.java | 22 +-
.../db/engine/storagegroup/DataRegionTest.java | 99 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 8 +-
.../storagegroup/TimePartitionManagerTest.java | 8 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 2 +-
.../mtree/multimode/MTreeDiskModeTest.java | 6 +-
.../mtree/multimode/MTreeFullMemoryTest.java | 2 +-
.../mtree/multimode/MTreeMemoryModeTest.java | 4 +-
.../mtree/multimode/MTreeNonMemoryTest.java | 2 +-
.../mtree/multimode/MTreePartialMemoryTest.java | 2 +-
.../mtree/schemafile/AliasIndexPageTest.java | 6 +-
.../mtree/schemafile/InternalPageTest.java | 6 +-
.../mtree/schemafile/SchemaFileLogTest.java | 6 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 6 +-
.../mtree/schemafile/WrappedSegmentTest.java | 6 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 4 +-
.../schemaRegion/SchemaRegionManagementTest.java | 31 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 8 +-
.../mpp/execution/exchange/SourceHandleTest.java | 19 +-
.../execution/operator/MergeSortOperatorTest.java | 6 +-
.../execution/schedule/DriverSchedulerTest.java | 4 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 15 +-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 18 +-
.../mpp/plan/analyze/QueryTimePartitionTest.java | 58 +-
.../mpp/plan/analyze/cache/PartitionCacheTest.java | 8 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 6 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 14 +-
.../plan/node/write/WritePlanNodeSplitTest.java | 11 +-
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 12 +-
.../db/query/control/FileReaderManagerTest.java | 2 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 11 +-
.../security/encrypt/MessageDigestEncryptTest.java | 2 +-
.../DataNodeInternalRPCServiceImplTest.java | 15 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 2 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 6 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 8 +-
.../iotdb/db/utils/EncodingInferenceUtilsTest.java | 6 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 62 +-
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 24 +-
.../datastructure/PrimitiveArrayManagerTest.java | 19 +-
.../org/apache/iotdb/db/wal/DisableWALTest.java | 8 +-
.../org/apache/iotdb/db/wal/WALManagerTest.java | 10 +-
.../db/wal/allocation/ElasticStrategyTest.java | 12 +-
.../db/wal/allocation/FirstCreateStrategyTest.java | 12 +-
.../db/wal/allocation/RoundRobinStrategyTest.java | 11 +-
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 12 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 2 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 6 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 18 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 20 +-
.../db/wal/recover/WALRecoverManagerTest.java | 22 +-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 15 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 2 +-
.../src/test/resources/iotdb-datanode.properties | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 24 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 54 +-
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 2 -
.../file/metadata/enums/CompressionType.java | 28 +
.../tsfile/file/metadata/enums/TSEncoding.java | 29 +
361 files changed, 8418 insertions(+), 8631 deletions(-)
copy server/src/main/resources/META-INF/services/org.apache.iotdb.db.protocol.mqtt.PayloadFormatter => confignode/src/test/resources/iotdb-confignode.properties (90%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/conf/PropertiesUtils.java
copy confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/RegionGroupExtensionPolicy.java => node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConsensusProtocolClass.java (51%)
copy confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/RegionGroupExtensionPolicy.java => node-commons/src/main/java/org/apache/iotdb/commons/loadbalance/LeaderDistributionPolicy.java (63%)
rename {confignode/src/main/java/org/apache/iotdb/confignode/manager/partition => node-commons/src/main/java/org/apache/iotdb/commons/loadbalance}/RegionGroupExtensionPolicy.java (96%)
rename {server/src/main/java/org/apache/iotdb/db => node-commons/src/main/java/org/apache/iotdb/commons}/utils/datastructure/TVListSortAlgorithm.java (94%)
rename {server/src/main/java/org/apache/iotdb/db/wal/utils => node-commons/src/main/java/org/apache/iotdb/commons/wal}/WALMode.java (96%)