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/26 13:54:15 UTC

[iotdb] branch xingtanzjr/fix_endpoint_mpp updated (279e6c9bba -> f9e9a2bf39)

This is an automated email from the ASF dual-hosted git repository.

xingtanzjr pushed a change to branch xingtanzjr/fix_endpoint_mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from 279e6c9bba set correct InternalEndpoint and DataBlockEndpoint when palnning
     add 8fb2737aba [IOTDB-3013] Using Client Pool to replace previous DataBlockServiceClientFactory and InternalServiceClientFactory (#5674)
     add f9e9a2bf39 Merge branch 'master' into xingtanzjr/fix_endpoint_mpp

No new revisions were added by this update.

Summary of changes:
 .../iotdb/db/mpp/buffer/DataBlockManager.java      |  17 +--
 .../iotdb/db/mpp/buffer/DataBlockService.java      |   8 +-
 .../mpp/buffer/DataBlockServiceClientFactory.java  | 117 ---------------------
 .../org/apache/iotdb/db/mpp/buffer/SinkHandle.java |  58 ++++++++--
 .../apache/iotdb/db/mpp/buffer/SourceHandle.java   |  53 ++++++++--
 .../apache/iotdb/db/mpp/execution/Coordinator.java |  19 +++-
 .../iotdb/db/mpp/execution/QueryExecution.java     |  16 ++-
 .../scheduler/AbstractFragInsStateTracker.java     |  43 ++++++--
 .../mpp/execution/scheduler/ClusterScheduler.java  |  14 ++-
 .../scheduler/FixedRateFragInsStateTracker.java    |  11 +-
 .../scheduler/InternalServiceClientFactory.java    | 112 --------------------
 .../scheduler/SimpleFragInstanceDispatcher.java    |  60 ++++++++---
 .../execution/scheduler/SimpleQueryTerminator.java |  41 ++++++--
 .../execution/scheduler/StandaloneScheduler.java   |  12 ++-
 .../apache/iotdb/db/mpp/buffer/SinkHandleTest.java |  51 ++++++---
 .../iotdb/db/mpp/buffer/SourceHandleTest.java      |  65 ++++++++----
 .../iotdb/db/mpp/sql/plan/QueryPlannerTest.java    |  24 ++++-
 17 files changed, 376 insertions(+), 345 deletions(-)
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceClientFactory.java
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/InternalServiceClientFactory.java