parquet-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ga...@apache.org
Subject [parquet-mr] branch master updated: PARQUET-1474: Less verbose and lower level logging for missing column/offset indexes (#563)
Date Thu, 13 Dec 2018 15:58:12 GMT
This is an automated email from the ASF dual-hosted git repository.

gabor pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/parquet-mr.git


The following commit(s) were added to refs/heads/master by this push:
     new 94555e1  PARQUET-1474: Less verbose and lower level logging for missing column/offset
indexes (#563)
94555e1 is described below

commit 94555e1f1dcd91bf371fd44dff8494385b699e09
Author: Gabor Szadovszky <gabor@apache.org>
AuthorDate: Thu Dec 13 16:58:07 2018 +0100

    PARQUET-1474: Less verbose and lower level logging for missing column/offset indexes (#563)
---
 .../parquet/internal/filter2/columnindex/ColumnIndexFilter.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/parquet-column/src/main/java/org/apache/parquet/internal/filter2/columnindex/ColumnIndexFilter.java
b/parquet-column/src/main/java/org/apache/parquet/internal/filter2/columnindex/ColumnIndexFilter.java
index fb3077e..f3efff7 100644
--- a/parquet-column/src/main/java/org/apache/parquet/internal/filter2/columnindex/ColumnIndexFilter.java
+++ b/parquet-column/src/main/java/org/apache/parquet/internal/filter2/columnindex/ColumnIndexFilter.java
@@ -85,7 +85,7 @@ public class ColumnIndexFilter implements Visitor<RowRanges> {
           return filterPredicateCompat.getFilterPredicate()
               .accept(new ColumnIndexFilter(columnIndexStore, paths, rowCount));
         } catch (MissingOffsetIndexException e) {
-          LOGGER.warn("Unable to do filtering", e);
+          LOGGER.info(e.getMessage());
           return RowRanges.createSingle(rowCount);
         }
       }
@@ -169,7 +169,7 @@ public class ColumnIndexFilter implements Visitor<RowRanges> {
     OffsetIndex oi = columnIndexStore.getOffsetIndex(columnPath);
     ColumnIndex ci = columnIndexStore.getColumnIndex(columnPath);
     if (ci == null) {
-      LOGGER.warn("No column index for column {} is available; Unable to filter on this column",
columnPath);
+      LOGGER.info("No column index for column {} is available; Unable to filter on this column",
columnPath);
       return allRows();
     }
 


Mime
View raw message