Skip to content

Commit c86cf29

Browse files
committed
fix-some
1 parent 9bb3dcd commit c86cf29

File tree

2 files changed

+9
-3
lines changed

2 files changed

+9
-3
lines changed

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,9 +104,15 @@ public PipeTableResp filter(final Boolean whereClause, final String pipeName) {
104104
}
105105

106106
public PipeTableResp filter(
107-
final Boolean whereClause, final String pipeName, final String userName) {
107+
final Boolean whereClause,
108+
final String pipeName,
109+
final boolean isTableModel,
110+
final String userName) {
108111
final PipeTableResp resp = filter(whereClause, pipeName);
109-
resp.allPipeMeta.removeIf(meta -> !isVisible4User(userName, meta.getStaticMeta()));
112+
resp.allPipeMeta.removeIf(
113+
meta ->
114+
!meta.getStaticMeta().visibleUnder(isTableModel)
115+
|| !isVisible4User(userName, meta.getStaticMeta()));
110116
return resp;
111117
}
112118

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -241,7 +241,7 @@ public TSStatus dropPipe(TDropPipeReq req) {
241241
public TShowPipeResp showPipes(final TShowPipeReq req) {
242242
try {
243243
return ((PipeTableResp) configManager.getConsensusManager().read(new ShowPipePlanV2()))
244-
.filter(req.whereClause, req.pipeName, req.userName)
244+
.filter(req.whereClause, req.pipeName, req.isTableModel, req.userName)
245245
.convertToTShowPipeResp();
246246
} catch (final ConsensusException e) {
247247
LOGGER.warn("Failed in the read API executing the consensus layer due to: ", e);

0 commit comments

Comments
 (0)