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

This commit is contained in:
Himanshu 2016-11-01 11:39:55 -05:00 committed by Fangjin Yang
parent 89d9c61894
commit 0e269ce72a
1 changed files with 1 additions and 0 deletions

View File

@ -559,6 +559,7 @@ public class SQLMetadataSegmentManager implements MetadataSegmentManager
)
)
.setFetchSize(connector.getStreamingFetchSize())
.setMaxRows(limit)
.bind("dataSource", dataSource)
.bind("start", interval.getStart().toString())
.bind("end", interval.getEnd().toString())