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/02 10:24:30 UTC
[iotdb] 02/02: fix the bug
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch xingtanzjr/query_execution
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 08b659f9ebef1fbbccc7d3796a48d2552bc6d19f
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Sat Apr 2 18:22:36 2022 +0800
fix the bug
---
.../main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java | 4 ----
.../iotdb/db/mpp/execution/scheduler/AbstractFragInsStateFetcher.java | 2 +-
.../db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java | 2 +-
3 files changed, 2 insertions(+), 6 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java
index f35693d..0023b48 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java
@@ -163,8 +163,4 @@ public class QueryExecution {
public LogicalQueryPlan getLogicalPlan() {
return logicalPlan;
}
-
- public List<FragmentInstance> getFragmentInstances() {
- return fragmentInstances;
- }
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/AbstractFragInsStateFetcher.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/AbstractFragInsStateFetcher.java
index 0cd65f4..6f283b8 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/AbstractFragInsStateFetcher.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/AbstractFragInsStateFetcher.java
@@ -47,7 +47,7 @@ public abstract class AbstractFragInsStateFetcher implements IFragInstanceStateF
protected FragmentInstanceState fetchState(FragmentInstance instance) throws TException {
InternalService.Client client = InternalServiceClientFactory
- .getInternalServiceClient(instance.getHostEndpoint().ip, instance.getHostEndpoint().port);
+ .getInternalServiceClient(instance.getHostEndpoint().getIp(), instance.getHostEndpoint().getPort());
TFragmentInstanceStateResp resp = client.fetchFragmentInstanceState(new TFetchFragmentInstanceStateReq(getTId(instance)));
return FragmentInstanceState.valueOf(resp.state);
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java
index f544c8e..a48fc7b 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java
@@ -35,7 +35,7 @@ public class SimpleFragInstanceDispatcher implements IFragInstanceDispatcher {
try {
for (FragmentInstance instance : instances) {
InternalService.Client client = InternalServiceClientFactory.
- getInternalServiceClient(instance.getHostEndpoint().ip, instance.getHostEndpoint().port);
+ getInternalServiceClient(instance.getHostEndpoint().getIp(), instance.getHostEndpoint().getPort());
client.sendFragmentInstance(null);
}
} catch (TException e) {