aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical
diff options
context:
space:
mode:
authorGautam Parai <gparai@maprtech.com>2018-06-02 12:06:21 -0700
committerSorabh Hamirwasia <sorabh@apache.org>2018-06-07 08:52:40 -0700
commit2902ca9a5a780b3ee8b6ec56f01e3b3df4e2f37a (patch)
tree7389d25ed900b8c8c9d0b5e14abbe52b3f6b3361 /exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical
parenta27a1047b16621f6c3c6c181c97f8713231f6c6c (diff)
DRILL-6463 : Fix integer overflow in MockGroupScanPOP
closes #1303
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ConvertCountToDirectScan.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ConvertCountToDirectScan.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ConvertCountToDirectScan.java
index 62e40a540..1049b2c67 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ConvertCountToDirectScan.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/ConvertCountToDirectScan.java
@@ -154,7 +154,7 @@ public class ConvertCountToDirectScan extends Prule {
private Map<String, Long> collectCounts(PlannerSettings settings, DrillAggregateRel agg, DrillScanRel scan, DrillProjectRel project) {
final Set<String> implicitColumnsNames = ColumnExplorer.initImplicitFileColumns(settings.getOptions()).keySet();
final GroupScan oldGrpScan = scan.getGroupScan();
- final long totalRecordCount = oldGrpScan.getScanStats(settings).getRecordCount();
+ final long totalRecordCount = (long)oldGrpScan.getScanStats(settings).getRecordCount();
final LinkedHashMap<String, Long> result = new LinkedHashMap<>();
for (int i = 0; i < agg.getAggCallList().size(); i++) {