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%)