From 4b427238fa4efff66a2d391d2faf886d24f73a65 Mon Sep 17 00:00:00 2001 From: Himanshu Date: Tue, 1 Nov 2016 16:10:20 -0500 Subject: [PATCH] max row limit is necessary is connector is setup for streaming (#3635) (#3638) --- .../main/java/io/druid/metadata/SQLMetadataSegmentManager.java | 1 + 1 file changed, 1 insertion(+) 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())