SteveYurongSu commented on code in PR #9245:
URL: https://github.com/apache/iotdb/pull/9245#discussion_r1130636435
##########
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/TsFilePipeInfo.java:
##########
@@ -81,14 +80,7 @@ PipeType getType() {
@Override
public TShowPipeInfo getTShowPipeInfo() {
- return new TShowPipeInfo(
- createTime,
- pipeName,
- SyncConstant.ROLE_SENDER,
- pipeSinkName,
- status.name(),
- String.format("SyncDelOp=%s,DataStartTimestamp=%s", syncDelOp,
dataStartTimestamp),
- messageType.name());
+ return new TShowPipeInfo();
Review Comment:
Can this file be removed?
##########
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java:
##########
@@ -1563,10 +1562,11 @@ public SettableFuture<ConfigTaskResult>
showPipe(ShowPipeStatement showPipeState
if (!StringUtils.isEmpty(showPipeStatement.getPipeName())) {
tShowPipeReq.setPipeName(showPipeStatement.getPipeName());
}
+ if (showPipeStatement.getWhereClause()) {
+ tShowPipeReq.setWhereClause(true);
+ }
TShowPipeResp resp = configNodeClient.showPipe(tShowPipeReq);
- List<TShowPipeInfo> tShowPipeInfoList =
-
SyncService.getInstance().showPipeForReceiver(showPipeStatement.getPipeName());
- tShowPipeInfoList.addAll(resp.getPipeInfoList());
+ List<TShowPipeInfo> tShowPipeInfoList = resp.getPipeInfoList();
Review Comment:
```suggestion
List<TShowPipeInfo> tShowPipeInfoList = new TShowPipeInfo();
```
--
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]
