diff --git a/server/src/main/java/io/druid/metadata/SQLMetadataSegmentManager.java b/server/src/main/java/io/druid/metadata/SQLMetadataSegmentManager.java index 06128fb86caf..b97517500684 100644 --- a/server/src/main/java/io/druid/metadata/SQLMetadataSegmentManager.java +++ b/server/src/main/java/io/druid/metadata/SQLMetadataSegmentManager.java @@ -559,6 +559,7 @@ public List inTransaction(Handle handle, TransactionStatus status) thr ) ) .setFetchSize(connector.getStreamingFetchSize()) + .setMaxRows(limit) .bind("dataSource", dataSource) .bind("start", interval.getStart().toString()) .bind("end", interval.getEnd().toString())