Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix bug in numRowsScanned

This commit is contained in:
Justin Borromeo 2019-03-25 15:57:55 -07:00
parent da4fc66403
commit 219af478c8
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
processing/src/main/java/org/apache/druid/query/scan/ScanQueryRunnerFactory.java
View File

@ -259,9 +259,9 @@ public class ScanQueryRunnerFactory implements QueryRunnerFactory<ScanResultValu
Interval finalInterval = null; Interval finalInterval = null;
while (!doneScanning) { while (!doneScanning) {
ScanResultValue next = yielder.get(); ScanResultValue next = yielder.get();
numRowsScanned++;
List<ScanResultValue> singleEventScanResultValues = next.toSingleEventScanResultValues(); List<ScanResultValue> singleEventScanResultValues = next.toSingleEventScanResultValues();
for (ScanResultValue srv : singleEventScanResultValues) { for (ScanResultValue srv : singleEventScanResultValues) {
numRowsScanned++;
// Using an intermediate unbatched ScanResultValue is not that great memory-wise, but the column list // Using an intermediate unbatched ScanResultValue is not that great memory-wise, but the column list
// needs to be preserved for queries using the compactedList result format // needs to be preserved for queries using the compactedList result format
q.offer(srv); q.offer(srv);