You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/04/14 14:06:09 UTC
[iotdb] branch ty-mpp updated (c78903f18c -> 145d367478)
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch ty-mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c78903f18c fix settle
add 10b40e7238 tmp save
add 1efdab36b5 Add getSeriesPartitionExecutor() in node-commons (#5528)
add 64e3121e89 Merge branch 'master' into ty-mpp
add b6de888bea tmp save
add 91dad5be71 fix DataRegionId directory name bug (#5547)
add 10db609088 Merge branch 'master' into ty-mpp
add 145d367478 1-2
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/manager/PartitionManager.java | 22 ++------
.../persistence/PartitionInfoPersistence.java | 15 ++++--
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../iotdb/commons/partition/DataPartition.java | 31 ++++++++----
.../iotdb/commons/partition/SchemaPartition.java | 45 ++++++++++++++---
.../executor/SeriesPartitionExecutor.java | 19 +++++++
.../apache/iotdb/commons/service/ServiceType.java | 3 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 17 +++----
.../iotdb/db/mpp/buffer/DataBlockManager.java | 2 +-
.../iotdb/db/mpp/buffer/DataBlockService.java | 2 +-
.../iotdb/db/mpp/execution/QueryExecution.java | 3 +-
.../iotdb/db/mpp/execution/SchemaDriver.java | 2 +-
.../scheduler/InternalServiceClientFactory.java | 17 ++++---
.../scheduler/SimpleFragInstanceDispatcher.java | 3 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 7 +--
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 9 ++--
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 9 +++-
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 6 ++-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 5 +-
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 6 ++-
.../plan/node/metedata/read/SchemaFetchNode.java | 3 +-
.../plan/node/metedata/read/SchemaMergeNode.java | 12 +++--
.../node/metedata/write/CreateTimeSeriesNode.java | 27 +++++++++-
.../planner/plan/node/process/ExchangeNode.java | 6 +++
.../planner/plan/node/sink/FragmentSinkNode.java | 6 +++
.../apache/iotdb/db/service/InternalService.java | 58 +++++++++++++++++++---
...ataNodeMBean.java => InternalServiceMBean.java} | 3 +-
.../InternalServiceThriftHandler.java} | 4 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 1 +
.../db/mpp/sql/plan/DistributionPlannerTest.java | 27 +++++++---
32 files changed, 279 insertions(+), 98 deletions(-)
copy server/src/main/java/org/apache/iotdb/db/service/{DataNodeMBean.java => InternalServiceMBean.java} (95%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/buffer/DataBlockServiceThriftHandler.java => service/InternalServiceThriftHandler.java} (92%)