You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by er...@apache.org on 2023/01/05 09:44:40 UTC
[iotdb] branch improve/iotdb-5803 updated (75d2b884dc -> cc2413fb6d)
This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch improve/iotdb-5803
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 75d2b884dc [IOTDB-5303] Refine IT config: part I
add 2f8abb245c [IOTDB-5284] Fix some code smells (#8730)
add 5a40a19ed4 [IOTDB-5284] Fix some iotdb-server code smells (#8754)
add 22bd622a57 [IOTDB-5284] Fix some code smells (#8751)
add 621e036983 [IOTDB-5284] Fix some iotdb-server code smells (#8743)
add a1c29277ac [IOTDB-5284] Fix some iotdb-server code smells (#8738)
add cc2413fb6d [IOTDB-5303] Refine IT config: part I
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 (75d2b884dc)
\
N -- N -- N refs/heads/improve/iotdb-5803 (cc2413fb6d)
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:
.../commons/auth/authorizer/BasicAuthorizer.java | 2 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 2 ++
.../apache/iotdb/commons/conf/IoTDBConstant.java | 17 +++++++--------
.../iotdb/commons/partition/DataPartition.java | 2 +-
.../apache/iotdb/commons/partition/Partition.java | 2 +-
.../partition/executor/hash/BKDRHashExecutor.java | 4 ++--
.../partition/executor/hash/JSHashExecutor.java | 4 ++--
.../fa/dfa/transition/AbstractDFATransition.java | 2 +-
.../security/encrypt/MessageDigestEncrypt.java | 4 +---
.../service/AbstractThriftServiceThread.java | 4 ++--
.../apache/iotdb/commons/sync/pipe/PipeInfo.java | 4 ++--
.../iotdb/commons/sync/pipesink/IoTDBPipeSink.java | 2 +-
.../apache/iotdb/commons/udf/utils/KDTreeUtil.java | 10 ++++-----
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 2 +-
.../commons/utils/BasicStructureSerDeUtil.java | 4 ++--
.../org/apache/iotdb/commons/utils/FileUtils.java | 4 ++--
.../apache/iotdb/commons/utils/SerializeUtils.java | 13 ++++++++++-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 8 +++----
.../apache/iotdb/db/client/ConfigNodeClient.java | 4 ++--
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 14 ++++++------
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 4 ++--
.../apache/iotdb/db/engine/cache/ChunkCache.java | 4 ++--
.../db/engine/cache/TimeSeriesMetadataCache.java | 2 +-
.../exception/CompactionExceptionHandler.java | 2 +-
.../performer/ICrossCompactionPerformer.java | 1 +
.../execute/performer/ISeqCompactionPerformer.java | 1 +
.../performer/IUnseqCompactionPerformer.java | 1 +
.../performer/impl/FastCompactionPerformer.java | 8 +++----
.../impl/ReadChunkCompactionPerformer.java | 2 +-
.../impl/ReadPointCompactionPerformer.java | 10 ++++-----
.../execute/recover/CompactionRecoverTask.java | 5 +----
.../execute/task/InnerSpaceCompactionTask.java | 2 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 6 +++---
.../fast/AlignedSeriesCompactionExecutor.java | 2 +-
.../executor/fast/SeriesCompactionExecutor.java | 18 ++++++----------
.../readchunk/SingleSeriesCompactionExecutor.java | 5 +++--
.../writer/AbstractCrossCompactionWriter.java | 2 +-
.../writer/AbstractInnerCompactionWriter.java | 2 +-
.../compaction/selector/ICrossSpaceSelector.java | 1 +
.../selector/IInnerSeqSpaceSelector.java | 1 +
.../selector/IInnerUnseqSpaceSelector.java | 1 +
.../impl/RewriteCrossSpaceCompactionSelector.java | 7 +++---
.../iotdb/db/engine/load/LoadTsFileManager.java | 12 +++++------
.../modification/utils/TracedBufferedReader.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../engine/trigger/sink/forward/ForwardEvent.java | 1 +
.../db/engine/trigger/utils/BatchHandlerQueue.java | 1 +
.../schemafile/RecordDuplicatedException.java | 2 +-
.../schemafile/SegmentOverflowException.java | 9 +++-----
.../template/DifferentTemplateException.java | 2 +-
.../template/NoTemplateOnMNodeException.java | 2 +-
.../template/UndefinedTemplateException.java | 2 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 2 ++
.../db/metadata/cache/DataNodeSchemaCache.java | 1 -
.../idtable/AppendOnlyDiskSchemaManager.java | 6 +++---
.../apache/iotdb/db/metadata/idtable/IDTable.java | 2 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 2 +-
.../metadata/mnode/container/MNodeContainers.java | 7 ++++++
.../db/metadata/mtree/store/CachedMTreeStore.java | 18 ++++++----------
.../mtree/store/disk/cache/CacheManager.java | 6 ++----
.../disk/memcontrol/CachedMNodeSizeEstimator.java | 1 +
.../store/disk/schemafile/AliasIndexPage.java | 2 +-
.../mtree/store/disk/schemafile/InternalPage.java | 2 +-
.../store/disk/schemafile/MockSchemaFile.java | 12 +++++------
.../mtree/store/disk/schemafile/SchemaFile.java | 3 +--
.../mtree/store/disk/schemafile/SchemaPage.java | 4 ++--
.../mtree/store/disk/schemafile/Segment.java | 2 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 6 +++---
.../disk/schemafile/pagemgr/BTreePageManager.java | 12 +++++------
.../store/disk/schemafile/pagemgr/PageManager.java | 2 +-
.../db/metadata/mtree/traverser/Traverser.java | 3 ++-
.../mtree/traverser/collector/EntityCollector.java | 4 ++--
.../traverser/collector/MNodeAboveSGCollector.java | 2 +-
.../mtree/traverser/collector/MNodeCollector.java | 2 +-
.../traverser/collector/MeasurementCollector.java | 6 +++---
.../traverser/collector/StorageGroupCollector.java | 2 +-
.../mtree/traverser/counter/CounterTraverser.java | 2 +-
.../counter/MeasurementGroupByLevelCounter.java | 6 ++----
.../impl/read/AbstractShowSchemaPlanImpl.java | 2 +-
.../plan/schemaregion/result/ShowSchemaResult.java | 4 ++--
.../db/metadata/schemaregion/SchemaEngine.java | 8 +++----
.../schemaregion/SchemaRegionSchemaFileImpl.java | 3 +--
.../metadata/template/ClusterTemplateManager.java | 2 +-
.../iotdb/db/metadata/template/Template.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 1 +
.../mpp/aggregation/FirstValueDescAccumulator.java | 6 ++++++
.../mpp/aggregation/LastValueDescAccumulator.java | 6 ++++++
.../slidingwindow/SlidingWindowAggregator.java | 2 +-
.../SlidingWindowAggregatorFactory.java | 11 ++++++----
.../iotdb/db/mpp/common/header/DatasetHeader.java | 2 +-
.../common/schematree/node/SchemaInternalNode.java | 1 +
.../db/mpp/common/schematree/node/SchemaNode.java | 2 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 2 +-
.../fragment/FragmentInstanceContext.java | 1 +
.../operator/process/AbstractIntoOperator.java | 8 ++++---
.../process/SingleInputAggregationOperator.java | 2 +-
.../operator/process/TransformOperator.java | 6 +-----
.../process/join/RowBasedTimeJoinOperator.java | 2 +-
.../operator/process/join/TimeJoinOperator.java | 2 +-
.../process/join/VerticallyConcatOperator.java | 2 +-
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 5 +----
.../AbstractSeriesAggregationScanOperator.java | 2 +-
.../execution/schedule/AbstractDriverThread.java | 11 +++++-----
.../db/mpp/execution/schedule/DriverScheduler.java | 2 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 2 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 4 ++--
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 5 +----
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 6 +++---
.../db/mpp/plan/analyze/cache/PartitionCache.java | 6 +++---
.../analyze/cache/StorageGroupCacheResult.java | 2 +-
.../db/mpp/plan/execution/QueryExecution.java | 6 ++----
.../plan/expression/ternary/BetweenExpression.java | 1 +
.../visitor/ColumnTransformerVisitor.java | 25 +++++++++++-----------
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 11 +++++-----
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 10 ++++-----
.../db/mpp/plan/planner/SubPlanTypeExtractor.java | 5 +++++
.../SimpleFragmentParallelPlanner.java | 4 ++--
.../plan/planner/distribution/SourceRewriter.java | 2 +-
.../iotdb/db/mpp/plan/planner/plan/SubPlan.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 13 ++++++-----
.../db/mpp/plan/planner/plan/node/PlanNode.java | 2 +-
.../metedata/read/AbstractSchemaMergeNode.java | 4 ++--
.../metedata/read/PathsUsingTemplateScanNode.java | 2 ++
.../node/metedata/read/SchemaFetchMergeNode.java | 1 +
.../node/metedata/read/SchemaQueryMergeNode.java | 1 +
.../write/CreateAlignedTimeSeriesNode.java | 1 +
.../metedata/write/CreateMultiTimeSeriesNode.java | 1 +
.../node/metedata/write/CreateTimeSeriesNode.java | 1 +
.../plan/node/process/MultiChildProcessNode.java | 4 ++--
.../planner/plan/node/process/ProcessNode.java | 2 +-
.../plan/node/process/SingleChildProcessNode.java | 4 ++--
.../node/process/last/LastQueryCollectNode.java | 1 +
.../plan/node/process/last/LastQueryMergeNode.java | 1 +
.../plan/node/process/last/LastQueryNode.java | 1 +
.../mpp/plan/planner/plan/node/sink/SinkNode.java | 2 +-
.../source/AlignedSeriesAggregationScanNode.java | 3 +++
.../node/source/SeriesAggregationScanNode.java | 3 +++
.../node/source/SeriesAggregationSourceNode.java | 2 +-
.../planner/plan/node/source/SeriesSourceNode.java | 2 +-
.../CrossSeriesAggregationDescriptor.java | 1 +
.../plan/planner/plan/parameter/OutputColumn.java | 2 +-
.../scheduler/AbstractFragInsStateTracker.java | 2 +-
.../scheduler/FixedRateFragInsStateTracker.java | 4 ++--
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 18 +++++++---------
.../plan/statement/component/IntoComponent.java | 8 +++----
.../crud/InsertMultiTabletsStatement.java | 1 +
.../plan/statement/crud/InsertRowStatement.java | 1 +
.../crud/InsertRowsOfOneDeviceStatement.java | 3 ++-
.../plan/statement/crud/InsertRowsStatement.java | 1 +
.../plan/statement/crud/InsertTabletStatement.java | 1 +
.../iotdb/db/mpp/statistics/StatisticsManager.java | 2 +-
.../dag/column/ColumnTransformer.java | 2 +-
.../binary/ArithmeticBinaryColumnTransformer.java | 2 +-
.../dag/column/binary/BinaryColumnTransformer.java | 2 +-
.../binary/CompareBinaryColumnTransformer.java | 2 +-
.../binary/LogicBinaryColumnTransformer.java | 2 +-
.../dag/column/leaf/LeafColumnTransformer.java | 2 +-
.../ternary/CompareTernaryColumnTransformer.java | 4 ++--
.../column/ternary/TernaryColumnTransformer.java | 2 +-
.../dag/column/unary/UnaryColumnTransformer.java | 2 +-
.../dag/transformer/unary/UnaryTransformer.java | 2 +-
.../protocol/influxdb/function/InfluxFunction.java | 4 ++--
.../function/aggregator/InfluxAggregator.java | 2 +-
.../function/aggregator/InfluxMeanFunction.java | 2 +-
.../function/aggregator/InfluxStddevFunction.java | 3 +--
.../function/aggregator/InfluxSumFunction.java | 2 +-
.../influxdb/function/selector/InfluxSelector.java | 2 +-
.../influxdb/handler/AbstractQueryHandler.java | 6 +++---
.../protocol/influxdb/handler/NewQueryHandler.java | 5 +++--
.../protocol/influxdb/handler/TagQueryHandler.java | 2 +-
.../influxdb/statement/InfluxSelectComponent.java | 1 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 2 +-
.../iotdb/db/query/control/FileReaderManager.java | 2 +-
.../iotdb/db/query/control/QueryFileManager.java | 8 +++----
.../db/service/DataNodeServerCommandLine.java | 2 +-
.../org/apache/iotdb/db/service/SettleService.java | 5 ++---
.../service/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 15 ++++++-------
.../iotdb/db/sync/datasource/AbstractOpBlock.java | 2 +-
.../iotdb/db/sync/datasource/PipeOpManager.java | 8 +++----
.../iotdb/db/sync/datasource/PipeOpSgManager.java | 6 +-----
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 10 ++++-----
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 4 ++--
.../db/sync/externalpipe/ExtPipePluginManager.java | 4 ++--
.../db/sync/externalpipe/operation/Operation.java | 2 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 1 +
.../apache/iotdb/db/sync/pipedata/PipeData.java | 4 ++--
.../db/sync/pipedata/load/DeletionLoader.java | 4 ++--
.../iotdb/db/sync/pipedata/load/TsFileLoader.java | 5 ++---
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 2 +-
.../db/sync/sender/pipe/ExternalPipeSink.java | 2 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 2 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 2 +-
.../db/sync/transport/client/SenderManager.java | 2 +-
.../db/sync/transport/server/ReceiverManager.java | 4 ++--
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 2 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 6 +++---
.../db/tools/validate/TsFileValidationTool.java | 2 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 2 +-
.../db/trigger/executor/TriggerFireVisitor.java | 19 ++++++++--------
.../trigger/service/TriggerInformationUpdater.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 4 ++--
.../datastructure/FixedPriorityBlockingQueue.java | 4 ++--
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../allocation/AbstractNodeAllocationStrategy.java | 2 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 4 +++-
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 2 +-
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 2 ++
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 2 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../wal/utils/listener/AbstractResultListener.java | 2 +-
218 files changed, 443 insertions(+), 411 deletions(-)