[ https://issues.apache.org/jira/browse/DRILL-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562140#comment-16562140 ]
ASF GitHub Bot commented on DRILL-6641: --------------------------------------- vvysotskyi commented on a change in pull request #1406: DRILL-6641: Fix columnValueCounts in ParquetGroupScanStatistics when ParquetGroupScan has RowGroupInfo without column statistics URL: https://github.com/apache/drill/pull/1406#discussion_r206245343 ########## File path: exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScanStatistics.java ########## @@ -87,19 +91,14 @@ public void collect(List<RowGroupInfo> rowGroupInfos, ParquetTableMetadataBase p long rowCount = rowGroup.getRowCount(); for (ColumnMetadata column : rowGroup.getColumns()) { SchemaPath schemaPath = SchemaPath.getCompoundPath(column.getName()); - Long previousCount = columnValueCounts.get(schemaPath); - if (previousCount != null) { - if (previousCount != GroupScan.NO_COLUMN_STATS && column.isNumNullsSet()) { - Long newCount = rowCount - column.getNulls(); - columnValueCounts.put(schemaPath, columnValueCounts.get(schemaPath) + newCount); - } + MutableLong emptyCount = new MutableLong(); + MutableLong previousCount = + Optional.ofNullable(columnValueCounts.putIfAbsent(schemaPath, emptyCount)) Review comment: Thanks, replaced with `if (previousCount == null)` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > TestConvertCountToDirectScan.ensureCorrectCountWithMissingStatistics() test > fails randomly > ------------------------------------------------------------------------------------------ > > Key: DRILL-6641 > URL: https://issues.apache.org/jira/browse/DRILL-6641 > Project: Apache Drill > Issue Type: Bug > Reporter: Volodymyr Vysotskyi > Assignee: Volodymyr Vysotskyi > Priority: Major > Labels: ready-to-commit > Fix For: 1.15.0 > > > {{TestConvertCountToDirectScan.ensureCorrectCountWithMissingStatistics()}} > fails randomly with assertion error: > {noformat} > Found unwanted pattern in plan: DynamicPojoRecordReader > 00-00 Screen > 00-01 Project(cnt_str=[$0], cnt_total=[$1]) > 00-02 Scan(groupscan=[files = > [/home/vitalii/IdeaProjects/drill-fork/exec/java-exec/target/org.apache.drill.exec.planner.logical.TestConvertCountToDirectScan/dfsTestTmp/1532655133770-0/wide_str_table/0_0_2.parquet, > > /home/vitalii/IdeaProjects/drill-fork/exec/java-exec/target/org.apache.drill.exec.planner.logical.TestConvertCountToDirectScan/dfsTestTmp/1532655133770-0/wide_str_table/0_0_1.parquet], > numFiles = 2, DynamicPojoRecordReader{records = [[0, 2]]}]) > {noformat} > This test uses a table with two partitions and it may fail when a partition > with set statistics is taken first in the > {{ParquetGroupScanStatistics.collect()}} method, which is indirectly called > from {{ConvertCountToDirectScan}} rule. -- This message was sent by Atlassian JIRA (v7.6.3#76005)