max row limit is necessary is connector is setup for streaming (#3635) (

#3638)
apache · Nov 1, 2016 · 4b42723 · 4b42723
1 parent 616735b
commit 4b42723
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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<Interval> inTransaction(Handle handle, TransactionStatus status) thr
                     )
                 )
                 .setFetchSize(connector.getStreamingFetchSize())
+                .setMaxRows(limit)
                 .bind("dataSource", dataSource)
                 .bind("start", interval.getStart().toString())
                 .bind("end", interval.getEnd().toString())