This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira5389
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard e59db0ef93 finish
add c085fb1a8c [IOTDB-4005] Pipeline fragmentInstance to implement
parallel execution
add 27549169a3 [IOTDB-5384] add
core_client_count_for_each_node_in_client_manager and
max_client_count_for_each_node_in_client_manager parameters for confignode and
datanode （#8800）
add a1cc705fdd [IOTDB-5387] Refine IT: Make JVM parameters mutable easily
(#8795)
add 7b1977330a [IOTDB-5328] Rename "REMOVE_DATANODE_PROCESS" in
MIGRATE_REGION_PROCEDURE to "REGION_MIGRATE_PROCESS" (#8790)
add 76d3a13e29 Eliminate LocalSchemaProcessor and stale code (#8802)
add 4dcaf696d5 Eliminate LocalConfigNode and Fix NPE while forceMLog
(#8804)
add dfb013b710 Separate SYNC_CONNECTION_ERROR and DISPATCH_ERROR (#8726)
add 8e40479c42 [IOTDB-5288][IOTDB-5163] Fix the file metrics is wrong
(#8805)
add 5ad3384f0f Change config in SourceHandleTest according to
IoTDBDescriptor
add 44fb69a7ff Fix wal manager test (#8808)
add a794c438d9 Jenkins disable integration (#8787)
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 (e59db0ef93)
\
N -- N -- N refs/heads/jira5389 (a794c438d9)
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:
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 +
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../procedure/env/DataNodeRemoveHandler.java | 15 +-
.../impl/statemachine/RegionMigrateProcedure.java | 15 +-
docs/UserGuide/Reference/Status-Codes.md | 15 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 249 +++++------
.../apache/iotdb/it/env/cluster/AbstractEnv.java | 15 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 36 +-
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 19 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 9 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 25 +-
.../iotdb/it/env/cluster/MppClusterConfig.java | 15 +
.../apache/iotdb/it/env/cluster/MppJVMConfig.java | 116 +++++
.../iotdb/it/env/remote/RemoteClusterConfig.java | 12 +
.../iotdb/it/env/remote/RemoteJVMConfig.java | 23 +-
.../org/apache/iotdb/itbase/env/ClusterConfig.java | 30 +-
.../org/apache/iotdb/itbase/env/JVMConfig.java | 33 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 6 +-
.../it/cluster/IoTDBClusterRestartIT.java | 3 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 3 -
.../apache/iotdb/commons/utils/StatusUtils.java | 4 +-
.../resources/conf/iotdb-datanode.properties | 9 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 -
.../execute/task/CrossSpaceCompactionTask.java | 27 +-
.../execute/task/InnerSpaceCompactionTask.java | 29 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 294 -------------
.../db/localconfignode/LocalDataPartitionInfo.java | 111 -----
.../localconfignode/LocalDataPartitionTable.java | 127 ------
.../localconfignode/LocalSchemaPartitionTable.java | 122 ------
.../iotdb/db/metadata/LocalSchemaProcessor.java | 250 -----------
.../iotdb/db/metadata/mtree/ConfigMTree.java | 21 -
.../db/metadata/schemaregion/SchemaEngine.java | 3 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 5 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 13 +-
.../storagegroup/IStorageGroupSchemaManager.java | 53 ---
.../storagegroup/StorageGroupSchemaManager.java | 78 ----
.../iotdb/db/mpp/execution/StateMachine.java | 4 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 37 +-
.../db/mpp/execution/driver/DataDriverContext.java | 48 ++-
.../iotdb/db/mpp/execution/driver/Driver.java | 34 +-
.../db/mpp/execution/driver/DriverContext.java | 76 +++-
.../iotdb/db/mpp/execution/driver/IDriver.java | 5 +-
.../db/mpp/execution/driver/SchemaDriver.java | 5 +-
.../mpp/execution/driver/SchemaDriverContext.java | 13 +-
.../exchange/IMPPDataExchangeManager.java | 4 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 25 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 27 +-
.../execution/exchange/MPPDataExchangeManager.java | 113 ++++-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 5 +
.../db/mpp/execution/exchange/SinkHandle.java | 2 +-
.../db/mpp/execution/exchange/SourceHandle.java | 2 +-
.../fragment/FragmentInstanceContext.java | 127 +++---
.../fragment/FragmentInstanceExecution.java | 25 +-
.../fragment/FragmentInstanceManager.java | 37 +-
.../db/mpp/execution/operator/OperatorContext.java | 32 +-
.../OperatorFactory.java} | 19 +-
.../SourceOperatorFactory.java} | 17 +-
.../operator/process/join/TimeJoinOperator.java | 1 -
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelScanOperator.java | 3 +-
.../operator/schema/SchemaCountOperator.java | 3 +-
.../operator/schema/SchemaQueryScanOperator.java | 5 +-
.../operator/source/AlignedSeriesScanUtil.java | 3 +-
.../operator/source/ExchangeOperator.java | 4 +
.../operator/source/SeriesScanOperator.java | 76 +++-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../execution/schedule/AbstractDriverThread.java | 9 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 143 ++++---
...eption.java => DriverTaskAbortedException.java} | 8 +-
.../mpp/execution/schedule/DriverTaskThread.java | 12 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../mpp/execution/schedule/IDriverScheduler.java | 7 +-
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 3 +-
.../execution/schedule/queue/L1PriorityQueue.java | 10 +-
.../execution/schedule/queue/L2PriorityQueue.java | 16 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 44 +-
.../task/{DriverTaskID.java => DriverTaskId.java} | 49 ++-
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 81 ++--
.../plan/planner/LocalExecutionPlanContext.java | 175 +++++---
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 100 ++---
.../plan/planner/MemoryDistributionCalculator.java | 472 ---------------------
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 269 +++++++-----
.../db/mpp/plan/planner/PipelineDriverFactory.java | 59 +++
.../db/mpp/plan/scheduler/ClusterScheduler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 158 -------
.../compaction/TestUtilsForAlignedSeries.java | 42 +-
.../db/engine/compaction/cross/MergeTest.java | 19 -
.../inner/AbstractInnerSpaceCompactionTest.java | 19 -
.../inner/FastCompactionPerformerAlignedTest.java | 3 -
...nerSeqCompactionWithReadChunkPerformerTest.java | 17 -
...rUnseqCompactionWithReadPointPerformerTest.java | 19 -
.../ReadChunkCompactionPerformerAlignedTest.java | 3 -
.../inner/sizetiered/SizeTieredCompactionTest.java | 19 -
.../recover/SizeTieredCompactionRecoverTest.java | 16 -
.../db/engine/memtable/MemTableFlushTaskTest.java | 2 -
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 6 -
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 12 -
.../iotdb/db/mpp/execution/DataDriverTest.java | 52 +--
.../execution/exchange/LocalSinkHandleTest.java | 26 +-
.../execution/exchange/LocalSourceHandleTest.java | 12 +-
.../exchange/MPPDataExchangeManagerTest.java | 8 +-
.../mpp/execution/exchange/SourceHandleTest.java | 82 ++--
.../operator/AggregationOperatorTest.java | 17 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 9 +-
.../operator/AlignedSeriesScanOperatorTest.java | 92 ++--
.../execution/operator/AlignedSeriesTestUtil.java | 53 ---
.../operator/DeviceMergeOperatorTest.java | 77 ++--
.../execution/operator/DeviceViewOperatorTest.java | 16 +-
.../mpp/execution/operator/FillOperatorTest.java | 17 +-
.../operator/LastQueryMergeOperatorTest.java | 25 +-
.../execution/operator/LastQueryOperatorTest.java | 49 +--
.../operator/LastQuerySortOperatorTest.java | 49 +--
.../mpp/execution/operator/LimitOperatorTest.java | 22 +-
.../execution/operator/LinearFillOperatorTest.java | 57 +--
.../execution/operator/MergeSortOperatorTest.java | 205 ++++-----
.../mpp/execution/operator/OffsetOperatorTest.java | 73 ++--
.../mpp/execution/operator/OperatorMemoryTest.java | 46 +-
.../operator/RawDataAggregationOperatorTest.java | 22 +-
.../SeriesAggregationScanOperatorTest.java | 8 +-
.../execution/operator/SeriesScanOperatorTest.java | 8 +-
.../operator/SingleDeviceViewOperatorTest.java | 20 +-
.../SlidingWindowAggregationOperatorTest.java | 12 +-
.../execution/operator/TimeJoinOperatorTest.java | 56 ++-
.../operator/UpdateLastCacheOperatorTest.java | 13 +-
.../operator/VerticallyConcatOperatorTest.java | 14 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 15 +-
.../operator/schema/SchemaCountOperatorTest.java | 23 +-
.../schema/SchemaQueryScanOperatorTest.java | 25 +-
.../schedule/DefaultDriverSchedulerTest.java | 166 +++++---
.../execution/schedule/DriverSchedulerTest.java | 45 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 23 +-
.../schedule/queue/L1PriorityQueueTest.java | 6 +-
.../schedule/queue/L2PriorityQueueTest.java | 12 +-
.../mpp/execution/schedule/queue/QueueElement.java | 4 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 19 -
.../DataNodeInternalRPCServiceImplTest.java | 11 +-
.../db/sync/datasource/PipeOpManagerTest.java | 3 -
.../apache/iotdb/db/utils/EnvironmentUtils.java | 7 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 22 +-
.../db/wal/recover/WALRecoverManagerTest.java | 32 --
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 53 ---
.../file/UnsealedTsFileRecoverPerformerTest.java | 31 --
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../apache/iotdb/spark/db/EnvironmentUtils.java | 3 -
150 files changed, 2339 insertions(+), 3673 deletions(-)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppJVMConfig.java
copy service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java =>
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteJVMConfig.java
(70%)
copy
server/src/main/java/org/apache/iotdb/db/sync/transport/client/ISyncClient.java
=> integration-test/src/main/java/org/apache/iotdb/itbase/env/JVMConfig.java
(55%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionTable.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalSchemaPartitionTable.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/LocalSchemaProcessor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/IStorageGroupSchemaManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupSchemaManager.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/{source/SourceOperator.java
=> factory/OperatorFactory.java} (62%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/{source/SourceOperator.java
=> factory/SourceOperatorFactory.java} (65%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/{FragmentInstanceAbortedException.java
=> DriverTaskAbortedException.java} (82%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/{DriverTaskID.java
=> DriverTaskId.java} (56%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/PipelineDriverFactory.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/MetadataManagerHelper.java
