chengjianyun commented on a change in pull request #4079:
URL: https://github.com/apache/iotdb/pull/4079#discussion_r738252253
##########
File path:
cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
##########
@@ -1441,31 +1446,33 @@ public TSStatus
processNonPartitionedMetaPlan(PhysicalPlan plan) {
return result;
}
- /**
- * Forward a non-query plan to the data port of "receiver"
- *
- * @param plan a non-query plan
- * @param header to determine which DataGroupMember of "receiver" will
process the request.
- * @return a TSStatus indicating if the forwarding is successful.
- */
- private TSStatus forwardDataPlanAsync(PhysicalPlan plan, Node receiver,
RaftNode header)
- throws IOException {
- RaftService.AsyncClient client =
- getClientProvider().getAsyncDataClient(receiver,
RaftServer.getWriteOperationTimeoutMS());
- return forwardPlanAsync(plan, receiver, header, client);
- }
-
- private TSStatus forwardDataPlanSync(PhysicalPlan plan, Node receiver,
RaftNode header)
- throws IOException {
- Client client;
- try {
- client =
- getClientProvider().getSyncDataClient(receiver,
RaftServer.getWriteOperationTimeoutMS());
- } catch (TException e) {
- throw new IOException(e);
- }
- return forwardPlanSync(plan, receiver, header, client);
- }
+ // /**
+ // * Forward a non-query plan to the data port of "receiver"
+ // *
+ // * @param plan a non-query plan
+ // * @param header to determine which DataGroupMember of "receiver" will
process the request.
+ // * @return a TSStatus indicating if the forwarding is successful.
+ // */
+ // private TSStatus forwardDataPlanAsync(PhysicalPlan plan, Node receiver,
RaftNode header)
+ // throws IOException {
+ // RaftService.AsyncClient client =
+ // getClientProvider()
+ // .getAsyncDataClient(receiver,
ClusterConstant.getWriteOperationTimeoutMS());
+ // return forwardPlanAsync(plan, receiver, header, client);
+ // }
+ //
+ // private TSStatus forwardDataPlanSync(PhysicalPlan plan, Node receiver,
RaftNode header)
+ // throws IOException {
+ // Client client;
+ // try {
+ // client =
+ // getClientProvider()
+ // .getSyncDataClient(receiver,
ClusterConstant.getWriteOperationTimeoutMS());
+ // } catch (TException e) {
+ // throw new IOException(e);
+ // }
+ // return forwardPlanSync(plan, receiver, header, client);
+ // }
Review comment:
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
